org.activemq.service.boundedvm
Class DurableQueueSubscription

java.lang.Object
  extended by org.activemq.service.boundedvm.DurableSubscription
      extended by org.activemq.service.boundedvm.DurableQueueSubscription

public class DurableQueueSubscription
extends DurableSubscription

A holder for Durable Queue consumer info and message routing

Version:
$Revision: 1.1.1.1 $

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

DurableQueueSubscription

public DurableQueueSubscription(BrokerClient client,
                                MemoryBoundedQueue dispatchedQueue,
                                MemoryBoundedQueue ackQueue,
                                Filter filter,
                                ConsumerInfo info)
Construct the DurableQueueSubscription

Parameters:
client -
dispatchedQueue -
ackQueue -
filter -
info -
Method Detail

isTarget

public boolean isTarget(ActiveMQMessage message)
                 throws JMSException
determines if the Subscription is interested in the message

Specified by:
isTarget in class DurableSubscription
Parameters:
message -
Returns:
true if this Subscription will accept the message
Throws:
JMSException

canAcceptMessages

public boolean canAcceptMessages()
Returns:
true if the consumer has capacity for more messages

doDispatch

public void doDispatch(DurableMessagePointer message)
                throws JMSException
Dispatch a message to the Consumer

Parameters:
message -
Throws:
JMSException

acknowledgeMessage

public DurableMessagePointer acknowledgeMessage(String id)
Acknowledge the receipt of a message by a consumer

Parameters:
id -
Returns:
the removed ActiveMQMessage with the associated id

getUndeliveredMessages

public List getUndeliveredMessages()
Returns:
all the unacknowledge messages

close

public void close()
close the subscription

Overrides:
close in class DurableSubscription

hasAckedMessage

public boolean hasAckedMessage()
Returns:
true if acked a message

addAckedMessage

public void addAckedMessage(DurableMessagePointer message)
Add an acked message.

Parameters:
message -

listAckedMessages

public List listAckedMessages()
Returns:
a list of all the acked messages

removeAllAckedMessages

public void removeAllAckedMessages()
Add an acked message.


isBrowser

public boolean isBrowser()


Copyright © 2004-2009 Protique, Ltd.. All Rights Reserved.