org.activemq.service
Interface MessageContainerManager

All Superinterfaces:
Service
All Known Subinterfaces:
QueueMessageContainerManager
All Known Implementing Classes:
DurableQueueBoundedMessageManager, DurableQueueMessageContainerManager, MessageContainerManagerSupport, ProxyMessageContainerManager, TransientQueueBoundedMessageManager, TransientTopicBoundedMessageManager

public interface MessageContainerManager
extends Service

A manager of MessageContainer instances


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)
           
 void createMessageContainer(ActiveMQDestination dest)
          Creates a destination.
 void deleteSubscription(java.lang.String clientId, java.lang.String subscriberName)
          Delete a durable subscriber
 void destroyMessageContainer(ActiveMQDestination dest)
          Destroys a destination.
 MessageContainer getContainer(java.lang.String physicalName)
          Allows the lookup of a specific named message container
 DeadLetterPolicy getDeadLetterPolicy()
           
 java.util.Map getDestinations()
          Returns an unmodifiable map, indexed by String name, of all the Destination objects available in this container
 java.util.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
 java.util.Map getMessageContainerAdmins()
          Returns an unmodifiable map, indexed by ActiveMQDestination, of all the MessageContainerAdmin objects available in this container
 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
 
Methods inherited from interface org.activemq.service.Service
start, stop
 

Method Detail

createMessageContainer

public void createMessageContainer(ActiveMQDestination dest)
                            throws javax.jms.JMSException
Creates a destination.

Parameters:
dest -
Throws:
javax.jms.JMSException

destroyMessageContainer

public void destroyMessageContainer(ActiveMQDestination dest)
                             throws javax.jms.JMSException
Destroys a destination.

Parameters:
dest -
Throws:
javax.jms.JMSException

getMessageContainerAdmins

public java.util.Map getMessageContainerAdmins()
                                        throws javax.jms.JMSException
Returns an unmodifiable map, indexed by ActiveMQDestination, of all the MessageContainerAdmin objects available in this container

Returns:
the Map
Throws:
javax.jms.JMSException

getDestinations

public java.util.Map getDestinations()
Returns an unmodifiable map, indexed by String name, of all the Destination objects available in this container

Returns:

getLocalDestinations

public java.util.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

Returns:

addMessageConsumer

public void addMessageConsumer(BrokerClient client,
                               ConsumerInfo info)
                        throws javax.jms.JMSException
Parameters:
client -
info -
Throws:
javax.jms.JMSException

removeMessageConsumer

public void removeMessageConsumer(BrokerClient client,
                                  ConsumerInfo info)
                           throws javax.jms.JMSException
Parameters:
client -
info -
Throws:
javax.jms.JMSException

deleteSubscription

public void deleteSubscription(java.lang.String clientId,
                               java.lang.String subscriberName)
                        throws javax.jms.JMSException
Delete a durable subscriber

Parameters:
clientId -
subscriberName -
Throws:
javax.jms.JMSException - if the subscriber doesn't exist or is still active

sendMessage

public void sendMessage(BrokerClient client,
                        ActiveMQMessage message)
                 throws javax.jms.JMSException
Parameters:
client -
message -
Throws:
javax.jms.JMSException

acknowledgeMessage

public void acknowledgeMessage(BrokerClient client,
                               MessageAck ack)
                        throws javax.jms.JMSException
Acknowledge a message as being read and consumed by the Consumer

Parameters:
client -
ack -
Throws:
javax.jms.JMSException

poll

public void poll()
          throws javax.jms.JMSException
Poll for messages

Throws:
javax.jms.JMSException

getContainer

public MessageContainer getContainer(java.lang.String physicalName)
                              throws javax.jms.JMSException
Allows the lookup of a specific named message container

Parameters:
physicalName -
Returns:
the MessageContainer
Throws:
javax.jms.JMSException

getDeadLetterPolicy

public DeadLetterPolicy getDeadLetterPolicy()
Returns:
the DeadLetterPolicy for this Container Manager

setDeadLetterPolicy

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

Parameters:
policy -


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