Class FIXTransportSender

  extended by org.apache.axis2.handlers.AbstractHandler
      extended by org.apache.axis2.transport.base.AbstractTransportSender
          extended by org.apache.synapse.transport.fix.FIXTransportSender
All Implemented Interfaces:
Handler, TransportSender

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

The FIX transport sender implementation. This implementation looks at the SOAPBody of the message context to identify how the message was first received by Axis2 engine and also looks at some FIX header fields to make the optimum routing decision.

This transport sender implementation does not support forwarding FIX messages to sessions with different BeginString values.When it performs a message forwarding it makes sure the forwarding takes place according to the conditions specified in the 'Third Party Routing' section in the FIX protocol specification.

Nested Class Summary
Nested classes/interfaces inherited from interface org.apache.axis2.engine.Handler
Field Summary
Fields inherited from class org.apache.axis2.transport.base.AbstractTransportSender
cfgCtx, log, metrics
Fields inherited from class org.apache.axis2.handlers.AbstractHandler
Constructor Summary
Method Summary
 void init(ConfigurationContext cfgCtx, TransportOutDescription transportOut)
 void logOutIncomingSession(quickfix.SessionID sessionID)
 void sendMessage(MessageContext msgCtx, String targetEPR, OutTransportInfo outTransportInfo)
          Performs the actual sending of the message.
 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
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

Constructor Detail


public FIXTransportSender()
Method Detail


public void init(ConfigurationContext cfgCtx,
                 TransportOutDescription transportOut)
          throws AxisFault
Specified by:
init in interface TransportSender
init in class org.apache.axis2.transport.base.AbstractTransportSender
cfgCtx - the axis2 configuration context
transportOut - the Out Transport description
AxisFault - on error


public void stop()
Specified by:
stop in interface TransportSender
stop in class org.apache.axis2.transport.base.AbstractTransportSender


public void sendMessage(MessageContext msgCtx,
                        String targetEPR,
                        OutTransportInfo outTransportInfo)
                 throws AxisFault
Performs the actual sending of the message.

Specified by:
sendMessage in class org.apache.axis2.transport.base.AbstractTransportSender
msgCtx - the axis2 message context of the message to be sent
targetEPR - the EPR for which the message is to be sent
outTransportInfo - the OutTransportInfo for the message
AxisFault - on error


public void logOutIncomingSession(quickfix.SessionID sessionID)

Copyright © 2005-2012 Apache Software Foundation. All Rights Reserved.