Package org.apache.synapse.transport.fix

Class FIXTransportSender

  • All Implemented Interfaces:
    org.apache.axis2.engine.Handler, org.apache.axis2.transport.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

        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

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void init​(org.apache.axis2.context.ConfigurationContext cfgCtx, org.apache.axis2.description.TransportOutDescription transportOut)  
      void logOutIncomingSession​(quickfix.SessionID sessionID)  
      void sendMessage​(org.apache.axis2.context.MessageContext msgCtx, String targetEPR, org.apache.axis2.transport.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 interface org.apache.axis2.engine.Handler

        cleanup, flowComplete, getHandlerDesc, getName, getParameter, init

    • Constructor Detail

      • FIXTransportSender

        public FIXTransportSender()

    • 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
        Parameters:
        cfgCtx - the axis2 configuration context
        transportOut - the Out Transport description
        Throws:
        org.apache.axis2.AxisFault - on error

      • 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
        Performs the actual sending of the message.
        Specified by:
        sendMessage in class org.apache.axis2.transport.base.AbstractTransportSender
        Parameters:
        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
        Throws:
        org.apache.axis2.AxisFault - on error

      • logOutIncomingSession

        public void logOutIncomingSession​(quickfix.SessionID sessionID)