|
||||||||||
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
public abstract class PrefetchSubscription
A subscription that honors the pre-fetch option of the ConsumerInfo.
Field Summary | |
---|---|
protected ActiveMQMessageAudit |
audit
|
protected long |
dequeueCounter
|
protected long |
dispatchCounter
|
protected List<MessageReference> |
dispatched
|
protected long |
enqueueCounter
|
protected PendingMessageCursor |
pending
|
protected int |
prefetchExtension
|
protected static Scheduler |
scheduler
|
protected SystemUsage |
usageManager
|
Fields inherited from class org.apache.activemq.broker.region.AbstractSubscription |
---|
broker, context, destinationFilter, destinations, info |
Constructor Summary | |
---|---|
PrefetchSubscription(Broker broker,
SystemUsage usageManager,
ConnectionContext context,
ConsumerInfo info)
|
|
PrefetchSubscription(Broker broker,
SystemUsage usageManager,
ConnectionContext context,
ConsumerInfo info,
PendingMessageCursor cursor)
|
Method Summary | |
---|---|
void |
acknowledge(ConnectionContext context,
MessageAck ack)
Used when client acknowledge receipt of dispatched message. |
protected abstract void |
acknowledge(ConnectionContext context,
MessageAck ack,
MessageReference node)
Used during acknowledgment to remove the message. |
void |
add(ConnectionContext context,
Destination destination)
The subscription will be receiving messages from the destination. |
void |
add(MessageReference node)
Used to add messages that match the subscription. |
protected void |
assertAckMatchesDispatched(MessageAck ack)
Checks an ack versus the contents of the dispatched list. |
protected abstract boolean |
canDispatch(MessageReference node)
Use when a matched message is about to be dispatched to the client. |
int |
countBeforeFull()
|
protected MessageDispatch |
createMessageDispatch(MessageReference node,
Message message)
|
protected boolean |
dispatch(MessageReference node)
|
protected void |
dispatchPending()
|
long |
getDequeueCounter()
|
long |
getDispatchedCounter()
|
int |
getDispatchedQueueSize()
|
long |
getEnqueueCounter()
|
int |
getInFlightSize()
|
int |
getMaxAuditDepth()
|
int |
getMaxProducersToAudit()
|
PendingMessageCursor |
getPending()
|
int |
getPendingQueueSize()
|
protected abstract boolean |
isDropped(MessageReference node)
|
boolean |
isFull()
Used to determine if the broker can dispatch to the consumer. |
boolean |
isHighWaterMark()
|
boolean |
isLowWaterMark()
|
boolean |
isRecoveryRequired()
Informs the Broker if the subscription needs to intervention to recover it's state e.g. |
protected void |
onDispatch(MessageReference node,
Message message)
|
void |
processMessageDispatchNotification(MessageDispatchNotification mdn)
Used by a Slave Broker to update dispatch infomation |
Response |
pullMessage(ConnectionContext context,
MessagePull pull)
Allows a message to be pulled on demand by a client |
List<MessageReference> |
remove(ConnectionContext context,
Destination destination)
The subscription will be no longer be receiving messages from the destination. |
protected void |
sendToDLQ(ConnectionContext context,
MessageReference node)
|
void |
setMaxAuditDepth(int maxAuditDepth)
|
void |
setMaxProducersToAudit(int maxProducersToAudit)
|
void |
setPending(PendingMessageCursor pending)
|
void |
updateConsumerPrefetch(int newPrefetch)
inform the MessageConsumer on the client to change it's prefetch |
Methods inherited from class org.apache.activemq.broker.region.AbstractSubscription |
---|
addDestination, addRecoveredMessage, doAddRecoveredMessage, gc, getActiveMQDestination, getConsumerInfo, getContext, getCursorMemoryHighWaterMark, getInFlightUsage, getInfo, getObjectName, getPrefetchSize, getSelector, getSelectorExpression, isBrowser, isSlave, matches, matches, removeDestination, setCursorMemoryHighWaterMark, setObjectName, setPrefetchSize, setSelector |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.apache.activemq.broker.region.Subscription |
---|
destroy |
Field Detail |
---|
protected static final Scheduler scheduler
protected PendingMessageCursor pending
protected final List<MessageReference> dispatched
protected int prefetchExtension
protected long enqueueCounter
protected long dispatchCounter
protected long dequeueCounter
protected final SystemUsage usageManager
protected ActiveMQMessageAudit audit
Constructor Detail |
---|
public PrefetchSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info, PendingMessageCursor cursor) throws InvalidSelectorException
InvalidSelectorException
public PrefetchSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info) throws InvalidSelectorException
InvalidSelectorException
Method Detail |
---|
public Response pullMessage(ConnectionContext context, MessagePull pull) throws Exception
Exception
public void add(MessageReference node) throws Exception
Subscription
Exception
InterruptedException
IOException
public void processMessageDispatchNotification(MessageDispatchNotification mdn) throws Exception
Subscription
Exception
public final void acknowledge(ConnectionContext context, MessageAck ack) throws Exception
Subscription
IOException
Exception
protected void assertAckMatchesDispatched(MessageAck ack) throws JMSException
ack
- firstAckedMsg
- lastAckedMsg
-
JMSException
- if it does not matchprotected void sendToDLQ(ConnectionContext context, MessageReference node) throws IOException, Exception
context
- node
-
IOException
Exception
public int getInFlightSize()
public boolean isFull()
public boolean isLowWaterMark()
public boolean isHighWaterMark()
public int countBeforeFull()
countBeforeFull
in interface Subscription
countBeforeFull
in class AbstractSubscription
public int getPendingQueueSize()
public int getDispatchedQueueSize()
public long getDequeueCounter()
public long getDispatchedCounter()
public long getEnqueueCounter()
public boolean isRecoveryRequired()
Subscription
isRecoveryRequired
in interface Subscription
isRecoveryRequired
in class AbstractSubscription
org.apache.activemq.region.cursors.PendingMessageCursor
public PendingMessageCursor getPending()
public void setPending(PendingMessageCursor pending)
public void add(ConnectionContext context, Destination destination) throws Exception
Subscription
add
in interface Subscription
add
in class AbstractSubscription
Exception
public List<MessageReference> remove(ConnectionContext context, Destination destination) throws Exception
Subscription
remove
in interface Subscription
remove
in class AbstractSubscription
Exception
protected void dispatchPending() throws IOException
IOException
protected boolean dispatch(MessageReference node) throws IOException
IOException
protected void onDispatch(MessageReference node, Message message)
public void updateConsumerPrefetch(int newPrefetch)
newPrefetch
- protected MessageDispatch createMessageDispatch(MessageReference node, Message message)
node
- message
-
protected abstract boolean canDispatch(MessageReference node) throws IOException
node
-
IOException
protected abstract boolean isDropped(MessageReference node)
protected abstract void acknowledge(ConnectionContext context, MessageAck ack, MessageReference node) throws IOException
IOException
public int getMaxProducersToAudit()
public void setMaxProducersToAudit(int maxProducersToAudit)
public int getMaxAuditDepth()
public void setMaxAuditDepth(int maxAuditDepth)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |