public class FIXTransportListener extends AbstractTransportListener
The FIX Transport listener
This is transport listener to which uses Quickfix/j engine to receive messages from FIX destinations into the ESB
Creates,starts or stops fix socket acceptors which receives fix messages.
One socket acceptor is created for one transport listener.>
Following FIX acceptor [default] properties should be defined for this instance
ConfigurationElement.State
logger, metrics, properties, serverName, transportName
Constructor and Description |
---|
FIXTransportListener() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getOriginatingTransportName() |
void |
registerProxyService(org.adroitlogic.ultraesb.core.ProxyService ps,
java.lang.String uriPattern,
java.util.Map properties) |
void |
setEndTime(java.lang.String endTime) |
void |
setHeartBeatIntervalSec(java.lang.String heartBeatIntervalSec) |
void |
setLogFactory(FIXLogFactory logFactory) |
void |
setMessageStoreFactory(FIXMessageStoreFactory messageStoreFactory) |
void |
setOtherSettings(java.util.Map otherSettings) |
void |
setSenderCompID(java.lang.String senderCompID) |
void |
setSocketAcceptPort(java.lang.String socketAcceptPort) |
void |
setStartTime(java.lang.String startTime) |
void |
start() |
void |
stop() |
void |
unregisterProxyService(org.adroitlogic.ultraesb.core.ProxyService ps)
Close all the sessions established while registering proxy service
|
getAccessURLs, getDetails, init, resetStatistics, setProperties, toBasicView, toDetailedView, toDetailedViewExt
equals, getDeploymentUnit, getDerivedName, getId, getState, getStreamCount, getTimerStreamMax, getTimerStreamMean, getTimerStreamMin, getTimerStreamPer, hashCode, init, isDebugOn, isStarted, maintenanceShutdown, markAsOutdated, pause, resetCounter, resetTimer, resolveMetricsStreams, resume, setBeanName, setConfig, setDebugOn, setDerivedName, setId, setMetricsEngine, setState, throwIllegalStateException, undeploy
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
retire
public java.lang.String getOriginatingTransportName()
public void registerProxyService(org.adroitlogic.ultraesb.core.ProxyService ps, java.lang.String uriPattern, java.util.Map properties)
public void start()
start
in interface ConfigurationElement
start
in class org.adroitlogic.ultraesb.core.config.AbstractConfigurationElement
public void stop()
stop
in interface ConfigurationElement
stop
in class org.adroitlogic.ultraesb.core.config.AbstractConfigurationElement
public void unregisterProxyService(org.adroitlogic.ultraesb.core.ProxyService ps)
ps
- proxy servicepublic void setSenderCompID(java.lang.String senderCompID)
public void setSocketAcceptPort(java.lang.String socketAcceptPort)
public void setHeartBeatIntervalSec(java.lang.String heartBeatIntervalSec)
public void setOtherSettings(java.util.Map otherSettings)
public void setStartTime(java.lang.String startTime)
public void setEndTime(java.lang.String endTime)
public void setMessageStoreFactory(FIXMessageStoreFactory messageStoreFactory)
public void setLogFactory(FIXLogFactory logFactory)