|
|||||||||||
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 |
acknowledgeTransactedMessage(BrokerClient client,
String transactionId,
MessageAck ack)
This is a hook to notify the dispatcher for the clients subscription that we have acknowledged a message within a transaction but before the commit - so the message is not really being acknowledged here but this method is intended to be a hook to let the dispatcher know that we can now send another message to the client. |
void |
addMessageConsumer(BrokerClient client,
ConsumerInfo info)
|
void |
commitTransaction(BrokerClient client,
String transactionId)
A hook when the transaction is about to be commited; so apply all outstanding commands to the Journal if using a Journal (transaction log) |
void |
deleteSubscription(String clientId,
String subscriberName)
Delete a durable subscriber |
MessageContainer |
getContainer(String physicalName)
Allows the lookup of a specific named message container |
Map |
getDestinations()
Returns an unmodifiable map, indexed by String name, of all the Destination
objects available in this container |
void |
poll()
Poll for messages |
void |
redeliverMessage(BrokerClient client,
MessageAck ack)
Called after a rollback of a JMS transaction to redeliver the message to the consumers dispatch queue |
void |
removeMessageConsumer(BrokerClient client,
ConsumerInfo info)
|
void |
rollbackTransaction(BrokerClient client,
String transactionId)
A hook when the transaction is about to be rolled back; so discard all outstanding commands that are pending to be written to the Journal |
void |
sendMessage(BrokerClient client,
ActiveMQMessage message)
|
Methods inherited from interface org.codehaus.activemq.service.Service |
start, stop |
Method Detail |
public Map getDestinations()
Destination
objects available in 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 redeliverMessage(BrokerClient client, MessageAck ack) throws JMSException
client
- ack
-
JMSException
public void poll() throws JMSException
JMSException
public void commitTransaction(BrokerClient client, String transactionId) throws JMSException
client
- transactionId
-
JMSException
public void rollbackTransaction(BrokerClient client, String transactionId)
client
- transactionId
- public MessageContainer getContainer(String physicalName) throws JMSException
physicalName
-
JMSException
public void acknowledgeTransactedMessage(BrokerClient client, String transactionId, MessageAck ack) throws JMSException
JMSException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |