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

Typedef Documentation

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

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

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.

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

publisher	The publisher from which to send a message.
msg	The 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
	)