Save This Page
Home » activemq-parent-5.3.1-source-release » org.apache » activemq » broker » region » [javadoc | source]
org.apache.activemq.broker.region
public class: Queue [javadoc | source]
java.lang.Object
   org.apache.activemq.broker.region.BaseDestination
      org.apache.activemq.broker.region.Queue

All Implemented Interfaces:
    Task, UsageListener, Destination

Direct Known Subclasses:
    TempQueue

The Queue is a List of MessageEntry objects that are dispatched to matching subscriptions.
Nested Class Summary:
class  Queue.TimeoutMessage   
class  Queue.FlowControlTimeoutTask   
final class  Queue.QueueThread   
class  Queue.BrowserDispatch   
Field Summary
protected static final  Log LOG     
protected final  TaskRunnerFactory taskFactory     
protected  TaskRunner taskRunner     
protected final  List<Subscription> consumers     
protected  PendingMessageCursor messages     
protected final  Map<MessageId, Runnable> messagesWaitingForSpace     
 DelayQueue<TimeoutMessage> flowControlTimeoutMessages     
 LinkedList<BrowserDispatch> browserDispatches     
Fields inherited from org.apache.activemq.broker.region.BaseDestination:
MAX_PAGE_SIZE,  MAX_BROWSE_PAGE_SIZE,  EXPIRE_MESSAGE_PERIOD,  destination,  broker,  store,  systemUsage,  memoryUsage,  warnOnProducerFlowControl,  blockedProducerWarningInterval,  destinationStatistics,  brokerService,  regionBroker,  deadLetterStrategy,  expireMessagesPeriod,  cursorMemoryHighWaterMark
Constructor:
 public Queue(BrokerService brokerService,
    ActiveMQDestination destination,
    MessageStore store,
    DestinationStatistics parentStats,
    TaskRunnerFactory taskFactory) throws Exception 
