|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.broker.region.AbstractSubscription
org.apache.activemq.broker.region.PrefetchSubscription
org.apache.activemq.broker.region.QueueSubscription
public class QueueSubscription
Field Summary |
---|
Fields inherited from class org.apache.activemq.broker.region.PrefetchSubscription |
---|
dispatched, pending, prefetchExtension |
Fields inherited from class org.apache.activemq.broker.region.AbstractSubscription |
---|
broker, context, destinationFilter, destinations, info |
Fields inherited from interface org.apache.activemq.broker.region.LockOwner |
---|
HIGH_PRIORITY_LOCK_OWNER |
Constructor Summary | |
---|---|
QueueSubscription(Broker broker,
ConnectionContext context,
ConsumerInfo info)
|
Method Summary | |
---|---|
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. |
protected boolean |
dispatch(MessageReference node)
Override so that the message ref count is > 0 only when the message is being dispatched to a client. |
int |
getLockPriority()
|
boolean |
isLockExclusive()
|
protected void |
onDispatch(MessageReference node,
Message message)
OK Message was transmitted, we can now drop the reference count. |
protected void |
sendToDLQ(ConnectionContext context,
MessageReference node)
Sending a message to the DQL will require us to increment the ref count so we can get at the content. |
String |
toString()
|
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, matches, setObjectName, setSelector |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public QueueSubscription(Broker broker, ConnectionContext context, ConsumerInfo info) throws javax.jms.InvalidSelectorException
javax.jms.InvalidSelectorException
Method Detail |
---|
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 String toString()
toString
in class Object
public int getLockPriority()
getLockPriority
in interface LockOwner
public boolean isLockExclusive()
isLockExclusive
in interface LockOwner
protected boolean dispatch(MessageReference node) throws IOException
dispatch
in class PrefetchSubscription
IOException
protected void onDispatch(MessageReference node, Message message)
onDispatch
in class PrefetchSubscription
PrefetchSubscription.onDispatch(org.apache.activemq.broker.region.MessageReference, org.apache.activemq.command.Message)
protected void sendToDLQ(ConnectionContext context, MessageReference node) throws IOException, Exception
sendToDLQ
in class PrefetchSubscription
IOException
Exception
public void destroy()
Subscription
destroy
in interface Subscription
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |