Package org.apache.activemq.transport.amqp

Class AmqpTransportFilter

java.lang.Object

org.apache.activemq.transport.TransportFilter

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 AmqpWireFormat 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

Modifier and Type	Field	Description
static org.slf4j.Logger	TRACE_FRAMES

Fields inherited from class org.apache.activemq.transport.TransportFilter

next, transportListener

Constructor Summary

Constructors

Constructor	Description
AmqpTransportFilter(Transport next, WireFormat wireFormat, BrokerService brokerService)

Method Summary

Modifier and Type	Method	Description
int	getConnectAttemptTimeout()
AmqpInactivityMonitor	getInactivityMonitor()
long	getMaxFrameSize()
X509Certificate[]	getPeerCertificates()
int	getProducerCredit()
AmqpProtocolConverter	getProtocolConverter()
String	getTransformer()
AmqpWireFormat	getWireFormat()	Retrieves the WireFormat instance associated with this Transport instance.
void	handleException(IOException e)
boolean	isTrace()
boolean	isUseInactivityMonitor()
long	keepAlive()
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(IOException error)
void	sendToActiveMQ(Command command)
void	sendToAmqp(Object command)
void	setConnectAttemptTimeout(int connectAttemptTimeout)
void	setInactivityMonitor(AmqpInactivityMonitor monitor)
void	setMaxFrameSize(long maxFrameSize)
void	setProducerCredit(int producerCredit)
void	setProtocolConverter(AmqpProtocolConverter protocolConverter)
void	setTrace(boolean trace)
void	setTransformer(String transformer)
void	start()

Methods inherited from class org.apache.activemq.transport.TransportFilter

asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, reconnect, request, request, setPeerCertificates, setTransportListener, 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

Field Detail

TRACE_FRAMES

public static final org.slf4j.Logger TRACE_FRAMES

Constructor Detail

AmqpTransportFilter

public AmqpTransportFilter(Transport next,
                           WireFormat wireFormat,
                           BrokerService brokerService)

Method Detail

start

public void start()
           throws Exception

Specified by:

start in interface Service

Overrides:

start in class TransportFilter

Throws:

Exception

See Also:

Service.start()

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

keepAlive

public long keepAlive()

Specified by:

keepAlive in interface AmqpTransport

getPeerCertificates

public X509Certificate[] getPeerCertificates()

Specified by:

getPeerCertificates in interface AmqpTransport

Specified by:

getPeerCertificates in interface Transport

Overrides:

getPeerCertificates in class TransportFilter

Returns:

the Certificates provided by the peer, or null if not a secure channel.

isTrace

public boolean isTrace()

Specified by:

isTrace in interface AmqpTransport

setTrace

public void setTrace(boolean trace)

getWireFormat

public AmqpWireFormat getWireFormat()

Description copied from interface: Transport

Retrieves the WireFormat instance associated with this Transport instance.

Specified by:

getWireFormat in interface AmqpTransport

Specified by:

getWireFormat in interface Transport

Overrides:

getWireFormat in class TransportFilter

Returns:

the WireFormat in use.

handleException

public void handleException(IOException e)

getTransformer

public String getTransformer()

Specified by:

getTransformer in interface AmqpTransport

setTransformer

public void setTransformer(String transformer)

getProtocolConverter

public AmqpProtocolConverter getProtocolConverter()

Specified by:

getProtocolConverter in interface AmqpTransport

setProtocolConverter

public void setProtocolConverter(AmqpProtocolConverter protocolConverter)

Specified by:

setProtocolConverter in interface AmqpTransport

setProducerCredit

public void setProducerCredit(int producerCredit)

getProducerCredit

public int getProducerCredit()

setInactivityMonitor

public void setInactivityMonitor(AmqpInactivityMonitor monitor)

Specified by:

setInactivityMonitor in interface AmqpTransport

getInactivityMonitor

public AmqpInactivityMonitor getInactivityMonitor()

Specified by:

getInactivityMonitor in interface AmqpTransport

isUseInactivityMonitor

public boolean isUseInactivityMonitor()

Specified by:

isUseInactivityMonitor in interface AmqpTransport

getConnectAttemptTimeout

public int getConnectAttemptTimeout()

setConnectAttemptTimeout

public void setConnectAttemptTimeout(int connectAttemptTimeout)

getMaxFrameSize

public long getMaxFrameSize()

setMaxFrameSize

public void setMaxFrameSize(long maxFrameSize)