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

Version:
$Revision: $

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)
           
protected  javax.jms.Message processCommand(javax.jms.TextMessage request)
           
 
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

protected javax.jms.Message processCommand(javax.jms.TextMessage request)
                                    throws java.lang.Exception
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 © 2011 Apache Software Foundation. All Rights Reserved.