Wombat::MamaDQPublisherManager

Public Functions

	Name
virtual	~MamaDQPublisherManager(void )
	MamaDQPublisherManager(void )
virtual void	create(MamaTransport * transport, MamaQueue * queue, MamaDQPublisherManagerCallback * callback, const char * sourcename, const char * root =”_MD”)
virtual void	addPublisher(const char * symbol, MamaDQPublisher * pub, void * cache)
virtual MamaDQPublisher *	removePublisher(const char * symbol)
virtual MamaDQPublisher *	createPublisher(const char * symbol, void * cache)
virtual void	destroyPublisher(const char * symbol)
virtual const MamaDQPublisher *	getPublisher(const char * symbol) const
virtual void	destroy(void )
virtual void	setStatus(mamaMsgStatus status)
virtual void	setSenderId(uint64_t id)
virtual void	setSeqNum(mama_seqnum_t num)
virtual void	sendSyncRequest(mama_u16_t nummsg, mama_f64_t delay, mama_f64_t duration)
virtual void	sendNoSubscribers(const char * symbol)

Public Functions Documentation

function ~MamaDQPublisherManager

virtual ~MamaDQPublisherManager(
    void 
)

function MamaDQPublisherManager

MamaDQPublisherManager(
    void 
)

function create

virtual void create(
    MamaTransport * transport,
    MamaQueue * queue,
    MamaDQPublisherManagerCallback * callback,
    const char * sourcename,
    const char * root ="_MD"
)

Parameters:

transport The transport to use. Must be a basic transport.
queue the quese subscription requests are received on.
callback subscription request callback.
sourcename The Sourcename for subscribers to send requests
root The root for market data publishers.

Create a MAMA publisher manager for the corresponding transport.

function addPublisher

virtual void addPublisher(
    const char * symbol,
    MamaDQPublisher * pub,
    void * cache
)

function removePublisher

virtual MamaDQPublisher * removePublisher(
    const char * symbol
)

function createPublisher

virtual MamaDQPublisher * createPublisher(
    const char * symbol,
    void * cache
)

function destroyPublisher

virtual void destroyPublisher(
    const char * symbol
)

function getPublisher

virtual const MamaDQPublisher * getPublisher(
    const char * symbol
) const

function destroy

virtual void destroy(
    void 
)

function setStatus

virtual void setStatus(
    mamaMsgStatus status
)

function setSenderId

virtual void setSenderId(
    uint64_t id
)

function setSeqNum

virtual void setSeqNum(
    mama_seqnum_t num
)

function sendSyncRequest

virtual void sendSyncRequest(
    mama_u16_t nummsg,
    mama_f64_t delay,
    mama_f64_t duration
)

function sendNoSubscribers

virtual void sendNoSubscribers(
    const char * symbol
)

Updated on 2023-03-31 at 15:29:25 +0100