org.apache.activemq.broker.util
Class CommandAgent
java.lang.Object
org.apache.activemq.broker.util.CommandAgent
- All Implemented Interfaces:
- BrokerServiceAware, Service
public class CommandAgent
- extends Object
- implements Service, BrokerServiceAware
An agent which listens to commands on a JMS destination
- Version:
- $Revision: $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CommandAgent
public CommandAgent()
start
public void start()
throws Exception
- Specified by:
start
in interface Service
- Throws:
Exception
stop
public void stop()
throws Exception
- Specified by:
stop
in interface Service
- Throws:
Exception
setBrokerService
public void setBrokerService(BrokerService brokerService)
- Specified by:
setBrokerService
in interface BrokerServiceAware
getBrokerUrl
public String getBrokerUrl()
setBrokerUrl
public void setBrokerUrl(String brokerUrl)
getConnectionFactory
public javax.jms.ConnectionFactory getConnectionFactory()
setConnectionFactory
public void setConnectionFactory(javax.jms.ConnectionFactory connectionFactory)
getConnection
public javax.jms.Connection getConnection()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
setConnection
public void setConnection(javax.jms.Connection connection)
getCommandDestination
public javax.jms.Destination getCommandDestination()
setCommandDestination
public void setCommandDestination(javax.jms.Destination commandDestination)
createConnection
protected javax.jms.Connection createConnection()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
createCommandDestination
protected javax.jms.Destination createCommandDestination()
Copyright © 2011 Apache Software Foundation. All Rights Reserved.