|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.service.boundedvm.DurableSubscription
org.activemq.service.boundedvm.DurableQueueSubscription
public class DurableQueueSubscription
A holder for Durable Queue consumer info and message routing
Field Summary |
---|
Fields inherited from class org.activemq.service.boundedvm.DurableSubscription |
---|
brokerName, client, clusterName, consumerInfo, filter |
Constructor Summary | |
---|---|
DurableQueueSubscription(BrokerClient client,
MemoryBoundedQueue dispatchedQueue,
MemoryBoundedQueue ackQueue,
Filter filter,
ConsumerInfo info)
Construct the DurableQueueSubscription |
Method Summary | |
---|---|
DurableMessagePointer |
acknowledgeMessage(String id)
Acknowledge the receipt of a message by a consumer |
void |
addAckedMessage(DurableMessagePointer message)
Add an acked message. |
boolean |
canAcceptMessages()
|
void |
close()
close the subscription |
void |
doDispatch(DurableMessagePointer message)
Dispatch a message to the Consumer |
List |
getUndeliveredMessages()
|
boolean |
hasAckedMessage()
|
boolean |
isBrowser()
|
boolean |
isTarget(ActiveMQMessage message)
determines if the Subscription is interested in the message |
List |
listAckedMessages()
|
void |
removeAllAckedMessages()
Add an acked message. |
Methods inherited from class org.activemq.service.boundedvm.DurableSubscription |
---|
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 DurableQueueSubscription(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 DurableSubscription
message
-
JMSException
public boolean canAcceptMessages()
public void doDispatch(DurableMessagePointer message) throws JMSException
message
-
JMSException
public DurableMessagePointer acknowledgeMessage(String id)
id
-
public List getUndeliveredMessages()
public void close()
close
in class DurableSubscription
public boolean hasAckedMessage()
public void addAckedMessage(DurableMessagePointer message)
message
- 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 |