|
||||||||||
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.DurableTopicSubscription
public class DurableTopicSubscription
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, info |
Constructor Summary | |
---|---|
DurableTopicSubscription(Broker broker,
ConnectionContext context,
ConsumerInfo info,
boolean keepDurableSubsActive,
PendingMessageCursor cursor)
|
Method Summary | |
---|---|
protected void |
acknowledge(ConnectionContext context,
MessageAck ack,
MessageReference node)
Used during acknowledgment to remove the message. |
void |
activate(ConnectionContext context,
ConsumerInfo info)
|
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 boolean |
canDispatch(MessageReference node)
Use when a matched message is about to be dispatched to the client. |
protected MessageDispatch |
createMessageDispatch(MessageReference node,
Message message)
|
void |
deactivate(boolean keepDurableSubsActive)
|
void |
destroy()
Release any references that we are holding. |
void |
gc()
The subscription should release as may references as it can to help the garbage collector reclaim memory. |
String |
getClientId()
|
int |
getPendingQueueSize()
|
SubscriptionKey |
getSubscriptionKey()
|
String |
getSubscriptionName()
|
boolean |
isActive()
|
protected boolean |
isFull()
Used to determine if the broker can dispatch to the consumer. |
void |
setSelector(String selector)
Attempts to change the current active selector on the subscription. |
String |
toString()
|
Methods inherited from class org.apache.activemq.broker.region.PrefetchSubscription |
---|
acknowledge, dispatch, dispatchMatched, getDequeueCounter, getDispatchedCounter, getDispatchedQueueSize, getEnqueueCounter, isHighWaterMark, isLowWaterMark, isRecoveryRequired, onDispatch, optimizePrefetch, processMessageDispatchNotification, pullMessage, remove, sendToDLQ, updateConsumerPrefetch |
Methods inherited from class org.apache.activemq.broker.region.AbstractSubscription |
---|
getConsumerInfo, getContext, getInfo, getObjectName, getPrefetchSize, getSelector, getSelectorExpression, isSlaveBroker, matches, matches, setObjectName |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public DurableTopicSubscription(Broker broker, ConnectionContext context, ConsumerInfo info, boolean keepDurableSubsActive, PendingMessageCursor cursor) throws javax.jms.InvalidSelectorException
javax.jms.InvalidSelectorException
Method Detail |
---|
public boolean isActive()
protected boolean isFull()
PrefetchSubscription
isFull
in class PrefetchSubscription
public void gc()
Subscription
gc
in interface Subscription
gc
in class AbstractSubscription
public void add(ConnectionContext context, Destination destination) throws Exception
Subscription
add
in interface Subscription
add
in class PrefetchSubscription
Exception
public void activate(ConnectionContext context, ConsumerInfo info) throws Exception
Exception
public void deactivate(boolean keepDurableSubsActive) throws Exception
Exception
protected MessageDispatch createMessageDispatch(MessageReference node, Message message)
createMessageDispatch
in class PrefetchSubscription
public void add(MessageReference node) throws Exception
Subscription
add
in interface Subscription
add
in class PrefetchSubscription
InterruptedException
IOException
Exception
public int getPendingQueueSize()
getPendingQueueSize
in interface Subscription
getPendingQueueSize
in class PrefetchSubscription
public void setSelector(String selector) throws javax.jms.InvalidSelectorException
Subscription
setSelector
in interface Subscription
setSelector
in class AbstractSubscription
javax.jms.InvalidSelectorException
protected boolean canDispatch(MessageReference node)
PrefetchSubscription
canDispatch
in class PrefetchSubscription
protected void acknowledge(ConnectionContext context, MessageAck ack, MessageReference node) throws IOException
PrefetchSubscription
acknowledge
in class PrefetchSubscription
IOException
public String getSubscriptionName()
public String toString()
toString
in class Object
public String getClientId()
public SubscriptionKey getSubscriptionKey()
public void destroy()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |