org.apache.activemq.transport.amqp
Class AMQPProtocolDiscriminator

java.lang.Object
  extended by org.apache.activemq.transport.amqp.AMQPProtocolDiscriminator
All Implemented Interfaces:
IAmqpProtocolConverter

public class AMQPProtocolDiscriminator
extends Object
implements IAmqpProtocolConverter

Used to assign the best implementation of a AmqpProtocolConverter to the AmqpTransport based on the AmqpHeader that the client sends us.


Constructor Summary
AMQPProtocolDiscriminator(AmqpTransport transport)
           
 
Method Summary
 void onActiveMQCommand(Command command)
           
 void onAMQPData(Object command)
           
 void onAMQPException(IOException error)
           
 void updateTracer()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AMQPProtocolDiscriminator

public AMQPProtocolDiscriminator(AmqpTransport transport)
Method Detail

onAMQPData

public void onAMQPData(Object command)
                throws Exception
Specified by:
onAMQPData in interface IAmqpProtocolConverter
Throws:
Exception

onAMQPException

public void onAMQPException(IOException error)
Specified by:
onAMQPException in interface IAmqpProtocolConverter

onActiveMQCommand

public void onActiveMQCommand(Command command)
                       throws Exception
Specified by:
onActiveMQCommand in interface IAmqpProtocolConverter
Throws:
Exception

updateTracer

public void updateTracer()
Specified by:
updateTracer in interface IAmqpProtocolConverter


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.