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)
           
 

Method Detail

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.