|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface Subscription
Method Summary | |
---|---|
void |
acknowledge(ConnectionContext context,
MessageAck ack)
Used when client acknowledge receipt of dispatched 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. |
void |
destroy()
Called when the subscription is destroyed. |
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. |
long |
getDequeueCounter()
|
long |
getDispatchedCounter()
|
int |
getDispatchedQueueSize()
|
long |
getEnqueueCounter()
|
javax.management.ObjectName |
getObjectName()
|
int |
getPendingQueueSize()
|
int |
getPrefetchSize()
|
java.lang.String |
getSelector()
|
boolean |
isHighWaterMark()
|
boolean |
isLowWaterMark()
|
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 |
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 |
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. |
void |
updateConsumerPrefetch(int newPrefetch)
inform the MessageConsumer on the client to change it's prefetch |
Method Detail |
---|
void add(MessageReference node) throws java.lang.Exception
node
-
java.lang.InterruptedException
java.io.IOException
java.lang.Exception
void acknowledge(ConnectionContext context, MessageAck ack) throws java.lang.Exception
node
-
java.io.IOException
java.lang.Exception
Response pullMessage(ConnectionContext context, MessagePull pull) throws java.lang.Exception
java.lang.Exception
boolean matches(MessageReference node, MessageEvaluationContext context) throws java.io.IOException
node
- context
-
java.io.IOException
boolean matches(ActiveMQDestination destination)
context
-
void add(ConnectionContext context, Destination destination) throws java.lang.Exception
context
- destination
-
java.lang.Exception
void remove(ConnectionContext context, Destination destination) throws java.lang.Exception
context
- destination
-
java.lang.Exception
ConsumerInfo getConsumerInfo()
destination
- void gc()
void processMessageDispatchNotification(MessageDispatchNotification mdn) throws java.lang.Exception
mdn
-
java.lang.Exception
boolean isSlaveBroker()
int getPendingQueueSize()
int getDispatchedQueueSize()
long getDispatchedCounter()
long getEnqueueCounter()
long getDequeueCounter()
java.lang.String getSelector()
void setSelector(java.lang.String selector) throws javax.jms.InvalidSelectorException, java.lang.UnsupportedOperationException
javax.jms.InvalidSelectorException
java.lang.UnsupportedOperationException
javax.management.ObjectName getObjectName()
void setObjectName(javax.management.ObjectName objectName)
boolean isLowWaterMark()
boolean isHighWaterMark()
void updateConsumerPrefetch(int newPrefetch)
newPrefetch
- void optimizePrefetch()
void destroy()
int getPrefetchSize()
boolean isRecoveryRequired()
org.apache.activemq.region.cursors.PendingMessageCursor
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |