Package org.apache.synapse.transport.fix

Class FIXTransportListener

java.lang.Object
org.apache.axis2.transport.base.AbstractTransportListener
org.apache.synapse.transport.fix.FIXTransportListener
All Implemented Interfaces:
org.apache.axis2.transport.TransportListener
public class FIXTransportListener extends org.apache.axis2.transport.base.AbstractTransportListener
The FIX transport listener implementation. A FIX Transport Listner will hold a FIX session factory, which would be created at initialization time. This implementation supports the creation of FIX sessions at runtime as and when required. This FIX Listener registers with Axis to be notified of service deployment/undeployment/start/stop, and enables or disables listening for FIX messages on the destinations as appropriate.

Service must state where the FIX configuration file is located so that the required FIX sessions can be initialized for the service. FIX configuration file should be a valid Quickfix/J session configuration file. A URL to the file should be provided.

http://www.mycompany.org/fixconfig/file.cfg

  • Field Summary

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

    cfgCtx, config, isNonBlocking, log, metrics, state, useAxis2ThreadPool, workerPool

    Fields inherited from interface org.apache.axis2.transport.TransportListener

    HOST_ADDRESS, PARAM_PORT

  • Constructor Summary

    Constructors
    Constructor
    Description
    FIXTransportListener()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.axis2.addressing.EndpointReference[]
    getEPRsForService(String serviceName, String ip)
    Returns EPRs for the given service and IP over the FIX transport
    void
    init(org.apache.axis2.context.ConfigurationContext cfgCtx, org.apache.axis2.description.TransportInDescription trpInDesc)
    This is the TransportListener initialization method invoked by Axis2
    void
    startListeningForService(org.apache.axis2.description.AxisService service)
    Prepare to listen for FIX messages on behalf of the given service by first creating and starting a FIX session
    protected void
    stopListeningForService(org.apache.axis2.description.AxisService service)
    Stops listening for messages for the service thats undeployed or stopped by stopping and disposing the appropriate FIX session

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

    createMessageContext, destroy, disableTransportForService, getActiveThreadCount, getAvgSizeReceived, getAvgSizeSent, getBytesReceived, getBytesSent, getConfigurationContext, getEPRForService, getEPRsForService, getFaultsReceiving, getFaultsSending, getLastResetTime, getMaxSizeReceived, getMaxSizeSent, getMessagesReceived, getMessagesSent, getMetricsCollector, getMetricsWindow, getMinSizeReceived, getMinSizeSent, getQueueSize, getResponseCodeTable, getSessionContext, getTimeoutsReceiving, getTimeoutsSending, getTransportInDescription, getTransportName, handleException, handleIncomingMessage, logException, maintenenceShutdown, pause, resetStatistics, resume, start, stop

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • FIXTransportListener

      public FIXTransportListener()

  • Method Details

    • init

      public void init(org.apache.axis2.context.ConfigurationContext cfgCtx, org.apache.axis2.description.TransportInDescription trpInDesc) throws org.apache.axis2.AxisFault
      This is the TransportListener initialization method invoked by Axis2
      Specified by:
      init in interface org.apache.axis2.transport.TransportListener
      Overrides:
      init in class org.apache.axis2.transport.base.AbstractTransportListener
      Parameters:
      cfgCtx - the Axis configuration context
      trpInDesc - the TransportIn description
      Throws:
      org.apache.axis2.AxisFault

    • startListeningForService

      public void startListeningForService(org.apache.axis2.description.AxisService service)
      Prepare to listen for FIX messages on behalf of the given service by first creating and starting a FIX session
      Specified by:
      startListeningForService in class org.apache.axis2.transport.base.AbstractTransportListener
      Parameters:
      service - the service for which to listen for messages

    • stopListeningForService

      protected void stopListeningForService(org.apache.axis2.description.AxisService service)
      Stops listening for messages for the service thats undeployed or stopped by stopping and disposing the appropriate FIX session
      Specified by:
      stopListeningForService in class org.apache.axis2.transport.base.AbstractTransportListener
      Parameters:
      service - the service that was undeployed or stopped

    • getEPRsForService

      public org.apache.axis2.addressing.EndpointReference[] getEPRsForService(String serviceName, String ip) throws org.apache.axis2.AxisFault
      Returns EPRs for the given service and IP over the FIX transport
      Specified by:
      getEPRsForService in interface org.apache.axis2.transport.TransportListener
      Overrides:
      getEPRsForService in class org.apache.axis2.transport.base.AbstractTransportListener
      Parameters:
      serviceName - service name
      ip - ignored
      Returns:
      the EPR for the service
      Throws:
      org.apache.axis2.AxisFault