|
||||||||||
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.TopicSubscription
public class TopicSubscription
Field Summary | |
---|---|
protected edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicLong |
dispatchedCounter
|
protected ActiveMQDestination |
dlqDestination
|
protected LinkedList |
matched
|
protected edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicLong |
prefetchExtension
|
protected UsageManager |
usageManager
|
Fields inherited from class org.apache.activemq.broker.region.AbstractSubscription |
---|
broker, context, destinationFilter, destinations, info |
Constructor Summary | |
---|---|
TopicSubscription(Broker broker,
ConnectionContext context,
ConsumerInfo info,
UsageManager usageManager)
|
Method Summary | |
---|---|
void |
acknowledge(ConnectionContext context,
MessageAck ack)
Used when client acknowledge receipt of dispatched message. |
void |
add(MessageReference node)
Used to add messages that match the subscription. |
void |
destroy()
Called when the subscription is destroyed. |
int |
discarded()
|
long |
getDequeueCounter()
|
long |
getDispatchedCounter()
|
int |
getDispatchedQueueSize()
|
long |
getEnqueueCounter()
|
int |
getMaximumPendingMessages()
|
MessageEvictionStrategy |
getMessageEvictionStrategy()
|
int |
getPendingQueueSize()
|
int |
getPrefetchSize()
|
boolean |
isHighWaterMark()
|
boolean |
isLowWaterMark()
|
int |
matched()
|
void |
optimizePrefetch()
optimize message consumer prefetch if the consumer supports it |
void |
processMessageDispatchNotification(MessageDispatchNotification mdn)
Used by a Slave Broker to update dispatch infomation |
Response |
pullMessage(ConnectionContext context,
MessagePull pull)
Allows a consumer to pull a message on demand |
protected void |
removeExpiredMessages(LinkedList messages)
Discard any expired messages from the matched list. |
void |
setMaximumPendingMessages(int maximumPendingMessages)
Sets the maximum number of pending messages that can be matched against this consumer before old messages are discarded. |
void |
setMessageEvictionStrategy(MessageEvictionStrategy messageEvictionStrategy)
Sets the eviction strategy used to decide which message to evict when the slow consumer needs to discard messages |
String |
toString()
|
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 |
---|
add, gc, getConsumerInfo, getContext, getInfo, getObjectName, getSelector, getSelectorExpression, isRecoveryRequired, isSlaveBroker, matches, matches, remove, setObjectName, setSelector |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
protected final LinkedList matched
protected final ActiveMQDestination dlqDestination
protected final UsageManager usageManager
protected edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicLong dispatchedCounter
protected edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicLong prefetchExtension
Constructor Detail |
---|
public TopicSubscription(Broker broker, ConnectionContext context, ConsumerInfo info, UsageManager usageManager) throws javax.jms.InvalidSelectorException
javax.jms.InvalidSelectorException
Method Detail |
---|
public void add(MessageReference node) throws InterruptedException, IOException
Subscription
InterruptedException
IOException
protected void removeExpiredMessages(LinkedList messages) throws IOException
IOException
public void processMessageDispatchNotification(MessageDispatchNotification mdn)
Subscription
public void acknowledge(ConnectionContext context, MessageAck ack) throws Exception
Subscription
IOException
Exception
public Response pullMessage(ConnectionContext context, MessagePull pull) throws Exception
Subscription
Exception
public int getPendingQueueSize()
public int getDispatchedQueueSize()
public int getMaximumPendingMessages()
public long getDispatchedCounter()
public long getEnqueueCounter()
public long getDequeueCounter()
public int discarded()
public int matched()
public void setMaximumPendingMessages(int maximumPendingMessages)
public MessageEvictionStrategy getMessageEvictionStrategy()
public void setMessageEvictionStrategy(MessageEvictionStrategy messageEvictionStrategy)
public boolean isLowWaterMark()
public boolean isHighWaterMark()
public void updateConsumerPrefetch(int newPrefetch)
newPrefetch
- public void optimizePrefetch()
public String toString()
toString
in class Object
public void destroy()
Subscription
public int getPrefetchSize()
getPrefetchSize
in interface Subscription
getPrefetchSize
in class AbstractSubscription
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |