org.apache.activemq.broker.util
Class CommandAgent

java.lang.Object
  extended by org.apache.activemq.broker.util.CommandAgent
All Implemented Interfaces:
BrokerServiceAware, Service

public class CommandAgent
extends java.lang.Object
implements Service, BrokerServiceAware

An agent which listens to commands on a JMS destination

Version:
$Revision: $

Constructor Summary
CommandAgent()
           
 
Method Summary
protected  javax.jms.Destination createCommandDestination()
           
protected  javax.jms.Connection createConnection()
           
 java.lang.String getBrokerUrl()
           
 javax.jms.Destination getCommandDestination()
           
 javax.jms.Connection getConnection()
           
 javax.jms.ConnectionFactory getConnectionFactory()
           
 void setBrokerService(BrokerService brokerService)
           
 void setBrokerUrl(java.lang.String brokerUrl)
           
 void setCommandDestination(javax.jms.Destination commandDestination)
           
 void setConnection(javax.jms.Connection connection)
           
 void setConnectionFactory(javax.jms.ConnectionFactory connectionFactory)
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

CommandAgent

public CommandAgent()
Method Detail

start

public void start()
           throws java.lang.Exception
Specified by:
start in interface Service
Throws:
java.lang.Exception

stop

public void stop()
          throws java.lang.Exception
Specified by:
stop in interface Service
Throws:
java.lang.Exception

setBrokerService

public void setBrokerService(BrokerService brokerService)
Specified by:
setBrokerService in interface BrokerServiceAware

getBrokerUrl

public java.lang.String getBrokerUrl()

setBrokerUrl

public void setBrokerUrl(java.lang.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.