OpenMAMA
 All Data Structures Files Functions Variables Typedefs Enumerations Enumerator Macros Pages
dqpublishermanager.h File Reference
#include "mama/types.h"
#include "wombat/wConfig.h"

Go to the source code of this file.

Data Structures

struct  mamaPublishTopic_
 
struct  mamaDQPublisherManagerCallbacks_
 

Typedefs

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
 

Functions

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 voidmamaDQPublisherManager_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)
 

Typedef Documentation

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)

Function Documentation

MAMAExpDLL mama_status mamaDQPublisherManager_allocate ( mamaDQPublisherManager result)

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
resultA pointer to hold the resulting mamaPublisher.
tportThe transport.
symbolSymbol on which to publish.
sourceThe source for market data publishers. (e.g. source.symbol)
rootThe root for market data publishers. Used internally.
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.

Parameters
publisherThe publisher from which to send a message.
msgThe mamaMsg to send.
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 
)


© 2012 Linux Foundation