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()