org.apache.synapse.transport.amqp
Class AMQPSender

java.lang.Object
  org.apache.axis2.handlers.AbstractHandler
      org.apache.synapse.transport.base.AbstractTransportSender
          org.apache.synapse.transport.amqp.AMQPSender

All Implemented Interfaces:

Handler, TransportSender

public class AMQPSender
extends AbstractTransportSender

Nested Class Summary

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

Handler.InvocationResponse

Field Summary

static String

TRANSPORT_NAME

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

cfgCtx, engine, metrics, transportName

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

handlerDesc

Constructor Summary

AMQPSender()

Method Summary

void	init(ConfigurationContext cfgCtx, TransportOutDescription transportOut) Initialize the generic transport sender.
void	sendMessage(MessageContext msgCtx, String targetEPR, OutTransportInfo outTransportInfo) Needs a more robust strategy to cache connections and sessions For efficiency I assume that the reply to exchange,queue and the binding already exists.

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

cleanup, createResponseMessageContext, getActiveThreadCount, getBytesReceived, getBytesSent, getFaultsReceiving, getFaultsSending, getMessagesReceived, getMessagesSent, getQueueSize, getTransportName, handleException, handleException, handleIncomingMessage, invoke, logException, maintenenceShutdown, pause, resume, setTransportName, stop, waitForSynchronousResponse

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

cleanup, 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

cleanup, flowComplete, getHandlerDesc, getName, getParameter, init

Field Detail

TRANSPORT_NAME

public static final String TRANSPORT_NAME

See Also:

Constant Field Values

Constructor Detail

AMQPSender

public AMQPSender()

Method Detail

init

public void init(ConfigurationContext cfgCtx,
                 TransportOutDescription transportOut)
          throws AxisFault

Description copied from class: AbstractTransportSender

Initialize the generic transport sender.

Specified by:

init in interface TransportSender

Overrides:

init in class AbstractTransportSender

Parameters:

cfgCtx - the axis configuration context

transportOut - the transport-out description

Throws:

AxisFault - on error

sendMessage

public void sendMessage(MessageContext msgCtx,
                        String targetEPR,
                        OutTransportInfo outTransportInfo)
                 throws AxisFault

Needs a more robust strategy to cache connections and sessions For efficiency I assume that the reply to exchange,queue and the binding already exists. For synchrouns request/reponse a temp queue will be create and bound to the direct exchange.

Specified by:

sendMessage in class AbstractTransportSender

Throws:

AxisFault