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
-
-
Constructor Summary
Constructors Constructor Description FIXTransportListener()
-
Method Summary
All Methods Instance Methods Concrete Methods 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 transportvoid
init(org.apache.axis2.context.ConfigurationContext cfgCtx, org.apache.axis2.description.TransportInDescription trpInDesc)
This is the TransportListener initialization method invoked by Axis2void
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 sessionprotected 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
-
-
-
-
Method Detail
-
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 interfaceorg.apache.axis2.transport.TransportListener
- Overrides:
init
in classorg.apache.axis2.transport.base.AbstractTransportListener
- Parameters:
cfgCtx
- the Axis configuration contexttrpInDesc
- 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 classorg.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 classorg.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 interfaceorg.apache.axis2.transport.TransportListener
- Overrides:
getEPRsForService
in classorg.apache.axis2.transport.base.AbstractTransportListener
- Parameters:
serviceName
- service nameip
- ignored- Returns:
- the EPR for the service
- Throws:
org.apache.axis2.AxisFault
-
-