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