|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
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 |
public void createMessageContainer(ActiveMQDestination dest) throws JMSException
dest
-
JMSException
public void destroyMessageContainer(ActiveMQDestination dest) throws JMSException
dest
-
JMSException
public Map getMessageContainerAdmins() throws JMSException
MessageContainerAdmin
objects available in this container
JMSException
public Map getDestinations()
Destination
objects available in this container
public Map getLocalDestinations()
Destination
objects used by non-broker consumers directly connected to this container
public void addMessageConsumer(BrokerClient client, ConsumerInfo info) throws JMSException
client
- info
-
JMSException
public void removeMessageConsumer(BrokerClient client, ConsumerInfo info) throws JMSException
client
- info
-
JMSException
public void deleteSubscription(String clientId, String subscriberName) throws JMSException
clientId
- subscriberName
-
JMSException
- if the subscriber doesn't exist or is still activepublic void sendMessage(BrokerClient client, ActiveMQMessage message) throws JMSException
client
- message
-
JMSException
public void acknowledgeMessage(BrokerClient client, MessageAck ack) throws JMSException
client
- ack
-
JMSException
public void poll() throws JMSException
JMSException
public MessageContainer getContainer(String physicalName) throws JMSException
physicalName
-
JMSException
public DeadLetterPolicy getDeadLetterPolicy()
public void setDeadLetterPolicy(DeadLetterPolicy policy)
policy
-
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |