9#ifndef __refinitiv_ema_access_OmmConsumer_h
10#define __refinitiv_ema_access_OmmConsumer_h
130class OmmConsumerConfig;
131class OmmConsumerClient;
132class OmmOAuth2ConsumerClient;
133class OmmConsumerErrorClient;
137class TunnelStreamRequest;
138class ChannelInformation;
139class OmmConsumerImpl;
149 InfiniteWaitEnum = -1,
385 OmmConsumerImpl* _pImpl;
Common.h file provides definitions of common variable types used in EMA.
*|--------------------------------------------------------------------------—
int Int32
represents 32-bit signed integer
long long Int64
represents 64-bit signed integer
unsigned long long UInt64
represents 64-bit unsigned integer
The access namespace contains all interfaces and definitions specified for use with the EMA Access pa...
The ema namespace contains all interfaces and definitions specified for use with EMA.
ChannelInfo provides information on application channel(s).
ChannelStats provides statistical information on application channel(s).
EmaString class is a container of a null terminated Ascii character string.
GenericMsg allows applications to bidirectionally send messages without any implied message semantics...
LoginMsgCredentialRenewal class is used with OmmConsumer::SubmitOAuthCredentialRenewal to supply EMA ...
OAuth2CredentialRenewal class is used with OmmConsumer::SubmitOAuthCredentialRenewal to supply EMA wi...
OmmConsumer class encapsulates functionality of an Omm consuming type application.
void getChannelInformation(ChannelInformation &)
OmmConsumer(const OmmConsumerConfig &config, OmmOAuth2ConsumerClient &oAuthClient, void *closure=0)
OmmConsumer(const OmmConsumerConfig &config, OmmConsumerClient &client, void *closure=0)
const EmaString & getConsumerName() const
Int64 dispatch(Int64 dispatchTimeout=NoWaitEnum)
void modifyIOCtl(Int32 code, Int32 value)
void modifyReactorIOCtl(Int32 code, Int32 value)
OmmConsumer(const OmmConsumerConfig &config, OmmConsumerClient &adminClient, OmmOAuth2ConsumerClient &oAuthClient, OmmConsumerErrorClient &errorClient, void *closure=0)
OmmConsumer(const OmmConsumerConfig &config, OmmConsumerErrorClient &client)
void renewLoginCredentials(LoginMsgCredentialRenewal &)
OmmConsumer(const OmmConsumerConfig &config)
UInt64 registerClient(const ReqMsg &reqMsg, OmmConsumerClient &client, void *closure=0, UInt64 parentHandle=0)
OmmConsumer(const OmmConsumerConfig &config, OmmOAuth2ConsumerClient &oAuthClient, OmmConsumerErrorClient &errorClient, void *closure=0)
void renewOAuth2Credentials(OAuth2CredentialRenewal &)
void reissue(const ReqMsg &reqMsg, UInt64 handle)
void getChannelStatistics(ChannelStatistics &)
void submit(const GenericMsg &genericMsg, UInt64 handle)
OmmConsumer(const OmmConsumerConfig &config, OmmConsumerClient &adminClient, OmmOAuth2ConsumerClient &oAuthClient, void *closure=0)
OmmConsumer(const OmmConsumerConfig &config, OmmConsumerClient &adminClient, OmmConsumerErrorClient &errorClient, void *closure=0)
void submit(const PostMsg &postMsg, UInt64 handle)
void unregister(UInt64 handle)
UInt64 registerClient(const TunnelStreamRequest &tunnelStreamRequest, OmmConsumerClient &client, void *closure=0)
OmmConsumerClient class provides callback interfaces to pass received messages.
OmmConsumerConfig is used to modify configuration and behavior of OmmConsumer.
OmmConsumerErrorclient class provides callback mechanism used in place of exceptions.
OmmOAuth2ConsumerClient class provides callback interfaces for OAuth interactions.
PostMsg allows consumer applications to contribute content.
ReqMsg allows consumer application to express its interest in an item.
TunnelStreamRequest encapsulates tunnel stream request parameters.