public class QueueSubscription extends PrefetchSubscription implements LockOwner
dispatched, dispatchLock, pending, pendingLock, scheduler, usageManager
broker, context, destinationFilter, destinations, info, prefetchExtension
HIGH_PRIORITY_LOCK_OWNER
Constructor and Description |
---|
QueueSubscription(Broker broker,
SystemUsage usageManager,
ConnectionContext context,
ConsumerInfo info) |
Modifier and Type | Method and Description |
---|---|
protected void |
acknowledge(ConnectionContext context,
MessageAck ack,
MessageReference n)
In the queue case, mark the node as dropped and then a gc cycle will
remove it from the queue.
|
protected boolean |
canDispatch(MessageReference n)
Use when a matched message is about to be dispatched to the client.
|
void |
destroy()
Called when the subscription is destroyed.
|
int |
getLockPriority() |
protected boolean |
isDropped(MessageReference node) |
boolean |
isLockExclusive() |
String |
toString() |
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, 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, matches, removeDestination, resetConsumedCount, setCursorMemoryHighWaterMark, setObjectName, setSelector, setSlowConsumer, setTimeOfLastMessageAck, setUsePrefetchExtension, unmatched, wakeupDestinationsForDispatch
public QueueSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info) throws javax.jms.JMSException
javax.jms.JMSException
protected void acknowledge(ConnectionContext context, MessageAck ack, MessageReference n) throws IOException
acknowledge
in class PrefetchSubscription
IOException
protected boolean canDispatch(MessageReference n) throws IOException
PrefetchSubscription
canDispatch
in class PrefetchSubscription
IOException
public int getLockPriority()
getLockPriority
in interface LockOwner
public boolean isLockExclusive()
isLockExclusive
in interface LockOwner
public void destroy()
Subscription
destroy
in interface Subscription
protected boolean isDropped(MessageReference node)
isDropped
in class PrefetchSubscription
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.