public class CommandMessageListener extends 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
|
String |
processCommandText(String line)
Processes an incoming command from a console and returning the text to
output
|
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 Exception
Exception
public String processCommandText(String line) throws Exception
Exception
public javax.jms.Session getSession()
public javax.jms.MessageProducer getProducer() throws javax.jms.JMSException
javax.jms.JMSException
public CommandHandler getHandler() throws IllegalAccessException, IOException, InstantiationException, ClassNotFoundException
Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.