|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.service.impl.ProxyMessageContainerManager
public abstract class ProxyMessageContainerManager
A Proxy implementation of MessageContainerManager
which
delegates to some other implementation which is useful for writing
Facade implementations
Constructor Summary | |
---|---|
ProxyMessageContainerManager()
|
|
ProxyMessageContainerManager(MessageContainerManager delegate)
|
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 destination)
Creates a destination. |
void |
deleteSubscription(String clientId,
String subscriberName)
Delete a durable subscriber |
void |
destroyMessageContainer(ActiveMQDestination destination)
Destroys a destination. |
MessageContainer |
getContainer(String physicalName)
Allows the lookup of a specific named message container |
DeadLetterPolicy |
getDeadLetterPolicy()
|
protected MessageContainerManager |
getDelegate()
|
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 |
protected void |
setDelegate(MessageContainerManager delegate)
|
void |
start()
Called to start the service |
void |
stop()
Called to shutdown the service |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ProxyMessageContainerManager()
public ProxyMessageContainerManager(MessageContainerManager delegate)
Method Detail |
---|
public Map getDestinations()
MessageContainerManager
Destination
objects available in this container
getDestinations
in interface MessageContainerManager
public Map getLocalDestinations()
MessageContainerManager
Destination
objects used by non-broker consumers directly connected to this container
getLocalDestinations
in interface MessageContainerManager
public void acknowledgeMessage(BrokerClient client, MessageAck ack) throws JMSException
MessageContainerManager
acknowledgeMessage
in interface MessageContainerManager
JMSException
public void addMessageConsumer(BrokerClient client, ConsumerInfo info) throws JMSException
addMessageConsumer
in interface MessageContainerManager
JMSException
public void deleteSubscription(String clientId, String subscriberName) throws JMSException
MessageContainerManager
deleteSubscription
in interface MessageContainerManager
JMSException
- if the subscriber doesn't exist or is still activepublic void poll() throws JMSException
MessageContainerManager
poll
in interface MessageContainerManager
JMSException
public void removeMessageConsumer(BrokerClient client, ConsumerInfo info) throws JMSException
removeMessageConsumer
in interface MessageContainerManager
JMSException
public void sendMessage(BrokerClient client, ActiveMQMessage message) throws JMSException
sendMessage
in interface MessageContainerManager
JMSException
public MessageContainer getContainer(String physicalName) throws JMSException
MessageContainerManager
getContainer
in interface MessageContainerManager
JMSException
public void start() throws JMSException
Service
start
in interface Service
JMSException
public void stop() throws JMSException
Service
stop
in interface Service
JMSException
public void createMessageContainer(ActiveMQDestination destination) throws JMSException
MessageContainerManager
createMessageContainer
in interface MessageContainerManager
JMSException
public void destroyMessageContainer(ActiveMQDestination destination) throws JMSException
MessageContainerManager
destroyMessageContainer
in interface MessageContainerManager
JMSException
public Map getMessageContainerAdmins() throws JMSException
MessageContainerManager
MessageContainerAdmin
objects available in this container
getMessageContainerAdmins
in interface MessageContainerManager
JMSException
public DeadLetterPolicy getDeadLetterPolicy()
getDeadLetterPolicy
in interface MessageContainerManager
public void setDeadLetterPolicy(DeadLetterPolicy policy)
setDeadLetterPolicy
in interface MessageContainerManager
policy
- protected MessageContainerManager getDelegate()
protected void setDelegate(MessageContainerManager delegate)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |