org.codehaus.activemq.service.boundedvm
Class TransientQueueBoundedMessageManager

java.lang.Object
  org.codehaus.activemq.service.boundedvm.TransientQueueBoundedMessageManager

All Implemented Interfaces:

MessageContainerManager, Runnable, Service

public class TransientQueueBoundedMessageManager

extends Object

implements MessageContainerManager, Runnable

A manager of MessageContainer instances

Constructor Summary

TransientQueueBoundedMessageManager(MemoryBoundedQueueManager mgr)
Constructor for TransientQueueBoundedMessageManager

Method Summary

void	acknowledgeMessage(BrokerClient client, MessageAck ack) Acknowledge a message as being read and consumed by the Consumer
void	acknowledgeTransactedMessage(BrokerClient client, String transactionId, MessageAck ack) This is a hook to notify the dispatcher for the clients subscription that we have acknowledged a message within a transaction but before the commit - so the message is not really being acknowledged here but this method is intended to be a hook to let the dispatcher know that we can now send another message to the client.
void	addMessageConsumer(BrokerClient client, ConsumerInfo info) Add a consumer if appropiate
void	commitTransaction(BrokerClient client, String transactionId) A hook when the transaction is about to be commited; so apply all outstanding commands to the Journal if using a Journal (transaction log)
protected MessageContainer	createContainer(String destinationName)
protected Destination	createDestination(String destinationName)
protected Filter	createFilter(ConsumerInfo info) Create filter for a Consumer
void	deleteSubscription(String clientId, String subscriberName) Delete a durable subscriber
MessageContainer	getContainer(String physicalName) Allows the lookup of a specific named message container
Map	getDestinations() Returns an unmodifiable map, indexed by String name, of all the Destination objects available in this container
void	poll() Poll for messages
void	redeliverMessage(BrokerClient client, MessageAck ack) Called after a rollback of a JMS transaction to redeliver the message to the consumers dispatch queue
void	removeMessageConsumer(BrokerClient client, ConsumerInfo info)
void	rollbackTransaction(BrokerClient client, String transactionId) A hook when the transaction is about to be rolled back; so discard all outstanding commands that are pending to be written to the Journal
void	run() collect expired messages
void	sendMessage(BrokerClient client, ActiveMQMessage message)
void	start() start the manager
void	stop() stop the manager

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TransientQueueBoundedMessageManager

public TransientQueueBoundedMessageManager(MemoryBoundedQueueManager mgr)

Constructor for TransientQueueBoundedMessageManager

Parameters:

mgr -

Method Detail

start

public void start()
           throws JMSException

start the manager

Specified by:

start in interface Service

Throws:

JMSException

stop

public void stop()
          throws JMSException

stop the manager

Specified by:

stop in interface Service

Throws:

JMSException

run

public void run()

collect expired messages

Specified by:

run in interface Runnable

addMessageConsumer

public void addMessageConsumer(BrokerClient client,
                               ConsumerInfo info)
                        throws JMSException

Add a consumer if appropiate

Specified by:

addMessageConsumer in interface MessageContainerManager

Parameters:

client -

info -

Throws:

JMSException

removeMessageConsumer

public void removeMessageConsumer(BrokerClient client,
                                  ConsumerInfo info)
                           throws JMSException

Specified by:

removeMessageConsumer in interface MessageContainerManager

Parameters:

client -

info -

Throws:

JMSException

deleteSubscription

public void deleteSubscription(String clientId,
                               String subscriberName)
                        throws JMSException

Delete a durable subscriber

Specified by:

deleteSubscription in interface MessageContainerManager

Parameters:

clientId -

subscriberName -

Throws:

JMSException - if the subscriber doesn't exist or is still active

sendMessage

public void sendMessage(BrokerClient client,
                        ActiveMQMessage message)
                 throws JMSException

Specified by:

sendMessage in interface MessageContainerManager

Parameters:

client -

message -

Throws:

JMSException

acknowledgeMessage

public void acknowledgeMessage(BrokerClient client,
                               MessageAck ack)
                        throws JMSException

Description copied from interface: MessageContainerManager

Acknowledge a message as being read and consumed by the Consumer

Specified by:

acknowledgeMessage in interface MessageContainerManager

Parameters:

client -

ack -

Throws:

JMSException

acknowledgeTransactedMessage

public void acknowledgeTransactedMessage(BrokerClient client,
                                         String transactionId,
                                         MessageAck ack)
                                  throws JMSException

Description copied from interface: MessageContainerManager

This is a hook to notify the dispatcher for the clients subscription that we have acknowledged a message within a transaction but before the commit - so the message is not really being acknowledged here but this method is intended to be a hook to let the dispatcher know that we can now send another message to the client.

Without this hook, if we have a prefetch value of 1, we can never consume 2 messages in a transaction, since the ack for the first message never arrives until the commit()

Specified by:

acknowledgeTransactedMessage in interface MessageContainerManager

Parameters:

client -

transactionId -

ack -

Throws:

JMSException

redeliverMessage

public void redeliverMessage(BrokerClient client,
                             MessageAck ack)
                      throws JMSException

Description copied from interface: MessageContainerManager

Called after a rollback of a JMS transaction to redeliver the message to the consumers dispatch queue

Specified by:

redeliverMessage in interface MessageContainerManager

Parameters:

client -

ack -

Throws:

JMSException

poll

public void poll()
          throws JMSException

Description copied from interface: MessageContainerManager

Poll for messages

Specified by:

poll in interface MessageContainerManager

Throws:

JMSException

commitTransaction

public void commitTransaction(BrokerClient client,
                              String transactionId)
                       throws JMSException

A hook when the transaction is about to be commited; so apply all outstanding commands to the Journal if using a Journal (transaction log)

Specified by:

commitTransaction in interface MessageContainerManager

Parameters:

client -

transactionId -

Throws:

JMSException

rollbackTransaction

public void rollbackTransaction(BrokerClient client,
                                String transactionId)

A hook when the transaction is about to be rolled back; so discard all outstanding commands that are pending to be written to the Journal

Specified by:

rollbackTransaction in interface MessageContainerManager

Parameters:

client -

transactionId -

getContainer

public MessageContainer getContainer(String physicalName)
                              throws JMSException

Description copied from interface: MessageContainerManager

Allows the lookup of a specific named message container

Specified by:

getContainer in interface MessageContainerManager

Parameters:

physicalName -

Returns:

@throws JMSException

Throws:

JMSException

getDestinations

public Map getDestinations()

Description copied from interface: MessageContainerManager

Returns an unmodifiable map, indexed by String name, of all the Destination objects available in this container

Specified by:

getDestinations in interface MessageContainerManager

Returns:

a map of destinations

createFilter

protected Filter createFilter(ConsumerInfo info)
                       throws JMSException

Create filter for a Consumer

Parameters:

info -

Returns:

the Fitler

Throws:

JMSException

createDestination

protected Destination createDestination(String destinationName)

createContainer

protected MessageContainer createContainer(String destinationName)
                                    throws JMSException

Throws:

JMSException