public class QueueBrowserSubscription extends QueueSubscription
Modifier and Type | Field and Description |
---|---|
protected static org.slf4j.Logger |
LOG |
dispatched, dispatchLock, pending, pendingLock, scheduler, usageManager
broker, context, destinationFilter, destinations, info, prefetchExtension
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.
|
boolean |
atMax() |
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 |
isDuplicate(MessageId messageId) |
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.
|
void |
setMaxMessages(long max) |
String |
toString() |
destroy, getLockPriority, isDropped, isLockExclusive
acknowledge, add, add, assertAckMatchesDispatched, countBeforeFull, createMessageDispatch, dispatch, dispatchPending, getDequeueCounter, getDispatchedCounter, getDispatchedQueueSize, getEnqueueCounter, getInFlightSize, getMaxAuditDepth, getMaxProducersToAudit, getPending, getPendingMessageSize, getPendingQueueSize, isFull, isHighWaterMark, isLowWaterMark, isRecoveryRequired, onDispatch, processMessageDispatchNotification, pullMessage, remove, sendToDLQ, setMaxAuditDepth, setMaxProducersToAudit, setPending, setPendingBatchSize, setPrefetchSize, updateConsumerPrefetch
addDestination, addRecoveredMessage, contractPrefetchExtension, decrementPrefetchExtension, doAddRecoveredMessage, expandPrefetchExtension, gc, getActiveMQDestination, getConsumedCount, getConsumerInfo, getContext, getCursorMemoryHighWaterMark, getInFlightMessageSize, getInFlightUsage, getInfo, getObjectName, getPrefetchExtension, getPrefetchSize, getSelector, getSelectorExpression, getSubscriptionStatistics, getTimeOfLastMessageAck, incrementConsumedCount, isBrowser, isSlowConsumer, isUsePrefetchExtension, isWildcard, matches, removeDestination, resetConsumedCount, setCursorMemoryHighWaterMark, setObjectName, setSelector, setSlowConsumer, setTimeOfLastMessageAck, setUsePrefetchExtension, unmatched, wakeupDestinationsForDispatch
protected static final org.slf4j.Logger LOG
public QueueBrowserSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info) throws javax.jms.JMSException
javax.jms.JMSException
protected boolean canDispatch(MessageReference node)
PrefetchSubscription
canDispatch
in class QueueSubscription
public String toString()
toString
in class QueueSubscription
public void destinationsAdded() throws Exception
Exception
public boolean isDuplicate(MessageId messageId)
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 void decrementQueueRef() throws Exception
Exception
public List<MessageReference> remove(ConnectionContext context, Destination destination) throws Exception
Subscription
remove
in interface Subscription
remove
in class PrefetchSubscription
Exception
public boolean atMax()
public void setMaxMessages(long max)
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.