22 #ifndef MAMA_DQPUBLISHERMANAGER_H__ 23 #define MAMA_DQPUBLISHERMANAGER_H__ 26 #include "wombat/wConfig.h" 28 #if defined( __cplusplus ) 116 const char* sourcename,
198 #if defined( __cplusplus ) int8_t mama_bool_t
Definition: types.h:42
void(MAMACALLTYPE * mamaDQPublisherMsgCB)(mamaDQPublisherManager manager, mamaMsg msg)
Definition: dqpublishermanager.h:72
struct mamaDQPublisherImpl_ * mamaDQPublisher
Definition: types.h:104
mamaDQPublisher pub
Definition: dqpublishermanager.h:38
Definition: dqpublishermanager.h:76
struct mamaDQPublisherManagerImpl_ * mamaDQPublisherManager
Definition: types.h:105
mamaDQPublisherCreateCB onCreate
Definition: dqpublishermanager.h:78
const char mamaFtState void * closure
Definition: ft.h:54
void(MAMACALLTYPE * mamaDQPublisherErrorCB)(mamaDQPublisherManager manager, mama_status status, const char *errortxt, mamaMsg msg)
Definition: dqpublishermanager.h:66
mamaDQPublisherErrorCB onError
Definition: dqpublishermanager.h:82
MAMAExpDLL mama_status mamaDQPublisherManager_addPublisher(mamaDQPublisherManager manager, const char *symbol, mamaDQPublisher pub, void *cache)
void(MAMACALLTYPE * mamaDQPublisherNewRequestCB)(mamaDQPublisherManager manager, const char *symbol, short subType, short msgType, mamaMsg msg)
Definition: dqpublishermanager.h:45
Definition: dqpublishermanager.h:35
struct mamaPublishTopic_ mamaPublishTopic
MAMAExpDLL void mamaDQPublisherManager_setSenderId(mamaDQPublisherManager manager, uint64_t senderid)
MAMAExpDLL mama_status mamaDQPublisherManager_destroyPublisher(mamaDQPublisherManager manager, const char *symbol)
MAMAExpDLL void mamaDQPublisherManager_setSeqNum(mamaDQPublisherManager manager, mama_seqnum_t num)
void(MAMACALLTYPE * mamaDQPublisherRefreshCB)(mamaDQPublisherManager manager, mamaPublishTopic *info, short subType, short msgType, mamaMsg msg)
Definition: dqpublishermanager.h:59
const char * symbol
Definition: dqpublishermanager.h:37
struct mamaQueueImpl_ * mamaQueue
Definition: types.h:107
void(MAMACALLTYPE * mamaDQPublisherRequestCB)(mamaDQPublisherManager manager, mamaPublishTopic *info, short subType, short msgType, mamaMsg msg)
Definition: dqpublishermanager.h:52
uint16_t mama_u16_t
Definition: types.h:37
MAMAExpDLL void * mamaDQPublisherManager_getClosure(mamaDQPublisherManager manager)
enum mamaMsgStatus_ mamaMsgStatus
Utility class (enum) for interpreting message status.
uint32_t mama_seqnum_t
Definition: types.h:48
mamaMsg msg
Definition: publisher.h:54
struct mamaDQPublisherManagerCallbacks_ mamaDQPublisherManagerCallbacks
MAMAExpDLL void mamaDQPublisherManager_destroy(mamaDQPublisherManager manager)
mamaDQPublisherMsgCB onMsg
Definition: dqpublishermanager.h:83
MAMAExpDLL mama_status mamaDQPublisherManager_removePublisher(mamaDQPublisherManager manager, const char *symbol, mamaDQPublisher *pub)
MAMAExpDLL mama_status mamaDQPublisherManager_createPublisher(mamaDQPublisherManager manager, const char *symbol, void *cache, mamaDQPublisher *newPublisher)
mamaDQPublisherRefreshCB onRefresh
Definition: dqpublishermanager.h:81
double mama_f64_t
Definition: types.h:44
MAMAExpDLL mama_status mamaDQPublisherManager_allocate(mamaDQPublisherManager *result)
Create a mama publisher for the corresponding transport.
struct mamaMsgImpl_ * mamaMsg
Opaque definitions for all major MAMA data types.
Definition: types.h:95
mamaDQPublisherNewRequestCB onNewRequest
Definition: dqpublishermanager.h:79
mama_status
Definition: status.h:37
MAMAExpDLL mama_status mamaDQPublisherManager_sendNoSubscribers(mamaDQPublisherManager manager, const char *symbol)
MAMAExpDLL void mamaDQPublisherManager_enableSendTime(mamaDQPublisherManager manager, mama_bool_t enable)
mamaMsg mama_status status
Definition: publisher.h:54
mamaDQPublisherRequestCB onRequest
Definition: dqpublishermanager.h:80
typedef void(MAMACALLTYPE *mamaFtMemberOnFtStateChangeCb)(mamaFtMember ftMember
Callback function type for MAMA fault tolerance events.
MAMAExpDLL mama_status mamaDQPublisherManager_create(mamaDQPublisherManager dqPublisher, mamaTransport transport, mamaQueue queue, const mamaDQPublisherManagerCallbacks *callback, const char *sourcename, const char *root, void *closure)
Send a message from the specified publisher.
struct mamaTransportImpl_ * mamaTransport
Definition: types.h:98
void(MAMACALLTYPE * mamaDQPublisherCreateCB)(mamaDQPublisherManager manager)
Definition: dqpublishermanager.h:42
void * cache
Definition: dqpublishermanager.h:39
MAMAExpDLL void mamaDQPublisherManager_setStatus(mamaDQPublisherManager manager, mamaMsgStatus status)
MAMAExpDLL mama_status mamaDQPublisherManager_sendSyncRequest(mamaDQPublisherManager manager, mama_u16_t nummsg, mama_f64_t delay, mama_f64_t duration)