|
||||||||||
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 long |
dequeueCounter
|
protected long |
dispatchCounter
|
protected java.util.List<MessageReference> |
dispatched
|
protected java.lang.Object |
dispatchLock
|
protected long |
enqueueCounter
|
protected PendingMessageCursor |
pending
|
protected java.lang.Object |
pendingLock
|
protected java.util.concurrent.atomic.AtomicInteger |
prefetchExtension
|
protected Scheduler |
scheduler
|
protected SystemUsage |
usageManager
|
protected boolean |
usePrefetchExtension
|
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 int |
getPrefetchExtension()
|
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. |
boolean |
isUsePrefetchExtension()
|
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 |
java.util.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)
|
protected void |
setPendingBatchSize(PendingMessageCursor pending,
int numberToDispatch)
|
void |
setUsePrefetchExtension(boolean usePrefetchExtension)
|
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, isSlowConsumer, matches, matches, removeDestination, setCursorMemoryHighWaterMark, setObjectName, setPrefetchSize, setSelector, setSlowConsumer, unmatched |
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 final Scheduler scheduler
protected PendingMessageCursor pending
protected final java.util.List<MessageReference> dispatched
protected final java.util.concurrent.atomic.AtomicInteger prefetchExtension
protected boolean usePrefetchExtension
protected long enqueueCounter
protected long dispatchCounter
protected long dequeueCounter
protected final SystemUsage usageManager
protected final java.lang.Object pendingLock
protected final java.lang.Object dispatchLock
Constructor Detail |
---|
public PrefetchSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info, PendingMessageCursor cursor) throws javax.jms.InvalidSelectorException
javax.jms.InvalidSelectorException
public PrefetchSubscription(Broker broker, SystemUsage usageManager, ConnectionContext context, ConsumerInfo info) throws javax.jms.InvalidSelectorException
javax.jms.InvalidSelectorException
Method Detail |
---|
public Response pullMessage(ConnectionContext context, MessagePull pull) throws java.lang.Exception
java.lang.Exception
public void add(MessageReference node) throws java.lang.Exception
Subscription
java.lang.Exception
java.lang.InterruptedException
java.io.IOException
public void processMessageDispatchNotification(MessageDispatchNotification mdn) throws java.lang.Exception
Subscription
java.lang.Exception
public final void acknowledge(ConnectionContext context, MessageAck ack) throws java.lang.Exception
Subscription
java.io.IOException
java.lang.Exception
protected void assertAckMatchesDispatched(MessageAck ack) throws javax.jms.JMSException
ack
-
javax.jms.JMSException
- if it does not matchprotected void sendToDLQ(ConnectionContext context, MessageReference node) throws java.io.IOException, java.lang.Exception
context
- node
-
java.io.IOException
java.lang.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 java.lang.Exception
Subscription
add
in interface Subscription
add
in class AbstractSubscription
java.lang.Exception
public java.util.List<MessageReference> remove(ConnectionContext context, Destination destination) throws java.lang.Exception
Subscription
remove
in interface Subscription
remove
in class AbstractSubscription
java.lang.Exception
protected void dispatchPending() throws java.io.IOException
java.io.IOException
protected void setPendingBatchSize(PendingMessageCursor pending, int numberToDispatch)
protected boolean dispatch(MessageReference node) throws java.io.IOException
java.io.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 java.io.IOException
node
-
java.io.IOException
protected abstract boolean isDropped(MessageReference node)
protected abstract void acknowledge(ConnectionContext context, MessageAck ack, MessageReference node) throws java.io.IOException
java.io.IOException
public int getMaxProducersToAudit()
public void setMaxProducersToAudit(int maxProducersToAudit)
public int getMaxAuditDepth()
public void setMaxAuditDepth(int maxAuditDepth)
public boolean isUsePrefetchExtension()
public void setUsePrefetchExtension(boolean usePrefetchExtension)
protected int getPrefetchExtension()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |