org.activemq.service
Interface MessageContainerManager

All Superinterfaces:

Service

All Known Subinterfaces:

QueueMessageContainerManager

All Known Implementing Classes:

DurableQueueBoundedMessageManager, DurableQueueMessageContainerManager, DurableTopicMessageContainerManager, InitialImageMessageContainerManager, MessageContainerManagerSupport, ProxyMessageContainerManager, TransientQueueBoundedMessageManager, TransientTopicBoundedMessageManager, TransientTopicMessageContainerManager

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(String clientId, String subscriberName) Delete a durable subscriber
void	destroyMessageContainer(ActiveMQDestination dest) Destroys a destination.
MessageContainer	getContainer(String physicalName) Allows the lookup of a specific named message container
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
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

void createMessageContainer(ActiveMQDestination dest)
                            throws JMSException

Creates a destination.

Parameters:

dest -

Throws:

JMSException

destroyMessageContainer

void destroyMessageContainer(ActiveMQDestination dest)
                             throws JMSException

Destroys a destination.

Parameters:

dest -

Throws:

JMSException

getMessageContainerAdmins

Map getMessageContainerAdmins()
                              throws JMSException

Returns an unmodifiable map, indexed by ActiveMQDestination, of all the MessageContainerAdmin objects available in this container

Returns:

the Map

Throws:

JMSException

getDestinations

Map getDestinations()

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

Returns:

getLocalDestinations

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

void addMessageConsumer(BrokerClient client,
                        ConsumerInfo info)
                        throws JMSException

Parameters:

client -

info -

Throws:

JMSException

removeMessageConsumer

void removeMessageConsumer(BrokerClient client,
                           ConsumerInfo info)
                           throws JMSException

Parameters:

client -

info -

Throws:

JMSException

deleteSubscription

void deleteSubscription(String clientId,
                        String subscriberName)
                        throws JMSException

Delete a durable subscriber

Parameters:

clientId -

subscriberName -

Throws:

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

sendMessage

void sendMessage(BrokerClient client,
                 ActiveMQMessage message)
                 throws JMSException

Parameters:

client -

message -

Throws:

JMSException

acknowledgeMessage

void acknowledgeMessage(BrokerClient client,
                        MessageAck ack)
                        throws JMSException

Acknowledge a message as being read and consumed by the Consumer

Parameters:

client -

ack -

Throws:

JMSException

poll

void poll()
          throws JMSException

Poll for messages

Throws:

JMSException

getContainer

MessageContainer getContainer(String physicalName)
                              throws JMSException

Allows the lookup of a specific named message container

Parameters:

physicalName -

Returns:

the MessageContainer

Throws:

JMSException

getDeadLetterPolicy

DeadLetterPolicy getDeadLetterPolicy()

Returns:

the DeadLetterPolicy for this Container Manager

setDeadLetterPolicy

void setDeadLetterPolicy(DeadLetterPolicy policy)

Set the DeadLetterPolicy for this Container Manager

Parameters:

policy -