com.apama.md.client
Event ConnectionHelper


Listens:
com.apama.md.adapter.ChannelInfo - 
com.apama.session.SessionError - 

Member summary
 stringdatastreamName
 stringsymbol
 com.apama.session.SessionKeysessionKey
 integerclientId
 com.apama.session.CtrlParamsconnectionParams
 action<integer, integer, string>userOnSetupListeners
 action<integer, com.apama.md.client.DatastreamConnectedInterface>userOnSuccess
 action<com.apama.md.client.Error>userOnFailure
 action<integer, com.apama.md.client.Error>userOnDisconnectFailure
 integerconnectionId
 action<com.apama.session.SessionError>sessionError
 listenerlistenSessionError
 stringchannel
 com.apama.md.DatastreamConstantsconsts
 
Action summary
 voidchannelInfo(integer connectionId, integer clientId)
 voidconnect(string datastreamName, string symbol, com.apama.session.SessionKey sessionKey, integer clientId, com.apama.session.CtrlParams connectionParams, action<com.apama.session.SessionError> sessionError, action<integer, integer, string> userOnSetupListeners, action<integer, com.apama.md.client.DatastreamConnectedInterface> userOnSuccess, action<com.apama.md.client.Error> userOnFailure)
 voidconnectionFailure(com.apama.md.adapter.Error error)
 voidconnectionSuccess(integer connectionId)
 voiddisconnect(action<integer> success, action<integer, com.apama.md.client.Error> failure)
 voiddisconnectionFailure(integer connectionId, com.apama.md.adapter.Error error)
 voidstartData(integer sessionId, integer connectionId, integer clientId, string symbol, string datastreamName, com.apama.session.SessionKey sKey, com.apama.session.CtrlParams connectionParams)
 voidsubscribeToMDChannel()
 voidunsubscribeFromMDChannel()
 
Member detail

channel

string channel

clientId

integer clientId

connectionId

integer connectionId

connectionParams

com.apama.session.CtrlParams connectionParams

consts

com.apama.md.DatastreamConstants consts

datastreamName

string datastreamName

listenSessionError

listener listenSessionError

sessionError

action<com.apama.session.SessionErrorsessionError

sessionKey

com.apama.session.SessionKey sessionKey

symbol

string symbol

userOnDisconnectFailure

action<integer, com.apama.md.client.ErroruserOnDisconnectFailure

userOnFailure

action<com.apama.md.client.ErroruserOnFailure

userOnSetupListeners

action<integer, integer, string> userOnSetupListeners

userOnSuccess

action<integer, com.apama.md.client.DatastreamConnectedInterface> userOnSuccess

Action detail

channelInfo

void channelInfo(integer connectionId, integer clientId)
Parameters:
connectionId
clientId

connect

void connect(string datastreamName, string symbol, com.apama.session.SessionKey sessionKey, integer clientId, com.apama.session.CtrlParams connectionParams, action<com.apama.session.SessionError> sessionError, action<integer, integer, string> userOnSetupListeners, action<integer, com.apama.md.client.DatastreamConnectedInterface> userOnSuccess, action<com.apama.md.client.Error> userOnFailure)
Parameters:
datastreamName
symbol
sessionKey
clientId
connectionParams
sessionError
userOnSetupListeners
userOnSuccess
userOnFailure
Listens:
com.apama.md.adapter.ChannelInfo - 

connectionFailure

void connectionFailure(com.apama.md.adapter.Error error)
Parameters:
error

connectionSuccess

void connectionSuccess(integer connectionId)
Parameters:
connectionId
Listens:
com.apama.session.SessionError - 

disconnect

void disconnect(action<integer> success, action<integer, com.apama.md.client.Error> failure)
Parameters:
success
failure

disconnectionFailure

void disconnectionFailure(integer connectionId, com.apama.md.adapter.Error error)
Parameters:
connectionId
error

startData

void startData(integer sessionId, integer connectionId, integer clientId, string symbol, string datastreamName, com.apama.session.SessionKey sKey, com.apama.session.CtrlParams connectionParams)
Parameters:
sessionId
connectionId
clientId
symbol
datastreamName
sKey
connectionParams

subscribeToMDChannel

void subscribeToMDChannel()

unsubscribeFromMDChannel

void unsubscribeFromMDChannel()