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