22 #ifndef MAMA_SUBSCRIPTION_CPP_H__ 23 #define MAMA_SUBSCRIPTION_CPP_H__ 26 #include "mama/subscription.h" 30 class MamaSubscriptionCallback;
32 class MamaSourceDerivative;
34 struct MamaSubscriptionImpl;
53 virtual void setCSubscription (mamaSubscription subscription);
54 virtual mamaSubscription getCSubscription ();
71 void* closure = NULL);
87 void* closure = NULL);
120 virtual void activate ();
126 virtual void deactivate ();
145 void* closure = NULL);
162 void* closure = NULL);
182 void* closure = NULL);
191 virtual void setRequiresInitial (
bool requiresInitial);
196 virtual bool getRequiresInitial (
void);
201 virtual bool getReceivedInitial (
void);
211 virtual void setRetries (
int retries);
216 virtual int getRetries (
void);
223 virtual void setSubscriptionType (mamaSubscriptionType type);
228 virtual mamaSubscriptionType getSubscriptionType (
void);
233 virtual long getServiceLevelOpt (
void);
242 virtual void setServiceLevel (mamaServiceLevel svcLevel,
248 virtual mamaServiceLevel getServiceLevel (
void);
255 virtual const char* getSymbol (
void)
const;
263 virtual void setSymbol (
const char* symbol);
286 virtual const MamaSource* getSource (
void)
const;
293 virtual const char* getSubscSource (
void)
const;
301 virtual void setTimeout (
double timeout);
306 virtual double getTimeout (
void);
314 virtual void setRecoverGaps (
bool recover);
322 virtual bool getRecoverGaps (
void)
const;
329 virtual void setAppDataType (uint8_t dataType);
336 virtual uint8_t getAppDataType ()
const;
343 virtual void setGroupSizeHint (
int groupSizeHint);
357 virtual void setItemClosure (
void* closure);
366 virtual void* getItemClosure (
void);
379 virtual void setPreInitialCacheSize (
int cacheSize);
386 virtual int getPreInitialCacheSize (
void);
406 virtual void setMsgQualifierFilter (
bool ignoreDefinitelyDuplicate,
407 bool ignorePossiblyDuplicate,
408 bool ignoreDefinitelyDelyaed,
409 bool ignorePossiblyDelayed,
410 bool ignoreOutOfSequence);
431 virtual void getMsgQualifierFilter (
bool &ignoreDefinitelyDuplicate,
432 bool &ignorePossiblyDuplicate,
433 bool &ignoreDefinitelyDelyaed,
434 bool &ignorePossiblyDelayed,
435 bool &ignoreOutOfSequence)
const;
443 virtual void destroy ();
454 virtual void destroyEx();
459 static void MAMACALLTYPE onSubscriptionCreate (mamaSubscription subscription,
462 static void MAMACALLTYPE onSubscriptionDestroy (mamaSubscription subscription,
465 static void MAMACALLTYPE onSubscriptionError (mamaSubscription subscription,
471 static void MAMACALLTYPE onSubscriptionGap (mamaSubscription subscription,
474 static void MAMACALLTYPE onSubscriptionMessage (mamaSubscription subscription,
479 static void MAMACALLTYPE onSubscriptionQuality (mamaSubscription subscription,
483 const void *platformInfo,
486 static void MAMACALLTYPE onSubscriptionRecapRequest (mamaSubscription subscription,
494 MamaSubscriptionImpl *mImpl;
498 #endif // MAMA_SUBSCRIPTION_CPP_H__ A MAMA source maintains information about a data source, including the quality of the data coming fro...
Definition: MamaSource.h:55
The MamaBasicSubscription interface represents a subscription to a topic with no market data semantic...
Definition: MamaBasicSubscription.h:44
A MamaSourceDerivative provides a reference to a common MamaSource object but can have attributes (su...
Definition: MamaSourceDerivative.h:38
Definition: MamaBasicSubscription.h:27
The message callback interface.
Definition: MamaSubscriptionCallback.h:39
Queue allows applications to dispatch events in order with multiple threads using a single MamaDispat...
Definition: MamaQueue.h:40
The MamaTransport class provides market data functionality.
Definition: MamaTransport.h:239
The MamaSubscription interface represents a subscription to a topic.
Definition: MamaSubscription.h:43