com.apama.md.adapter
Event FTSCSession
The Forward to Spot Converter converts the Forward prices and quantities to Spot prices and quantities and vice versa.
FTSC Session connects to data sources which support the following data streams and will attempt to connect to them in the following order of priority: ? Depth ? Best Bid Ask ? Trade. create() - is used to create a FTSC session.
-
Routes:
-
com.apama.md.BBA -
-
com.apama.md.D -
-
com.apama.md.DD -
-
com.apama.md.ES -
-
com.apama.md.ESD -
-
com.apama.md.O -
-
com.apama.md.OD -
-
com.apama.session.SessionError -
-
com.apama.md.T -
-
com.apama.md.WrappedBBA -
-
com.apama.md.WrappedD -
-
com.apama.md.WrappedES -
-
com.apama.md.WrappedO -
-
com.apama.md.WrappedT -
-
Sends:
-
com.apama.md.BBA -
-
com.apama.md.D -
-
com.apama.md.DD -
-
com.apama.md.ES -
-
com.apama.md.ESD -
-
com.apama.md.O -
-
com.apama.md.OD -
-
com.apama.md.T -
-
com.apama.md.WrappedBBA -
-
com.apama.md.WrappedD -
-
com.apama.md.WrappedES -
-
com.apama.md.WrappedO -
-
com.apama.md.WrappedT -
-
Listens:
-
com.apama.md.BBA -
-
com.apama.md.D -
-
com.apama.md.DD -
-
com.apama.md.ES -
-
com.apama.md.ESD -
-
com.apama.md.T -
-
com.apama.md.WrappedBBA -
-
com.apama.md.WrappedD -
-
com.apama.md.WrappedES -
-
com.apama.md.WrappedT -
Import summary |
TimeFormatPlugin | timeMgr
|
Action summary |
void |
create(context mainCtx, string sessionName, com.apama.session.SessionInfo underlyingSession, com.apama.session.SessionConfigParams underlyingSessionConfig, com.apama.session.CtrlParams underlyingConnectionParams, action<dictionary<string, com.apama.session.SessionInfo>> onFTSCSuccess, action<sequence<string>> onFTSCFailure)
Creates a FTSC Session, including creating the underlying source. |
com.apama.md.adapter.FSConvertorParams |
getFSConvertorParams(com.apama.md.adapter.ConnectionKey connKey)
Returns the ForwardToSpotConvertorParams for the given connection. |
boolean |
resetFSConvertorParams(com.apama.md.adapter.ConnectionKey connKey, com.apama.md.adapter.FSConvertorParams params)
Validates and sets the FTSC parameters for the given connection to the new values. |
void |
startSendingData(com.apama.md.adapter.StartSendingData ssd, string underlyingSymbolName, action<com.apama.md.adapter.ConnectionKey, integer, string> success)
|
timeMgr
TimeFormatPlugin timeMgr
constt
com.apama.md.DatastreamConstants constt
outputStreamType
string outputStreamType
create
void create(context mainCtx, string sessionName, com.apama.session.SessionInfo underlyingSession, com.apama.session.SessionConfigParams underlyingSessionConfig, com.apama.session.CtrlParams underlyingConnectionParams, action<dictionary<string, com.apama.session.SessionInfo>> onFTSCSuccess, action<sequence<string>> onFTSCFailure)
Creates a FTSC Session, including creating the underlying source.
-
Parameters:
-
mainCtx - The correlator's main context.
-
sessionName - Name of the session being created.
-
underlyingSession - SessionInfo of the data source. These need to have been registered with the session manager, but need not be started.
-
underlyingSessionConfig - Configuration parameters from the underlying session for the data source.
-
underlyingConnectionParams - Control parameters from the underlying session for the data source.
-
onFTSCSuccess - Callback used when the session creation is successful.
-
onFTSCFailure - Callback used when an error occurs during the session creation.
getFSConvertorParams
com.apama.md.adapter.FSConvertorParams getFSConvertorParams(com.apama.md.adapter.ConnectionKey connKey)
Returns the ForwardToSpotConvertorParams for the given connection.
-
Parameters:
-
connKey - The connection key for which the FSConvertorParams are required.
-
Returns:
- The FSConvertorParams if found, otherwise a new FSConvertorParams.
resetFSConvertorParams
boolean resetFSConvertorParams(com.apama.md.adapter.ConnectionKey connKey, com.apama.md.adapter.FSConvertorParams params)
Validates and sets the FTSC parameters for the given connection to the new values.
-
Parameters:
-
connKey - Connection key for which the parameters are to be set.
-
params - New FTSC parameters.
-
Returns:
- True for a successful update, false if there was an error, eg: if the validation check fails.
startSendingData
void startSendingData(com.apama.md.adapter.StartSendingData ssd, string underlyingSymbolName, action<com.apama.md.adapter.ConnectionKey, integer, string> success)
-
Parameters:
-
ssd
-
underlyingSymbolName
-
success