org.apache.activemq.broker.util

Class CommandMessageListener

java.lang.Object

org.apache.activemq.broker.util.CommandMessageListener

All Implemented Interfaces:

javax.jms.MessageListener

public class CommandMessageListener
extends Object
implements javax.jms.MessageListener

Constructor Summary

Constructors

Constructor and Description
CommandMessageListener(javax.jms.Session session)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	addReplyHeaders(javax.jms.TextMessage request, javax.jms.Message response)
CommandHandler	getHandler()
javax.jms.MessageProducer	getProducer()
javax.jms.Session	getSession()
void	onMessage(javax.jms.Message message)
javax.jms.Message	processCommand(javax.jms.TextMessage request) Processes an incoming JMS message returning the response message
String	processCommandText(String line) Processes an incoming command from a console and returning the text to output

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CommandMessageListener

public CommandMessageListener(javax.jms.Session session)

Method Detail

onMessage

public void onMessage(javax.jms.Message message)

Specified by:

onMessage in interface javax.jms.MessageListener

addReplyHeaders

protected void addReplyHeaders(javax.jms.TextMessage request,
                   javax.jms.Message response)
                        throws javax.jms.JMSException

Throws:

javax.jms.JMSException

processCommand

public javax.jms.Message processCommand(javax.jms.TextMessage request)
                                 throws Exception

Processes an incoming JMS message returning the response message

Throws:

Exception

processCommandText

public String processCommandText(String line)
                          throws Exception

Processes an incoming command from a console and returning the text to output

Throws:

Exception

getSession

public javax.jms.Session getSession()

getProducer

public javax.jms.MessageProducer getProducer()
                                      throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getHandler

public CommandHandler getHandler()
                          throws IllegalAccessException,
                                 IOException,
                                 InstantiationException,
                                 ClassNotFoundException

Throws:

IllegalAccessException

IOException

InstantiationException

ClassNotFoundException