|
||||||||||
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 java.util.concurrent.CopyOnWriteArrayList<Destination> |
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 |
addDestination(Destination destination)
Add a destination |
boolean |
addRecoveredMessage(ConnectionContext context,
MessageReference message)
Add a message to the SubscriptionRecovery |
int |
countBeforeFull()
|
protected void |
doAddRecoveredMessage(MessageReference message)
|
void |
gc()
The subscription should release as may references as it can to help the garbage collector reclaim memory. |
ActiveMQDestination |
getActiveMQDestination()
|
ConsumerInfo |
getConsumerInfo()
The ConsumerInfo object that created the subscription. |
ConnectionContext |
getContext()
|
int |
getCursorMemoryHighWaterMark()
|
int |
getInFlightUsage()
|
ConsumerInfo |
getInfo()
|
javax.management.ObjectName |
getObjectName()
|
int |
getPrefetchSize()
|
java.lang.String |
getSelector()
|
BooleanExpression |
getSelectorExpression()
|
boolean |
isBrowser()
|
boolean |
isRecoveryRequired()
Informs the Broker if the subscription needs to intervention to recover it's state e.g. |
boolean |
isSlave()
|
boolean |
isSlowConsumer()
|
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? |
java.util.List<MessageReference> |
remove(ConnectionContext context,
Destination destination)
The subscription will be no longer be receiving messages from the destination. |
void |
removeDestination(Destination destination)
Remove a destination |
void |
setCursorMemoryHighWaterMark(int cursorMemoryHighWaterMark)
|
void |
setObjectName(javax.management.ObjectName objectName)
Set when the subscription is registered in JMX |
void |
setPrefetchSize(int newSize)
|
void |
setSelector(java.lang.String selector)
Attempts to change the current active selector on the subscription. |
void |
setSlowConsumer(boolean val)
|
void |
unmatched(MessageReference node)
|
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, getInFlightSize, getPendingQueueSize, isFull, isHighWaterMark, isLowWaterMark, processMessageDispatchNotification, pullMessage, updateConsumerPrefetch |
Field Detail |
---|
protected Broker broker
protected ConnectionContext context
protected ConsumerInfo info
protected final DestinationFilter destinationFilter
protected final java.util.concurrent.CopyOnWriteArrayList<Destination> 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 java.util.List<MessageReference> 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 isSlave()
isSlave
in interface Subscription
public ConnectionContext getContext()
getContext
in interface Subscription
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 void setPrefetchSize(int newSize)
public boolean isRecoveryRequired()
Subscription
isRecoveryRequired
in interface Subscription
org.apache.activemq.region.cursors.PendingMessageCursor
public boolean isSlowConsumer()
isSlowConsumer
in interface Subscription
public void setSlowConsumer(boolean val)
public boolean addRecoveredMessage(ConnectionContext context, MessageReference message) throws java.lang.Exception
SubscriptionRecovery
addRecoveredMessage
in interface SubscriptionRecovery
java.lang.Exception
public ActiveMQDestination getActiveMQDestination()
getActiveMQDestination
in interface SubscriptionRecovery
public boolean isBrowser()
isBrowser
in interface Subscription
public int getInFlightUsage()
getInFlightUsage
in interface Subscription
public void addDestination(Destination destination)
destination
- public void removeDestination(Destination destination)
destination
- public int getCursorMemoryHighWaterMark()
getCursorMemoryHighWaterMark
in interface Subscription
public void setCursorMemoryHighWaterMark(int cursorMemoryHighWaterMark)
setCursorMemoryHighWaterMark
in interface Subscription
public int countBeforeFull()
countBeforeFull
in interface Subscription
public void unmatched(MessageReference node) throws java.io.IOException
unmatched
in interface Subscription
java.io.IOException
protected void doAddRecoveredMessage(MessageReference message) throws java.lang.Exception
java.lang.Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |