|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||
java.lang.Objectorg.activemq.service.boundedvm.TransientSubscription
org.activemq.service.boundedvm.TransientQueueSubscription
A holder for Transient Queue consumer info and message routing
| Field Summary |
| Fields inherited from class org.activemq.service.boundedvm.TransientSubscription |
brokerName, client, clusterName, consumerInfo, filter |
| Constructor Summary | |
TransientQueueSubscription(BrokerClient client,
MemoryBoundedQueue dispatchedQueue,
MemoryBoundedQueue ackQueue,
Filter filter,
ConsumerInfo info)
Construct the TransientQueueSubscription |
|
| Method Summary | |
ActiveMQMessage |
acknowledgeMessage(java.lang.String id)
Acknowledge the receipt of a message by a consumer |
void |
addAckedMessage(ActiveMQMessage message)
Add an acked message. |
boolean |
canAcceptMessages()
|
void |
close()
close the subscription |
void |
doDispatch(ActiveMQMessage message)
Dispatch a message to the Consumer |
java.util.List |
getUndeliveredMessages()
|
boolean |
hasAckedMessage()
Add an acked message. |
boolean |
isBrowser()
|
boolean |
isTarget(ActiveMQMessage message)
determines if the Subscription is interested in the message |
java.util.List |
listAckedMessages()
Get a list of all the acked messages |
void |
removeAllAckedMessages()
Add an acked message. |
| Methods inherited from class org.activemq.service.boundedvm.TransientSubscription |
getConsumerInfo, getDestination, getFilter, isLocalSubscription, setConsumerInfo, setFilter |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
public TransientQueueSubscription(BrokerClient client,
MemoryBoundedQueue dispatchedQueue,
MemoryBoundedQueue ackQueue,
Filter filter,
ConsumerInfo info)
client - dispatchedQueue - ackQueue - filter - info - | Method Detail |
public boolean isTarget(ActiveMQMessage message)
throws javax.jms.JMSException
isTarget in class TransientSubscriptionmessage -
javax.jms.JMSExceptionpublic boolean canAcceptMessages()
public void doDispatch(ActiveMQMessage message)
throws javax.jms.JMSException
message -
javax.jms.JMSExceptionpublic ActiveMQMessage acknowledgeMessage(java.lang.String id)
id -
public java.util.List getUndeliveredMessages()
public void close()
close in class TransientSubscriptionpublic boolean hasAckedMessage()
public void addAckedMessage(ActiveMQMessage message)
java.lang.InterruptedExceptionpublic java.util.List listAckedMessages()
public void removeAllAckedMessages()
public boolean isBrowser()
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||