|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.broker.region.AbstractSubscription
public abstract class AbstractSubscription
Field Summary | |
---|---|
protected Broker |
broker
|
protected ConnectionContext |
context
|
protected DestinationFilter |
destinationFilter
|
protected edu.emory.mathcs.backport.java.util.concurrent.CopyOnWriteArrayList |
destinations
|
protected ConsumerInfo |
info
|
Constructor Summary | |
---|---|
AbstractSubscription(Broker broker,
ConnectionContext context,
ConsumerInfo info)
|
Method Summary | |
---|---|
void |
add(ConnectionContext context,
Destination destination)
The subscription will be receiving messages from the destination. |
void |
gc()
The subscription should release as may references as it can to help the garbage collector reclaim memory. |
ConsumerInfo |
getConsumerInfo()
The ConsumerInfo object that created the subscription. |
ConnectionContext |
getContext()
|
ConsumerInfo |
getInfo()
|
javax.management.ObjectName |
getObjectName()
|
int |
getPrefetchSize()
|
java.lang.String |
getSelector()
|
BooleanExpression |
getSelectorExpression()
|
boolean |
isRecoveryRequired()
Informs the Broker if the subscription needs to intervention to recover it's state e.g. |
boolean |
isSlaveBroker()
|
boolean |
matches(ActiveMQDestination destination)
Is the subscription interested in messages in the destination? |
boolean |
matches(MessageReference node,
MessageEvaluationContext context)
Is the subscription interested in the message? |
void |
remove(ConnectionContext context,
Destination destination)
The subscription will be no longer be receiving messages from the destination. |
void |
setObjectName(javax.management.ObjectName objectName)
Set when the subscription is registered in JMX |
void |
setSelector(java.lang.String selector)
Attempts to change the current active selector on the subscription. |
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 |
---|
acknowledge, add, destroy, getDequeueCounter, getDispatchedCounter, getDispatchedQueueSize, getEnqueueCounter, getPendingQueueSize, isHighWaterMark, isLowWaterMark, optimizePrefetch, processMessageDispatchNotification, pullMessage, updateConsumerPrefetch |
Field Detail |
---|
protected Broker broker
protected ConnectionContext context
protected ConsumerInfo info
protected final DestinationFilter destinationFilter
protected final edu.emory.mathcs.backport.java.util.concurrent.CopyOnWriteArrayList destinations
Constructor Detail |
---|
public AbstractSubscription(Broker broker, ConnectionContext context, ConsumerInfo info) throws javax.jms.InvalidSelectorException
javax.jms.InvalidSelectorException
Method Detail |
---|
public boolean matches(MessageReference node, MessageEvaluationContext context) throws java.io.IOException
Subscription
matches
in interface Subscription
java.io.IOException
public boolean matches(ActiveMQDestination destination)
Subscription
matches
in interface Subscription
public void add(ConnectionContext context, Destination destination) throws java.lang.Exception
Subscription
add
in interface Subscription
java.lang.Exception
public void remove(ConnectionContext context, Destination destination) throws java.lang.Exception
Subscription
remove
in interface Subscription
java.lang.Exception
public ConsumerInfo getConsumerInfo()
Subscription
getConsumerInfo
in interface Subscription
public void gc()
Subscription
gc
in interface Subscription
public boolean isSlaveBroker()
isSlaveBroker
in interface Subscription
public ConnectionContext getContext()
public ConsumerInfo getInfo()
public BooleanExpression getSelectorExpression()
public java.lang.String getSelector()
getSelector
in interface Subscription
public void setSelector(java.lang.String selector) throws javax.jms.InvalidSelectorException
Subscription
setSelector
in interface Subscription
javax.jms.InvalidSelectorException
public javax.management.ObjectName getObjectName()
getObjectName
in interface Subscription
public void setObjectName(javax.management.ObjectName objectName)
Subscription
setObjectName
in interface Subscription
public int getPrefetchSize()
getPrefetchSize
in interface Subscription
public boolean isRecoveryRequired()
Subscription
isRecoveryRequired
in interface Subscription
org.apache.activemq.region.cursors.PendingMessageCursor
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |