org.apache.activemq.broker.util
Class CommandMessageListener

java.lang.Object
  extended by org.apache.activemq.broker.util.CommandMessageListener
All Implemented Interfaces:
javax.jms.MessageListener

public class CommandMessageListener
extends java.lang.Object
implements javax.jms.MessageListener


Constructor Summary
CommandMessageListener(javax.jms.Session session)
           
 
Method Summary
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
 
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 java.lang.Exception
Processes an incoming JMS message returning the response message

Throws:
java.lang.Exception

processCommandText

public java.lang.String processCommandText(java.lang.String line)
                                    throws java.lang.Exception
Processes an incoming command from a console and returning the text to output

Throws:
java.lang.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 java.lang.IllegalAccessException,
                                 java.io.IOException,
                                 java.lang.InstantiationException,
                                 java.lang.ClassNotFoundException
Throws:
java.lang.IllegalAccessException
java.io.IOException
java.lang.InstantiationException
java.lang.ClassNotFoundException


Copyright © 2005-2012. All Rights Reserved.