#include "mama/types.h"
#include "wombat/wConfig.h"
Go to the source code of this file.
|
typedef struct mamaPublishTopic_ | mamaPublishTopic |
|
typedef void(MAMACALLTYPE * | mamaDQPublisherCreateCB) (mamaDQPublisherManager manager) |
|
typedef void(MAMACALLTYPE * | mamaDQPublisherNewRequestCB) (mamaDQPublisherManager manager, const char *symbol, short subType, short msgType, mamaMsg msg) |
|
typedef void(MAMACALLTYPE * | mamaDQPublisherRequestCB) (mamaDQPublisherManager manager, mamaPublishTopic *info, short subType, short msgType, mamaMsg msg) |
|
typedef void(MAMACALLTYPE * | mamaDQPublisherRefreshCB) (mamaDQPublisherManager manager, mamaPublishTopic *info, short subType, short msgType, mamaMsg msg) |
|
typedef void(MAMACALLTYPE * | mamaDQPublisherErrorCB) (mamaDQPublisherManager manager, mama_status status, const char *errortxt, mamaMsg msg) |
|
typedef void(MAMACALLTYPE * | mamaDQPublisherMsgCB) (mamaDQPublisherManager manager, mamaMsg msg) |
|
typedef struct mamaDQPublisherManagerCallbacks_ | mamaDQPublisherManagerCallbacks |
|
|
MAMAExpDLL mama_status | mamaDQPublisherManager_allocate (mamaDQPublisherManager *result) |
| Create a mama publisher for the corresponding transport. More...
|
|
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. More...
|
|
MAMAExpDLL void | mamaDQPublisherManager_destroy (mamaDQPublisherManager manager) |
|
MAMAExpDLL mama_status | mamaDQPublisherManager_addPublisher (mamaDQPublisherManager manager, const char *symbol, mamaDQPublisher pub, void *cache) |
|
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) |
|
MAMAExpDLL mama_status | mamaDQPublisherManager_destroyPublisher (mamaDQPublisherManager manager, const char *symbol) |
|
MAMAExpDLL void | mamaDQPublisherManager_setStatus (mamaDQPublisherManager manager, mamaMsgStatus status) |
|
MAMAExpDLL void * | mamaDQPublisherManager_getClosure (mamaDQPublisherManager manager) |
|
MAMAExpDLL void | mamaDQPublisherManager_setSenderId (mamaDQPublisherManager manager, uint64_t senderid) |
|
MAMAExpDLL void | mamaDQPublisherManager_setSeqNum (mamaDQPublisherManager manager, mama_seqnum_t num) |
|
MAMAExpDLL mama_status | mamaDQPublisherManager_sendSyncRequest (mamaDQPublisherManager manager, mama_u16_t nummsg, mama_f64_t delay, mama_f64_t duration) |
|
MAMAExpDLL mama_status | mamaDQPublisherManager_sendNoSubscribers (mamaDQPublisherManager manager, const char *symbol) |
|
MAMAExpDLL void | mamaDQPublisherManager_enableSendTime (mamaDQPublisherManager manager, mama_bool_t enable) |
|
Create a mama publisher for the corresponding transport.
If the transport is a marketdata transport, as opposed to a "basic" transport, the topic corresponds to the symbol. For a basic transport, the source and root get ignored.
- Parameters
-
result | A pointer to hold the resulting mamaPublisher. |
tport | The transport. |
symbol | Symbol on which to publish. |
source | The source for market data publishers. (e.g. source.symbol) |
root | The root for market data publishers. Used internally. |
Send a message from the specified publisher.
- Parameters
-
publisher | The publisher from which to send a message. |
msg | The mamaMsg to send. |