|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.service.boundedvm.TransientQueueBoundedMessageManager
A manager of MessageContainer instances
Constructor Summary | |
TransientQueueBoundedMessageManager(MemoryBoundedQueueManager mgr)
Constructor for TransientQueueBoundedMessageManager |
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)
Add a consumer if appropiate |
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) |
protected MessageContainer |
createContainer(String destinationName)
|
protected Destination |
createDestination(String destinationName)
|
protected Filter |
createFilter(ConsumerInfo info)
Create filter for a Consumer |
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 |
run()
collect expired messages |
void |
sendMessage(BrokerClient client,
ActiveMQMessage message)
|
void |
start()
start the manager |
void |
stop()
stop the manager |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public TransientQueueBoundedMessageManager(MemoryBoundedQueueManager mgr)
mgr
- Method Detail |
public void start() throws JMSException
start
in interface Service
JMSException
public void stop() throws JMSException
stop
in interface Service
JMSException
public void run()
run
in interface Runnable
public void addMessageConsumer(BrokerClient client, ConsumerInfo info) throws JMSException
addMessageConsumer
in interface MessageContainerManager
client
- info
-
JMSException
public void removeMessageConsumer(BrokerClient client, ConsumerInfo info) throws JMSException
removeMessageConsumer
in interface MessageContainerManager
client
- info
-
JMSException
public void deleteSubscription(String clientId, String subscriberName) throws JMSException
deleteSubscription
in interface MessageContainerManager
clientId
- subscriberName
-
JMSException
- if the subscriber doesn't exist or is still activepublic void sendMessage(BrokerClient client, ActiveMQMessage message) throws JMSException
sendMessage
in interface MessageContainerManager
client
- message
-
JMSException
public void acknowledgeMessage(BrokerClient client, MessageAck ack) throws JMSException
MessageContainerManager
acknowledgeMessage
in interface MessageContainerManager
client
- ack
-
JMSException
public void acknowledgeTransactedMessage(BrokerClient client, String transactionId, MessageAck ack) throws JMSException
MessageContainerManager
acknowledgeTransactedMessage
in interface MessageContainerManager
client
- transactionId
- ack
-
JMSException
public void redeliverMessage(BrokerClient client, MessageAck ack) throws JMSException
MessageContainerManager
redeliverMessage
in interface MessageContainerManager
client
- ack
-
JMSException
public void poll() throws JMSException
MessageContainerManager
poll
in interface MessageContainerManager
JMSException
public void commitTransaction(BrokerClient client, String transactionId) throws JMSException
commitTransaction
in interface MessageContainerManager
client
- transactionId
-
JMSException
public void rollbackTransaction(BrokerClient client, String transactionId)
rollbackTransaction
in interface MessageContainerManager
client
- transactionId
- public MessageContainer getContainer(String physicalName) throws JMSException
MessageContainerManager
getContainer
in interface MessageContainerManager
physicalName
-
JMSException
public Map getDestinations()
MessageContainerManager
Destination
objects available in this container
getDestinations
in interface MessageContainerManager
protected Filter createFilter(ConsumerInfo info) throws JMSException
info
-
JMSException
protected Destination createDestination(String destinationName)
protected MessageContainer createContainer(String destinationName) throws JMSException
JMSException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |