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 |
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. |
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