org.activemq.service.boundedvm
Class TransientQueueSubscription

java.lang.Object
  org.activemq.service.boundedvm.TransientSubscription
      org.activemq.service.boundedvm.TransientQueueSubscription

public class TransientQueueSubscription
extends TransientSubscription

A holder for Transient Queue consumer info and message routing

Version:

$Revision: 1.1.1.1 $

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

TransientQueueSubscription

public TransientQueueSubscription(BrokerClient client,
                                  MemoryBoundedQueue dispatchedQueue,
                                  MemoryBoundedQueue ackQueue,
                                  Filter filter,
                                  ConsumerInfo info)

Construct the TransientQueueSubscription

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 TransientSubscription

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(ActiveMQMessage message)
                throws JMSException

Dispatch a message to the Consumer

Parameters:

message -

Throws:

JMSException

acknowledgeMessage

public ActiveMQMessage 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 TransientSubscription

hasAckedMessage

public boolean hasAckedMessage()

Add an acked message.

addAckedMessage

public void addAckedMessage(ActiveMQMessage message)

Add an acked message.

Throws:

InterruptedException

listAckedMessages

public List listAckedMessages()

Get a list of all the acked messages

removeAllAckedMessages

public void removeAllAckedMessages()

Add an acked message.

isBrowser

public boolean isBrowser()