org.apache.activemq.broker.region
Class QueueBrowserSubscription
java.lang.Object
org.apache.activemq.broker.region.AbstractSubscription
org.apache.activemq.broker.region.PrefetchSubscription
org.apache.activemq.broker.region.QueueSubscription
org.apache.activemq.broker.region.QueueBrowserSubscription
- All Implemented Interfaces:
- LockOwner, Subscription
public class QueueBrowserSubscription
- extends QueueSubscription
Methods inherited from class org.apache.activemq.broker.region.PrefetchSubscription |
acknowledge, add, add, createMessageDispatch, dispatchMatched, getDequeueCounter, getDispatchedCounter, getDispatchedQueueSize, getEnqueueCounter, getPendingQueueSize, isFull, isHighWaterMark, isLowWaterMark, isRecoveryRequired, optimizePrefetch, processMessageDispatchNotification, pullMessage, remove, updateConsumerPrefetch |
Methods inherited from class org.apache.activemq.broker.region.AbstractSubscription |
gc, getConsumerInfo, getContext, getInfo, getObjectName, getPrefetchSize, getSelector, getSelectorExpression, isSlaveBroker, matches, setObjectName, setSelector |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
QueueBrowserSubscription
public QueueBrowserSubscription(Broker broker,
ConnectionContext context,
ConsumerInfo info)
throws javax.jms.InvalidSelectorException
- Throws:
javax.jms.InvalidSelectorException
canDispatch
protected boolean canDispatch(MessageReference node)
- Description copied from class:
PrefetchSubscription
- Use when a matched message is about to be dispatched to the client.
- Overrides:
canDispatch
in class QueueSubscription
- Returns:
- false if the message should not be dispatched to the client (another sub may have already dispatched it
for example).
toString
public java.lang.String toString()
- Overrides:
toString
in class QueueSubscription
browseDone
public void browseDone()
throws java.lang.Exception
- Throws:
java.lang.Exception
matches
public boolean matches(MessageReference node,
MessageEvaluationContext context)
throws java.io.IOException
- Description copied from interface:
Subscription
- Is the subscription interested in the message?
- Specified by:
matches
in interface Subscription
- Overrides:
matches
in class AbstractSubscription
- Returns:
-
- Throws:
java.io.IOException
acknowledge
protected void acknowledge(ConnectionContext context,
MessageAck ack,
MessageReference n)
throws java.io.IOException
- Since we are a browser we don't really remove the message from the queue.
- Overrides:
acknowledge
in class QueueSubscription
- Throws:
java.io.IOException
Copyright © 2011 Apache Software Foundation. All Rights Reserved.