public class QueueSubscription extends PrefetchSubscription implements LockOwner
dequeueCounter, dispatchCounter, dispatched, dispatchLock, enqueueCounter, pending, pendingLock, prefetchExtension, scheduler, usageManager, usePrefetchExtension
broker, context, destinationFilter, destinations, info
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 void |
assignGroupToMe(MessageGroupMap messageGroupOwners,
MessageReference n,
String groupId)
Assigns the message group to this subscription and set the flag on the
message that it is the first message to be dispatched.
|
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, getPendingQueueSize, getPrefetchExtension, isFull, isHighWaterMark, isLowWaterMark, isRecoveryRequired, isUsePrefetchExtension, onDispatch, processMessageDispatchNotification, pullMessage, remove, 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, matches, removeDestination, setCursorMemoryHighWaterMark, setObjectName, setPrefetchSize, setSelector, setSlowConsumer, unmatched
public QueueSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info) throws javax.jms.InvalidSelectorException
javax.jms.InvalidSelectorException
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
protected void assignGroupToMe(MessageGroupMap messageGroupOwners, MessageReference n, String groupId) throws IOException
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–2015. All rights reserved.