|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.service.impl.MessageContainerManagerSupport
Field Summary | |
protected Dispatcher |
dispatcher
|
protected Map |
messageContainers
|
Constructor Summary | |
MessageContainerManagerSupport(Dispatcher dispatcher)
|
Method Summary | |
protected abstract MessageContainer |
createContainer(String destinationName)
Factory method to create a new MessageContainer |
protected abstract Destination |
createDestination(String destinationName)
Factory method to create a new Destination |
MessageContainer |
getContainer(String destinationName)
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 |
boolean |
isMaintainDestinationStats()
|
protected void |
loadContainer(String destinationName,
Destination destination)
Loads the container for the given name and destination on startup |
void |
setMaintainDestinationStats(boolean maintainDestinationStats)
|
void |
start()
Called to start the service |
void |
stop()
Called to shutdown the service |
protected void |
updateAcknowledgeStats(BrokerClient client,
Subscription subscription)
Updates the message acknowledgement stats |
protected void |
updateSendStats(BrokerClient client,
ActiveMQMessage message)
Updates the message sending stats |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.codehaus.activemq.service.MessageContainerManager |
acknowledgeMessage, acknowledgeTransactedMessage, addMessageConsumer, commitTransaction, deleteSubscription, poll, redeliverMessage, removeMessageConsumer, rollbackTransaction, sendMessage |
Field Detail |
protected Dispatcher dispatcher
protected Map messageContainers
Constructor Detail |
public MessageContainerManagerSupport(Dispatcher dispatcher)
Method Detail |
public Map getDestinations()
MessageContainerManager
Destination
objects available in this container
getDestinations
in interface MessageContainerManager
public void start() throws JMSException
Service
start
in interface Service
JMSException
public void stop() throws JMSException
Service
stop
in interface Service
JMSException
public MessageContainer getContainer(String destinationName) throws JMSException
MessageContainerManager
getContainer
in interface MessageContainerManager
destinationName
-
JMSException
public boolean isMaintainDestinationStats()
public void setMaintainDestinationStats(boolean maintainDestinationStats)
protected abstract Destination createDestination(String destinationName)
Destination
protected abstract MessageContainer createContainer(String destinationName) throws JMSException
MessageContainer
JMSException
protected void loadContainer(String destinationName, Destination destination) throws JMSException
JMSException
protected void updateAcknowledgeStats(BrokerClient client, Subscription subscription)
client
- subscription
- protected void updateSendStats(BrokerClient client, ActiveMQMessage message) throws JMSException
client
- message
-
JMSException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |