org.apache.synapse.transport.amqp

Class AMQPTransportSender

java.lang.Object

org.apache.axis2.handlers.AbstractHandler

org.apache.axis2.transport.base.AbstractTransportSender

org.apache.synapse.transport.amqp.AMQPTransportSender

All Implemented Interfaces:

org.apache.axis2.engine.Handler, org.apache.axis2.transport.TransportSender

public class AMQPTransportSender
extends org.apache.axis2.transport.base.AbstractTransportSender

The transport sender implementation for AMQP transport. A message can end up here as part of directly calling an AMQP endpoint or sending a response to a two way request message.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.axis2.engine.Handler

org.apache.axis2.engine.Handler.InvocationResponse

Field Summary

Fields inherited from class org.apache.axis2.transport.base.AbstractTransportSender

cfgCtx, log, metrics

Fields inherited from class org.apache.axis2.handlers.AbstractHandler

handlerDesc

Constructor Summary

Constructors

Constructor and Description
AMQPTransportSender()

Method Summary

Modifier and Type	Method and Description
void	init(org.apache.axis2.context.ConfigurationContext cfgCtx, org.apache.axis2.description.TransportOutDescription transportOut)
void	sendMessage(org.apache.axis2.context.MessageContext msgCtx, String targetEPR, org.apache.axis2.transport.OutTransportInfo outTransportInfo)
void	stop()

Methods inherited from class org.apache.axis2.transport.base.AbstractTransportSender

cleanup, createResponseMessageContext, getActiveThreadCount, getAvgSizeReceived, getAvgSizeSent, getBytesReceived, getBytesSent, getFaultsReceiving, getFaultsSending, getLastResetTime, getMaxSizeReceived, getMaxSizeSent, getMessagesReceived, getMessagesSent, getMetricsWindow, getMinSizeReceived, getMinSizeSent, getQueueSize, getResponseCodeTable, getTimeoutsReceiving, getTimeoutsSending, getTransportName, handleException, handleException, handleIncomingMessage, invoke, logException, maintenenceShutdown, pause, resetStatistics, resume, waitForSynchronousResponse

Methods inherited from class org.apache.axis2.handlers.AbstractHandler

flowComplete, getHandlerDesc, getName, getParameter, init, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.axis2.engine.Handler

flowComplete, getHandlerDesc, getName, getParameter, init

Constructor Detail

AMQPTransportSender

public AMQPTransportSender()

Method Detail

init

public void init(org.apache.axis2.context.ConfigurationContext cfgCtx,
                 org.apache.axis2.description.TransportOutDescription transportOut)
          throws org.apache.axis2.AxisFault

Specified by:

init in interface org.apache.axis2.transport.TransportSender

Overrides:

init in class org.apache.axis2.transport.base.AbstractTransportSender

Throws:

org.apache.axis2.AxisFault

stop

public void stop()

Specified by:

stop in interface org.apache.axis2.transport.TransportSender

Overrides:

stop in class org.apache.axis2.transport.base.AbstractTransportSender

sendMessage

public void sendMessage(org.apache.axis2.context.MessageContext msgCtx,
                        String targetEPR,
                        org.apache.axis2.transport.OutTransportInfo outTransportInfo)
                 throws org.apache.axis2.AxisFault

Specified by:

sendMessage in class org.apache.axis2.transport.base.AbstractTransportSender

Throws:

org.apache.axis2.AxisFault