Method from org.apache.activemq.broker.region.Queue Summary:
acknowledge,   addSubscription,   browse,   copyMatchingMessages,   copyMatchingMessagesTo,   copyMatchingMessagesTo,   copyMessageTo,   createConnectionContext,   createMessageIdFilter,   createSelectorFilter,   doBrowse,   doMessageSend,   gc,   getActiveMQDestination,   getConsumers,   getConsumersBeforeDispatchStarts,   getDispatchPolicy,   getMessage,   getMessageGroupMapFactory,   getMessageGroupOwners,   getMessages,   getNextBrowserDispatch,   getTimeBeforeDispatchStarts,   initialize,   isOptimizedDispatch,   isStrictOrderDispatch,   isUseConsumerPriority,   iterate,   loadMessage,   messageExpired,   messageExpired,   moveMatchingMessagesTo,   moveMatchingMessagesTo,   moveMatchingMessagesTo,   moveMessageTo,   moveMessageTo,   onUsageChanged,   pageInMessages,   processDispatchNotification,   purge,   removeMatchingMessages,   removeMatchingMessages,   removeMatchingMessages,   removeMessage,   removeMessage,   removeMessage,   removeMessage,   removeSubscription,   send,   sendMessage,   setConsumersBeforeDispatchStarts,   setDispatchPolicy,   setMessageGroupMapFactory,   setMessages,   setOptimizedDispatch,   setStrictOrderDispatch,   setTimeBeforeDispatchStarts,   setUseConsumerPriority,   start,   stop,   toString,   wakeup
Methods from org.apache.activemq.broker.region.BaseDestination:
addProducer,   dispose,   fastProducer,   getActiveMQDestination,   getBlockedProducerWarningInterval,   getCursorMemoryHighWaterMark,   getDeadLetterStrategy,   getDestinationSequenceId,   getDestinationStatistics,   getExpireMessagesPeriod,   getMaxAuditDepth,   getMaxBrowsePageSize,   getMaxExpirePageSize,   getMaxPageSize,   getMaxProducersToAudit,   getMemoryUsage,   getMessageStore,   getMinimumMessageSize,   getName,   initialize,   isActive,   isAdvisdoryForFastProducers,   isAdvisoryForConsumed,   isAdvisoryForDelivery,   isAdvisoryForDiscardingMessages,   isAdvisoryForSlowConsumers,   isAdvisoryWhenFull,   isEnableAudit,   isFull,   isLazyDispatch,   isProducerFlowControl,   isSendAdvisoryIfNoConsumers,   isUseCache,   messageConsumed,   messageDelivered,   messageDiscarded,   onMessageWithNoConsumers,   processDispatchNotification,   removeProducer,   setAdvisdoryForFastProducers,   setAdvisoryForConsumed,   setAdvisoryForDelivery,   setAdvisoryForDiscardingMessages,   setAdvisoryForSlowConsumers,   setAdvisoryWhenFull,   setBlockedProducerWarningInterval,   setCursorMemoryHighWaterMark,   setDeadLetterStrategy,   setEnableAudit,   setExpireMessagesPeriod,   setLazyDispatch,   setMaxAuditDepth,   setMaxBrowsePageSize,   setMaxExpirePageSize,   setMaxPageSize,   setMaxProducersToAudit,   setMinimumMessageSize,   setProducerFlowControl,   setSendAdvisoryIfNoConsumers,   setUseCache,   slowConsumer
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.broker.region.Queue Detail:
 public  void acknowledge(ConnectionContext context,
    Subscription sub,
    MessageAck ack,
    MessageReference node) throws IOException 
 public  void addSubscription(ConnectionContext context,
    Subscription sub) throws Exception 
 public Message[] browse() 
 public int copyMatchingMessages(ConnectionContext context,
    MessageReferenceFilter filter,
    ActiveMQDestination dest,
    int maximumMessages) throws Exception 
    Copies the messages matching the given filter up to the maximum number of matched messages
 public int copyMatchingMessagesTo(ConnectionContext context,
    String selector,
    ActiveMQDestination dest) throws Exception 
    Copies the messages matching the given selector
 public int copyMatchingMessagesTo(ConnectionContext context,
    String selector,
    ActiveMQDestination dest,
    int maximumMessages) throws Exception 
    Copies the messages matching the given selector up to the maximum number of matched messages
 public boolean copyMessageTo(ConnectionContext context,
    String messageId,
    ActiveMQDestination dest) throws Exception 
    Copies the message matching the given messageId
 protected ConnectionContext createConnectionContext() 
 protected MessageReferenceFilter createMessageIdFilter(String messageId) 
 protected MessageReferenceFilter createSelectorFilter(String selector) throws InvalidSelectorException 
 public  void doBrowse(List<Message> browseList,
    int max) 
  void doMessageSend(ProducerBrokerExchange producerExchange,
    Message message) throws IOException, Exception 
 public  void gc() 
 public ActiveMQDestination getActiveMQDestination() 
 public List<Subscription> getConsumers() 
 public int getConsumersBeforeDispatchStarts() 
 public DispatchPolicy getDispatchPolicy() 
 public Message getMessage(String id) 
 public MessageGroupMapFactory getMessageGroupMapFactory() 
 public MessageGroupMap getMessageGroupOwners() 
 public PendingMessageCursor getMessages() 
 BrowserDispatch getNextBrowserDispatch() 
 public int getTimeBeforeDispatchStarts() 
 public  void initialize() throws Exception 
 public boolean isOptimizedDispatch() 
 public boolean isStrictOrderDispatch() 
 public boolean isUseConsumerPriority() 
 public boolean iterate() 
 Message loadMessage(MessageId messageId) throws IOException 
 public  void messageExpired(ConnectionContext context,
    MessageReference reference) 
 public  void messageExpired(ConnectionContext context,
    Subscription subs,
    MessageReference reference) 
 public int moveMatchingMessagesTo(ConnectionContext context,
    String selector,
    ActiveMQDestination dest) throws Exception 
    Moves the messages matching the given selector
 public int moveMatchingMessagesTo(ConnectionContext context,
    String selector,
    ActiveMQDestination dest,
    int maximumMessages) throws Exception 
    Moves the messages matching the given selector up to the maximum number of matched messages
 public int moveMatchingMessagesTo(ConnectionContext context,
    MessageReferenceFilter filter,
    ActiveMQDestination dest,
    int maximumMessages) throws Exception 
    Moves the messages matching the given filter up to the maximum number of matched messages
 public boolean moveMessageTo(ConnectionContext context,
    Message m,
    ActiveMQDestination dest) throws Exception 
    Move a message
 public boolean moveMessageTo(ConnectionContext context,
    String messageId,
    ActiveMQDestination dest) throws Exception 
    Moves the message matching the given messageId
 public  void onUsageChanged(Usage usage,
    int oldPercentUsage,
    int newPercentUsage) 
 protected  void pageInMessages(boolean force) throws Exception 
 public  void processDispatchNotification(MessageDispatchNotification messageDispatchNotification) throws Exception 
 public  void purge() throws Exception 
 public int removeMatchingMessages(String selector) throws Exception 
    Removes the messages matching the given selector
 public int removeMatchingMessages(String selector,
    int maximumMessages) throws Exception 
    Removes the messages matching the given selector up to the maximum number of matched messages
 public int removeMatchingMessages(MessageReferenceFilter filter,
    int maximumMessages) throws Exception 
    Removes the messages matching the given filter up to the maximum number of matched messages
 public boolean removeMessage(String messageId) throws Exception 
    Removes the message matching the given messageId
 protected  void removeMessage(ConnectionContext c,
    QueueMessageReference r) throws IOException 
 protected  void removeMessage(ConnectionContext c,
    Subscription subs,
    QueueMessageReference r) throws IOException 
 protected  void removeMessage(ConnectionContext context,
    Subscription sub,
    QueueMessageReference reference,
    MessageAck ack) throws IOException 
 public  void removeSubscription(ConnectionContext context,
    Subscription sub,
    long lastDeiveredSequenceId) throws Exception 
 public  void send(ProducerBrokerExchange producerExchange,
    Message message) throws Exception 
 final  void sendMessage(ConnectionContext context,
    Message msg) throws Exception 
 public  void setConsumersBeforeDispatchStarts(int consumersBeforeDispatchStarts) 
 public  void setDispatchPolicy(DispatchPolicy dispatchPolicy) 
 public  void setMessageGroupMapFactory(MessageGroupMapFactory messageGroupMapFactory) 
 public  void setMessages(PendingMessageCursor messages) 
 public  void setOptimizedDispatch(boolean optimizedDispatch) 
 public  void setStrictOrderDispatch(boolean strictOrderDispatch) 
 public  void setTimeBeforeDispatchStarts(int timeBeforeDispatchStarts) 
 public  void setUseConsumerPriority(boolean useConsumerPriority) 
 public  void start() throws Exception 
 public  void stop() throws Exception 
 public String toString() 
 public  void wakeup()