public class QueueBrowserSubscription extends QueueSubscription
dequeueCounter, dispatchCounter, dispatched, dispatchLock, enqueueCounter, pending, pendingLock, prefetchExtension, scheduler, usageManager, usePrefetchExtension
broker, context, destinationFilter, destinations, info
HIGH_PRIORITY_LOCK_OWNER
Constructor and Description |
---|
QueueBrowserSubscription(Broker broker,
SystemUsage usageManager,
ConnectionContext context,
ConsumerInfo info) |
Modifier and Type | Method and Description |
---|---|
protected void |
acknowledge(ConnectionContext context,
MessageAck ack,
MessageReference n)
Since we are a browser we don't really remove the message from the queue.
|
protected boolean |
canDispatch(MessageReference node)
Use when a matched message is about to be dispatched to the client.
|
void |
decrementQueueRef() |
void |
destinationsAdded() |
void |
incrementQueueRef() |
boolean |
matches(MessageReference node,
MessageEvaluationContext context)
Is the subscription interested in the message?
|
List<MessageReference> |
remove(ConnectionContext context,
Destination destination)
The subscription will be no longer be receiving messages from the destination.
|
String |
toString() |
assignGroupToMe, destroy, getLockPriority, isDropped, isLockExclusive
acknowledge, add, add, assertAckMatchesDispatched, countBeforeFull, createMessageDispatch, dispatch, dispatchPending, getDequeueCounter, getDispatchedCounter, getDispatchedQueueSize, getEnqueueCounter, getInFlightSize, getMaxAuditDepth, getMaxProducersToAudit, getPending, getPendingQueueSize, getPrefetchExtension, isFull, isHighWaterMark, isLowWaterMark, isRecoveryRequired, isUsePrefetchExtension, onDispatch, processMessageDispatchNotification, pullMessage, sendToDLQ, setMaxAuditDepth, setMaxProducersToAudit, setPending, setPendingBatchSize, setUsePrefetchExtension, updateConsumerPrefetch
addDestination, addRecoveredMessage, doAddRecoveredMessage, gc, getActiveMQDestination, getConsumerInfo, getContext, getCursorMemoryHighWaterMark, getInFlightUsage, getInfo, getObjectName, getPrefetchSize, getSelector, getSelectorExpression, isBrowser, isSlave, isSlowConsumer, matches, removeDestination, setCursorMemoryHighWaterMark, setObjectName, setPrefetchSize, setSelector, setSlowConsumer, unmatched
public QueueBrowserSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info) throws javax.jms.InvalidSelectorException
javax.jms.InvalidSelectorException
protected boolean canDispatch(MessageReference node)
PrefetchSubscription
canDispatch
in class QueueSubscription
public String toString()
toString
in class QueueSubscription
public boolean matches(MessageReference node, MessageEvaluationContext context) throws IOException
Subscription
matches
in interface Subscription
matches
in class AbstractSubscription
IOException
protected void acknowledge(ConnectionContext context, MessageAck ack, MessageReference n) throws IOException
acknowledge
in class QueueSubscription
IOException
public void incrementQueueRef()
public List<MessageReference> remove(ConnectionContext context, Destination destination) throws Exception
Subscription
remove
in interface Subscription
remove
in class PrefetchSubscription
Exception
Copyright © 2005–2015 The Apache Software Foundation. All rights reserved.