Go to the documentation of this file.
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 )
MAMAExpDLL mama_status mamaDQPublisherManager_removePublisher(mamaDQPublisherManager manager, const char *symbol, mamaDQPublisher *pub)
Definition: dqpublishermanager.h:35
mamaDQPublisherRefreshCB onRefresh
Definition: dqpublishermanager.h:81
void(MAMACALLTYPE * mamaDQPublisherRequestCB)(mamaDQPublisherManager manager, mamaPublishTopic *info, short subType, short msgType, mamaMsg msg)
Definition: dqpublishermanager.h:52
MAMAExpDLL mama_status mamaDQPublisherManager_createPublisher(mamaDQPublisherManager manager, const char *symbol, void *cache, mamaDQPublisher *newPublisher)
MAMAExpDLL void * mamaDQPublisherManager_getClosure(mamaDQPublisherManager manager)
mama_status
Definition: status.h:37
MAMAExpDLL void mamaDQPublisherManager_destroy(mamaDQPublisherManager manager)
struct mamaDQPublisherManagerImpl_ * mamaDQPublisherManager
Definition: types.h:105
const char * symbol
Definition: dqpublishermanager.h:37
Definition: dqpublishermanager.h:76
uint16_t mama_u16_t
Definition: types.h:37
MAMAExpDLL void mamaDQPublisherManager_enableSendTime(mamaDQPublisherManager manager, mama_bool_t enable)
MAMAExpDLL mama_status mamaDQPublisherManager_allocate(mamaDQPublisherManager *result)
Create a mama publisher for the corresponding transport.
void(MAMACALLTYPE * mamaDQPublisherMsgCB)(mamaDQPublisherManager manager, mamaMsg msg)
Definition: dqpublishermanager.h:72
void(MAMACALLTYPE * mamaDQPublisherCreateCB)(mamaDQPublisherManager manager)
Definition: dqpublishermanager.h:42
mamaDQPublisherNewRequestCB onNewRequest
Definition: dqpublishermanager.h:79
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.
MAMAExpDLL mama_status mamaDQPublisherManager_sendNoSubscribers(mamaDQPublisherManager manager, const char *symbol)
struct mamaDQPublisherImpl_ * mamaDQPublisher
Definition: types.h:104
void(MAMACALLTYPE * mamaDQPublisherErrorCB)(mamaDQPublisherManager manager, mama_status status, const char *errortxt, mamaMsg msg)
Definition: dqpublishermanager.h:66
MAMAExpDLL void mamaDQPublisherManager_setStatus(mamaDQPublisherManager manager, mamaMsgStatus status)
struct mamaDQPublisherManagerCallbacks_ mamaDQPublisherManagerCallbacks
mamaDQPublisherRequestCB onRequest
Definition: dqpublishermanager.h:80
struct mamaTransportImpl_ * mamaTransport
Definition: types.h:98
mamaDQPublisherErrorCB onError
Definition: dqpublishermanager.h:82
MAMAExpDLL mama_status mamaDQPublisherManager_addPublisher(mamaDQPublisherManager manager, const char *symbol, mamaDQPublisher pub, void *cache)
MAMAExpDLL mama_status mamaDQPublisherManager_sendSyncRequest(mamaDQPublisherManager manager, mama_u16_t nummsg, mama_f64_t delay, mama_f64_t duration)
void(MAMACALLTYPE * mamaDQPublisherNewRequestCB)(mamaDQPublisherManager manager, const char *symbol, short subType, short msgType, mamaMsg msg)
Definition: dqpublishermanager.h:45
double mama_f64_t
Definition: types.h:44
struct mamaMsgImpl_ * mamaMsg
Opaque definitions for all major MAMA data types.
Definition: types.h:95
mamaDQPublisher pub
Definition: dqpublishermanager.h:38
uint32_t mama_seqnum_t
Definition: types.h:48
struct mamaPublishTopic_ mamaPublishTopic
MAMAExpDLL void mamaDQPublisherManager_setSenderId(mamaDQPublisherManager manager, uint64_t senderid)
int8_t mama_bool_t
Definition: types.h:42
void * cache
Definition: dqpublishermanager.h:39
mamaDQPublisherCreateCB onCreate
Definition: dqpublishermanager.h:78
void(MAMACALLTYPE * mamaDQPublisherRefreshCB)(mamaDQPublisherManager manager, mamaPublishTopic *info, short subType, short msgType, mamaMsg msg)
Definition: dqpublishermanager.h:59
MAMAExpDLL void mamaDQPublisherManager_setSeqNum(mamaDQPublisherManager manager, mama_seqnum_t num)
MAMAExpDLL mama_status mamaDQPublisherManager_destroyPublisher(mamaDQPublisherManager manager, const char *symbol)
struct mamaQueueImpl_ * mamaQueue
Definition: types.h:107
enum mamaMsgStatus_ mamaMsgStatus
Utility class (enum) for interpreting message status.
mamaDQPublisherMsgCB onMsg
Definition: dqpublishermanager.h:83