org.usergrid.mq
Interface QueueManager
- All Known Implementing Classes:
- QueueManagerImpl
public interface QueueManager
Method Summary |
QueueSet |
addSubscribersToQueue(String publisherQueuePath,
List<String> subscriberQueuePaths)
|
Results |
getAggregateQueueCounters(String queuePath,
CounterQuery query)
|
Results |
getAggregateQueueCounters(String queuePath,
String category,
String counterName,
CounterResolution resolution,
long start,
long finish,
boolean pad)
|
QueueSet |
getChildQueues(String publisherQueuePath,
String firstQueuePath,
int count)
|
QueueResults |
getFromQueue(String queuePath,
QueueQuery query)
|
Message |
getMessage(UUID messageId)
|
UUID |
getNewConsumerId()
|
Queue |
getQueue(String queuePath)
|
Set<String> |
getQueueCounterNames(String queuePath)
|
Map<String,Long> |
getQueueCounters(String queuePath)
|
QueueSet |
getQueues(String firstQueuePath,
int limit)
|
QueueSet |
getSubscribers(String publisherQueuePath,
String firstSubscriberQueuePath,
int limit)
|
QueueSet |
getSubscriptions(String subscriberQueuePath,
String firstSubscriptionQueuePath,
int limit)
|
void |
incrementAggregateQueueCounters(String queuePath,
String category,
String counterName,
long value)
|
void |
incrementQueueCounter(String queuePath,
String name,
long value)
|
void |
incrementQueueCounters(String queuePath,
Map<String,Long> counts)
|
List<Message> |
postToQueue(String queuePath,
List<Message> messages)
|
Message |
postToQueue(String queuePath,
Message message)
|
QueueSet |
removeSubscribersFromQueue(String publisherQueuePath,
List<String> subscriberQueuePaths)
|
QueueSet |
searchSubscribers(String publisherQueuePath,
Query query)
|
QueueSet |
subscribeToQueue(String publisherQueuePath,
String subscriberQueuePath)
|
QueueSet |
subscribeToQueues(String subscriberQueuePath,
List<String> publisherQueuePaths)
|
QueueSet |
unsubscribeFromQueue(String publisherQueuePath,
String subscriberQueuePath)
|
QueueSet |
unsubscribeFromQueues(String subscriberQueuePath,
List<String> publisherQueuePaths)
|
Queue |
updateQueue(String queuePath,
Map<String,Object> properties)
|
Queue |
updateQueue(String queuePath,
Queue queue)
|
getQueue
Queue getQueue(String queuePath)
updateQueue
Queue updateQueue(String queuePath,
Map<String,Object> properties)
updateQueue
Queue updateQueue(String queuePath,
Queue queue)
postToQueue
Message postToQueue(String queuePath,
Message message)
postToQueue
List<Message> postToQueue(String queuePath,
List<Message> messages)
getFromQueue
QueueResults getFromQueue(String queuePath,
QueueQuery query)
getMessage
Message getMessage(UUID messageId)
getNewConsumerId
UUID getNewConsumerId()
getQueues
QueueSet getQueues(String firstQueuePath,
int limit)
subscribeToQueue
QueueSet subscribeToQueue(String publisherQueuePath,
String subscriberQueuePath)
unsubscribeFromQueue
QueueSet unsubscribeFromQueue(String publisherQueuePath,
String subscriberQueuePath)
addSubscribersToQueue
QueueSet addSubscribersToQueue(String publisherQueuePath,
List<String> subscriberQueuePaths)
removeSubscribersFromQueue
QueueSet removeSubscribersFromQueue(String publisherQueuePath,
List<String> subscriberQueuePaths)
subscribeToQueues
QueueSet subscribeToQueues(String subscriberQueuePath,
List<String> publisherQueuePaths)
unsubscribeFromQueues
QueueSet unsubscribeFromQueues(String subscriberQueuePath,
List<String> publisherQueuePaths)
getSubscribers
QueueSet getSubscribers(String publisherQueuePath,
String firstSubscriberQueuePath,
int limit)
getSubscriptions
QueueSet getSubscriptions(String subscriberQueuePath,
String firstSubscriptionQueuePath,
int limit)
searchSubscribers
QueueSet searchSubscribers(String publisherQueuePath,
Query query)
getChildQueues
QueueSet getChildQueues(String publisherQueuePath,
String firstQueuePath,
int count)
incrementAggregateQueueCounters
void incrementAggregateQueueCounters(String queuePath,
String category,
String counterName,
long value)
getAggregateQueueCounters
Results getAggregateQueueCounters(String queuePath,
String category,
String counterName,
CounterResolution resolution,
long start,
long finish,
boolean pad)
getAggregateQueueCounters
Results getAggregateQueueCounters(String queuePath,
CounterQuery query)
throws Exception
- Throws:
Exception
getQueueCounterNames
Set<String> getQueueCounterNames(String queuePath)
throws Exception
- Throws:
Exception
incrementQueueCounters
void incrementQueueCounters(String queuePath,
Map<String,Long> counts)
incrementQueueCounter
void incrementQueueCounter(String queuePath,
String name,
long value)
getQueueCounters
Map<String,Long> getQueueCounters(String queuePath)
throws Exception
- Throws:
Exception
Copyright © 2013. All Rights Reserved.