Methods in org.usergrid.mq that return QueueSet |
QueueSet |
QueueSet.addQueue(String queuePath,
UUID queueId)
|
QueueSet |
QueueManager.addSubscribersToQueue(String publisherQueuePath,
List<String> subscriberQueuePaths)
|
QueueSet |
QueueManager.getChildQueues(String publisherQueuePath,
String firstQueuePath,
int count)
|
QueueSet |
QueueManager.getQueues(String firstQueuePath,
int limit)
|
QueueSet |
QueueManager.getSubscribers(String publisherQueuePath,
String firstSubscriberQueuePath,
int limit)
|
QueueSet |
QueueManager.getSubscriptions(String subscriberQueuePath,
String firstSubscriptionQueuePath,
int limit)
|
QueueSet |
QueueManager.removeSubscribersFromQueue(String publisherQueuePath,
List<String> subscriberQueuePaths)
|
QueueSet |
QueueManager.searchSubscribers(String publisherQueuePath,
Query query)
|
QueueSet |
QueueManager.subscribeToQueue(String publisherQueuePath,
String subscriberQueuePath)
|
QueueSet |
QueueManager.subscribeToQueues(String subscriberQueuePath,
List<String> publisherQueuePaths)
|
QueueSet |
QueueManager.unsubscribeFromQueue(String publisherQueuePath,
String subscriberQueuePath)
|
QueueSet |
QueueManager.unsubscribeFromQueues(String subscriberQueuePath,
List<String> publisherQueuePaths)
|
Methods in org.usergrid.mq.cassandra that return QueueSet |
QueueSet |
QueueManagerImpl.addSubscribersToQueue(String publisherQueuePath,
List<String> subscriberQueuePaths)
|
QueueSet |
QueueManagerImpl.getChildQueues(String publisherQueuePath,
String firstQueuePath,
int count)
|
QueueSet |
QueueManagerImpl.getQueues(String firstQueuePath,
int limit)
|
QueueSet |
QueueManagerImpl.getSubscribers(String publisherQueuePath,
String firstSubscriberQueuePath,
int limit)
|
QueueSet |
QueueManagerImpl.getSubscriptions(String subscriberQueuePath,
String firstSubscriptionQueuePath,
int limit)
|
QueueSet |
QueueManagerImpl.removeSubscribersFromQueue(String publisherQueuePath,
List<String> subscriberQueuePaths)
|
QueueSet |
QueueManagerImpl.searchQueueIndex(UUID publisherQueueId,
QueryProcessor.QuerySlice slice,
int count)
|
QueueSet |
QueueManagerImpl.searchSubscribers(String publisherQueuePath,
Query query)
|
QueueSet |
QueueManagerImpl.subscribeToQueue(String publisherQueuePath,
String subscriberQueuePath)
|
QueueSet |
QueueManagerImpl.subscribeToQueues(String subscriberQueuePath,
List<String> publisherQueuePaths)
|
QueueSet |
QueueManagerImpl.unsubscribeFromQueue(String publisherQueuePath,
String subscriberQueuePath)
|
QueueSet |
QueueManagerImpl.unsubscribeFromQueues(String subscriberQueuePath,
List<String> publisherQueuePaths)
|