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(com.apama.exceptions.Exception e)
 
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.SessionError > sessionError

sessionKey

com.apama.session.SessionKey sessionKey

symbol

string symbol

userOnDisconnectFailure

action<integer, com.apama.md.client.Error > userOnDisconnectFailure

userOnFailure

action<com.apama.md.client.Error > userOnFailure

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(com.apama.exceptions.Exception e)
Parameters:
e