org.activemq.service.boundedvm
Class TransientTopicBoundedMessageManager

java.lang.Object
  extended byorg.activemq.service.boundedvm.TransientTopicBoundedMessageManager
All Implemented Interfaces:
MessageContainerManager, Service

public class TransientTopicBoundedMessageManager
extends Object
implements MessageContainerManager

A manager of MessageContainer instances


Constructor Summary
TransientTopicBoundedMessageManager(MemoryBoundedQueueManager mgr)
          Constructor for TransientTopicBoundedMessageManager
 
Method Summary
 void acknowledgeMessage(BrokerClient client, MessageAck ack)
          Acknowledge a message as being read and consumed by the Consumer
 void addMessageConsumer(BrokerClient client, ConsumerInfo info)
          Add a consumer if appropiate
protected  Filter createFilter(ConsumerInfo info)
          Create filter for a Consumer
 void createMessageContainer(ActiveMQDestination dest)
          Creates a destination.
 void deleteSubscription(String clientId, String subscriberName)
          Delete a durable subscriber
 void destroyMessageContainer(ActiveMQDestination dest)
          Destroys a destination.
 MessageContainer getContainer(String physicalName)
          For Transient topics - a MessageContainer maps on to the messages to be dispatched through a BrokerClient, not a destination
 DeadLetterPolicy getDeadLetterPolicy()
           
 Map getDestinations()
          Returns an unmodifiable map, indexed by String name, of all the Destination objects available in this container
 Map getLocalDestinations()
          Returns an unmodifiable map, indexed by String name, of all the Destination objects used by non-broker consumers directly connected to this container
 Map getMessageContainerAdmins()
          Returns an unmodifiable map, indexed by ActiveMQDestination, of all the MessageContainerAdmin objects available in this container
protected  boolean hasConsumerFor(ActiveMQDestination destination)
           
 boolean isDecoupledDispatch()
           
 void poll()
          Poll for messages
 void removeMessageConsumer(BrokerClient client, ConsumerInfo info)
           
 void sendMessage(BrokerClient client, ActiveMQMessage message)
           
 void setDeadLetterPolicy(DeadLetterPolicy policy)
          Set the DeadLetterPolicy for this Container Manager
 void setDecoupledDispatch(boolean decoupledDispatch)
           
 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

TransientTopicBoundedMessageManager

public TransientTopicBoundedMessageManager(MemoryBoundedQueueManager mgr)
Constructor for TransientTopicBoundedMessageManager

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

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

poll

public void poll()
          throws JMSException
Description copied from interface: MessageContainerManager
Poll for messages

Specified by:
poll in interface MessageContainerManager
Throws:
JMSException

getContainer

public MessageContainer getContainer(String physicalName)
                              throws JMSException
For Transient topics - a MessageContainer maps on to the messages to be dispatched through a BrokerClient, not a destination

Specified by:
getContainer in interface MessageContainerManager
Parameters:
physicalName -
Returns:
the MessageContainer used for dispatching - always returns null
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 all the destinations

getLocalDestinations

public Map getLocalDestinations()
Returns an unmodifiable map, indexed by String name, of all the Destination objects used by non-broker consumers directly connected to this container

Specified by:
getLocalDestinations in interface MessageContainerManager
Returns:

getDeadLetterPolicy

public DeadLetterPolicy getDeadLetterPolicy()
Specified by:
getDeadLetterPolicy in interface MessageContainerManager
Returns:
the DeadLetterPolicy for this Container Manager

setDeadLetterPolicy

public void setDeadLetterPolicy(DeadLetterPolicy policy)
Set the DeadLetterPolicy for this Container Manager

Specified by:
setDeadLetterPolicy in interface MessageContainerManager
Parameters:
policy -

isDecoupledDispatch

public boolean isDecoupledDispatch()
Returns:
Returns the decoupledDispatch.

setDecoupledDispatch

public void setDecoupledDispatch(boolean decoupledDispatch)
Parameters:
decoupledDispatch - The decoupledDispatch to set.

createFilter

protected Filter createFilter(ConsumerInfo info)
                       throws JMSException
Create filter for a Consumer

Parameters:
info -
Returns:
the Fitler
Throws:
JMSException

hasConsumerFor

protected boolean hasConsumerFor(ActiveMQDestination destination)

createMessageContainer

public void createMessageContainer(ActiveMQDestination dest)
                            throws JMSException
Description copied from interface: MessageContainerManager
Creates a destination.

Specified by:
createMessageContainer in interface MessageContainerManager
Parameters:
dest -
Throws:
JMSException
See Also:
MessageContainerManager.createMessageContainer(org.activemq.message.ActiveMQDestination)

destroyMessageContainer

public void destroyMessageContainer(ActiveMQDestination dest)
                             throws JMSException
Description copied from interface: MessageContainerManager
Destroys a destination.

Specified by:
destroyMessageContainer in interface MessageContainerManager
Parameters:
dest -
Throws:
JMSException
See Also:
MessageContainerManager.destroyMessageContainer(org.activemq.message.ActiveMQDestination)

getMessageContainerAdmins

public Map getMessageContainerAdmins()
                              throws JMSException
Description copied from interface: MessageContainerManager
Returns an unmodifiable map, indexed by ActiveMQDestination, of all the MessageContainerAdmin objects available in this container

Specified by:
getMessageContainerAdmins in interface MessageContainerManager
Returns:
the Map
Throws:
JMSException
See Also:
MessageContainerManager.getMessageContainerAdmins()


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