org.apache.activemq.broker.util
public class CommandMessageListener extends java.lang.Object implements javax.jms.MessageListener
Constructor and Description |
---|
CommandMessageListener(javax.jms.Session session) |
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
|
java.lang.String |
processCommandText(java.lang.String line)
Processes an incoming command from a console and returning the text to
output
|
public CommandMessageListener(javax.jms.Session session)
public void onMessage(javax.jms.Message message)
onMessage
in interface javax.jms.MessageListener
protected void addReplyHeaders(javax.jms.TextMessage request, javax.jms.Message response) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.Message processCommand(javax.jms.TextMessage request) throws java.lang.Exception
java.lang.Exception
public java.lang.String processCommandText(java.lang.String line) throws java.lang.Exception
java.lang.Exception
public javax.jms.Session getSession()
public javax.jms.MessageProducer getProducer() throws javax.jms.JMSException
javax.jms.JMSException
public CommandHandler getHandler() throws java.lang.IllegalAccessException, java.io.IOException, java.lang.InstantiationException, java.lang.ClassNotFoundException
java.lang.IllegalAccessException
java.io.IOException
java.lang.InstantiationException
java.lang.ClassNotFoundException
Copyright © 2005-2014. All Rights Reserved.