com.apama.md.adapter
Event GenericSourceFactory


Starting point for creating the generic data source framework Note that all control operations (i.e. session start/stop/reconfigure, connect & disconnect) need to send appropriate success/failed events to the main context.
Since:
CMF 2.1.0

Action summary
 voidcreateSource(string sourceName, context mainCtx, dictionary<integer, com.apama.md.adapter.UnderlyingSession> underlyingSessions, dictionary<string, com.apama.md.adapter.OutputSession> outputSessions, action<com.apama.session.SessionStart, action<integer>, action<integer, string>> startSession, action<com.apama.session.SessionStop, action<integer>, action<integer, string>> stopSession, action<com.apama.session.SessionReconfigure, action<integer>, action<integer, string>> reconfigureSession, action<com.apama.md.adapter.ConnectDatastream, string, action<com.apama.md.adapter.ConnectionKey, integer, string>, action<com.apama.md.adapter.ConnectionKey, integer, string>> connect, action<com.apama.md.adapter.StartSendingData, string, action<com.apama.md.adapter.ConnectionKey, integer, string>> startSendingData, action<com.apama.md.adapter.DisconnectDatastream, string, action<com.apama.md.adapter.ConnectionKey, integer>, action<com.apama.md.adapter.ConnectionKey, integer, string>> disconnect, integer numOfUnderlyingFailuresAllowed, action<com.apama.md.adapter.GenericSourceInterface> sourceCreateSuccess, action<sequence<string>> sourceCreateFailure)

Used to create the generic source without setting up handlers for session controls.
 
Action detail

createSource

void createSource(string sourceName, context mainCtx, dictionary<integer, com.apama.md.adapter.UnderlyingSession> underlyingSessions, dictionary<string, com.apama.md.adapter.OutputSession> outputSessions, action<com.apama.session.SessionStart, action<integer>, action<integer, string>> startSession, action<com.apama.session.SessionStop, action<integer>, action<integer, string>> stopSession, action<com.apama.session.SessionReconfigure, action<integer>, action<integer, string>> reconfigureSession, action<com.apama.md.adapter.ConnectDatastream, string, action<com.apama.md.adapter.ConnectionKey, integer, string>, action<com.apama.md.adapter.ConnectionKey, integer, string>> connect, action<com.apama.md.adapter.StartSendingData, string, action<com.apama.md.adapter.ConnectionKey, integer, string>> startSendingData, action<com.apama.md.adapter.DisconnectDatastream, string, action<com.apama.md.adapter.ConnectionKey, integer>, action<com.apama.md.adapter.ConnectionKey, integer, string>> disconnect, integer numOfUnderlyingFailuresAllowed, action<com.apama.md.adapter.GenericSourceInterface> sourceCreateSuccess, action<sequence<string>> sourceCreateFailure)
Used to create the generic source without setting up handlers for session controls.
Parameters:
sourceName - A unique name identifying the source
mainCtx - The main context
underlyingSessions
outputSessions
startSession
stopSession
reconfigureSession
connect - Callback used for responding to connection requests
startSendingData
disconnect - Callback used for responding to disconnection requests
numOfUnderlyingFailuresAllowed
sourceCreateSuccess
sourceCreateFailure