public class FIXTransportListener
extends org.apache.axis2.transport.base.AbstractTransportListener
Constructor and Description |
---|
FIXTransportListener() |
Modifier and Type | Method and 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
|
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
public void init(org.apache.axis2.context.ConfigurationContext cfgCtx, org.apache.axis2.description.TransportInDescription trpInDesc) throws org.apache.axis2.AxisFault
init
in interface org.apache.axis2.transport.TransportListener
init
in class org.apache.axis2.transport.base.AbstractTransportListener
cfgCtx
- the Axis configuration contexttrpInDesc
- the TransportIn descriptionorg.apache.axis2.AxisFault
public void startListeningForService(org.apache.axis2.description.AxisService service)
startListeningForService
in class org.apache.axis2.transport.base.AbstractTransportListener
service
- the service for which to listen for messagesprotected void stopListeningForService(org.apache.axis2.description.AxisService service)
stopListeningForService
in class org.apache.axis2.transport.base.AbstractTransportListener
service
- the service that was undeployed or stoppedpublic org.apache.axis2.addressing.EndpointReference[] getEPRsForService(String serviceName, String ip) throws org.apache.axis2.AxisFault
getEPRsForService
in interface org.apache.axis2.transport.TransportListener
getEPRsForService
in class org.apache.axis2.transport.base.AbstractTransportListener
serviceName
- service nameip
- ignoredorg.apache.axis2.AxisFault
Copyright © 2005-2017 Apache Software Foundation. All Rights Reserved.