|
||||||||||
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()
|
ObjectName |
getObjectName()
|
int |
getPendingQueueSize()
|
int |
getPrefetchSize()
|
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(ObjectName objectName)
Set when the subscription is registered in JMX |
void |
setSelector(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 Exception
node
-
InterruptedException
IOException
Exception
void acknowledge(ConnectionContext context, MessageAck ack) throws Exception
node
-
IOException
Exception
Response pullMessage(ConnectionContext context, MessagePull pull) throws Exception
Exception
boolean matches(MessageReference node, MessageEvaluationContext context) throws IOException
node
- context
-
IOException
boolean matches(ActiveMQDestination destination)
context
-
void add(ConnectionContext context, Destination destination) throws Exception
context
- destination
-
Exception
void remove(ConnectionContext context, Destination destination) throws Exception
context
- destination
-
Exception
ConsumerInfo getConsumerInfo()
destination
- void gc()
void processMessageDispatchNotification(MessageDispatchNotification mdn) throws Exception
mdn
-
Exception
boolean isSlaveBroker()
int getPendingQueueSize()
int getDispatchedQueueSize()
long getDispatchedCounter()
long getEnqueueCounter()
long getDequeueCounter()
String getSelector()
void setSelector(String selector) throws javax.jms.InvalidSelectorException, UnsupportedOperationException
javax.jms.InvalidSelectorException
UnsupportedOperationException
ObjectName getObjectName()
void setObjectName(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 |