public class FIXTransportSender extends AbstractTransportSender
FIX transport sender
Fix initiator [default] properties should be defined for this instance
ConfigurationElement.State
metrics, originatingTransport, properties
Constructor and Description |
---|
FIXTransportSender() |
Modifier and Type | Method and Description |
---|---|
java.util.Map |
getOutgoingMessages() |
TransportSender.SendingResult |
send(org.adroitlogic.ultraesb.core.MessageImpl message) |
void |
sendResultBack(Message fixMessage)
Sending acknowledgement/response fix message received from fix-endpoint back to the sender
|
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 |
setReconnectInterval(java.lang.String reconnectInterval) |
void |
setStartTime(java.lang.String startTime) |
void |
start() |
void |
stop() |
getDetails, getOriginatingTransport, pause, resetStatistics, resume, setProperties, toBasicView, toDetailedView, toDetailedViewExt
equals, getDeploymentUnit, getDerivedName, getId, getState, getStreamCount, getTimerStreamMax, getTimerStreamMean, getTimerStreamMin, getTimerStreamPer, hashCode, init, isDebugOn, isStarted, maintenanceShutdown, markAsOutdated, resetCounter, resetTimer, resolveMetricsStreams, setBeanName, setConfig, setDebugOn, setDerivedName, setId, setMetricsEngine, setState, throwIllegalStateException, undeploy
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
retire
public void start()
start
in interface ConfigurationElement
start
in class AbstractTransportSender
public void stop()
stop
in interface ConfigurationElement
stop
in class AbstractTransportSender
public TransportSender.SendingResult send(org.adroitlogic.ultraesb.core.MessageImpl message)
public void sendResultBack(Message fixMessage)
fixMessage
- response message from receiver (eg: execution report)public java.util.Map getOutgoingMessages()
public void setHeartBeatIntervalSec(java.lang.String heartBeatIntervalSec)
public void setStartTime(java.lang.String startTime)
public void setEndTime(java.lang.String endTime)
public void setReconnectInterval(java.lang.String reconnectInterval)
public void setMessageStoreFactory(FIXMessageStoreFactory messageStoreFactory)
public void setLogFactory(FIXLogFactory logFactory)
public void setOtherSettings(java.util.Map otherSettings)