org.apache.activemq.transport.amqp
Class AmqpTransportFilter

java.lang.Object
  extended by org.apache.activemq.transport.TransportFilter
      extended by org.apache.activemq.transport.amqp.AmqpTransportFilter
All Implemented Interfaces:
Service, AmqpTransport, Transport, TransportListener

public class AmqpTransportFilter
extends TransportFilter
implements AmqpTransport

The AMQPTransportFilter normally sits on top of a TcpTransport that has been configured with the StompWireFormat and is used to convert AMQP commands to ActiveMQ commands. All of the conversion work is done by delegating to the AMQPProtocolConverter


Field Summary
 
Fields inherited from class org.apache.activemq.transport.TransportFilter
next, transportListener
 
Constructor Summary
AmqpTransportFilter(Transport next, WireFormat wireFormat, BrokerContext brokerContext)
           
 
Method Summary
 X509Certificate[] getPeerCertificates()
           
 String getTransformer()
           
 AmqpWireFormat getWireFormat()
           
 void handleException(IOException e)
           
 boolean isTrace()
           
 void onCommand(Object command)
          called to process a command
 void oneway(Object o)
          A one way asynchronous send
 void onException(IOException error)
          An unrecoverable exception has occured on the transport
 void sendToActiveMQ(Command command)
           
 void sendToActiveMQ(IOException error)
           
 void sendToAmqp(Object command)
           
 void setTrace(boolean trace)
           
 void setTransformer(String transformer)
           
 
Methods inherited from class org.apache.activemq.transport.TransportFilter
asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, reconnect, request, request, setTransportListener, start, stop, toString, transportInterupted, transportResumed, updateURIs
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.activemq.transport.amqp.AmqpTransport
getRemoteAddress, stop
 

Constructor Detail

AmqpTransportFilter

public AmqpTransportFilter(Transport next,
                           WireFormat wireFormat,
                           BrokerContext brokerContext)
Method Detail

oneway

public void oneway(Object o)
            throws IOException
Description copied from interface: Transport
A one way asynchronous send

Specified by:
oneway in interface Transport
Overrides:
oneway in class TransportFilter
Throws:
IOException

onException

public void onException(IOException error)
Description copied from interface: TransportListener
An unrecoverable exception has occured on the transport

Specified by:
onException in interface AmqpTransport
Specified by:
onException in interface TransportListener
Overrides:
onException in class TransportFilter

sendToActiveMQ

public void sendToActiveMQ(IOException error)
Specified by:
sendToActiveMQ in interface AmqpTransport

onCommand

public void onCommand(Object command)
Description copied from interface: TransportListener
called to process a command

Specified by:
onCommand in interface TransportListener
Overrides:
onCommand in class TransportFilter

sendToActiveMQ

public void sendToActiveMQ(Command command)
Specified by:
sendToActiveMQ in interface AmqpTransport

sendToAmqp

public void sendToAmqp(Object command)
                throws IOException
Specified by:
sendToAmqp in interface AmqpTransport
Throws:
IOException

getPeerCertificates

public X509Certificate[] getPeerCertificates()
Specified by:
getPeerCertificates in interface AmqpTransport

isTrace

public boolean isTrace()
Specified by:
isTrace in interface AmqpTransport

setTrace

public void setTrace(boolean trace)

getWireFormat

public AmqpWireFormat getWireFormat()
Specified by:
getWireFormat in interface AmqpTransport

handleException

public void handleException(IOException e)

getTransformer

public String getTransformer()
Specified by:
getTransformer in interface AmqpTransport

setTransformer

public void setTransformer(String transformer)


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.