|
|||||||||||
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(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 |
List |
getUndeliveredMessages()
|
boolean |
hasAckedMessage()
Add an acked message. |
boolean |
isBrowser()
|
boolean |
isTarget(ActiveMQMessage message)
determines if the Subscription is interested in the message |
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 JMSException
isTarget
in class TransientSubscription
message
-
JMSException
public boolean canAcceptMessages()
public void doDispatch(ActiveMQMessage message) throws JMSException
message
-
JMSException
public ActiveMQMessage acknowledgeMessage(String id)
id
-
public List getUndeliveredMessages()
public void close()
close
in class TransientSubscription
public boolean hasAckedMessage()
public void addAckedMessage(ActiveMQMessage message)
InterruptedException
public List listAckedMessages()
public void removeAllAckedMessages()
public boolean isBrowser()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |