OpenMAMA C++ API
Wombat::MamaPublisher Class Reference

The publisher class publishes messages to basic or market data subscriptions depending on the underlying transport. More...

#include <MamaPublisher.h>

Public Member Functions

virtual ~MamaPublisher (void)
 
 MamaPublisher (void)
 
virtual void create (MamaTransport *transport, const char *topic, const char *source=NULL, const char *root=NULL)
 Create a MAMA publisher for the corresponding transport. More...
 
virtual void createWithCallbacks (MamaTransport *transport, MamaQueue *queue, MamaPublisherCallback *cb, void *closure, const char *topic, const char *source=NULL, const char *root=NULL)
 
virtual void send (MamaMsg *msg) const
 
virtual void sendWithThrottle (MamaMsg *msg, MamaSendCompleteCallback *cb, void *closure) const
 
virtual void sendFromInbox (MamaInbox *inbox, MamaMsg *msg) const
 
virtual void sendFromInboxWithThrottle (MamaInbox *inbox, MamaMsg *msg, MamaSendCompleteCallback *cb, void *closure) const
 
virtual void sendReplyToInbox (const MamaMsg &request, MamaMsg *reply) const
 
virtual void sendReplyToInbox (mamaMsgReply replyHandle, MamaMsg *reply) const
 
virtual void destroy (void)
 
virtual void destroyEx (void)
 
virtual MamaTransportgetTransport (void) const
 Return the MamaTransport for the MamaPublisher. More...
 
virtual mamaPublisherState getState () const
 
virtual const char * stringForState (mamaPublisherState state) const
 
virtual const char * getRoot () const
 
virtual const char * getSource () const
 
virtual const char * getSymbol () const
 
virtual MamaPublisherCallbackgetCallback () const
 

Protected Attributes

MamaTransportmTransport
 

Detailed Description

The publisher class publishes messages to basic or market data subscriptions depending on the underlying transport.

For basic transports the source parameter must be NULL.

Constructor & Destructor Documentation

§ ~MamaPublisher()

virtual Wombat::MamaPublisher::~MamaPublisher ( void  )
virtual

§ MamaPublisher()

Wombat::MamaPublisher::MamaPublisher ( void  )

Member Function Documentation

§ create()

virtual void Wombat::MamaPublisher::create ( MamaTransport transport,
const char *  topic,
const char *  source = NULL,
const char *  root = NULL 
)
virtual

Create a MAMA publisher for the corresponding transport.

If the transport is a market data transport, as opposed to a "basic" transport, the topic corresponds to the symbol. For a basic transport, the source and root get ignored.

Parameters
transportThe transport to use. Must be a basic transport.
topicfor basic publishers. Symbol for market data topics.
sourceThe source for market data publishers.
rootThe root for market data publishers. Used internally.

§ createWithCallbacks()

virtual void Wombat::MamaPublisher::createWithCallbacks ( MamaTransport transport,
MamaQueue queue,
MamaPublisherCallback cb,
void *  closure,
const char *  topic,
const char *  source = NULL,
const char *  root = NULL 
)
virtual

§ send()

virtual void Wombat::MamaPublisher::send ( MamaMsg msg) const
virtual

§ sendWithThrottle()

virtual void Wombat::MamaPublisher::sendWithThrottle ( MamaMsg msg,
MamaSendCompleteCallback cb,
void *  closure 
) const
virtual

§ sendFromInbox()

virtual void Wombat::MamaPublisher::sendFromInbox ( MamaInbox inbox,
MamaMsg msg 
) const
virtual

§ sendFromInboxWithThrottle()

virtual void Wombat::MamaPublisher::sendFromInboxWithThrottle ( MamaInbox inbox,
MamaMsg msg,
MamaSendCompleteCallback cb,
void *  closure 
) const
virtual

§ sendReplyToInbox() [1/2]

virtual void Wombat::MamaPublisher::sendReplyToInbox ( const MamaMsg request,
MamaMsg reply 
) const
virtual

§ sendReplyToInbox() [2/2]

virtual void Wombat::MamaPublisher::sendReplyToInbox ( mamaMsgReply  replyHandle,
MamaMsg reply 
) const
virtual

§ destroy()

virtual void Wombat::MamaPublisher::destroy ( void  )
virtual

§ destroyEx()

virtual void Wombat::MamaPublisher::destroyEx ( void  )
virtual

§ getTransport()

virtual MamaTransport* Wombat::MamaPublisher::getTransport ( void  ) const
virtual

Return the MamaTransport for the MamaPublisher.

§ getState()

virtual mamaPublisherState Wombat::MamaPublisher::getState ( ) const
virtual

§ stringForState()

virtual const char* Wombat::MamaPublisher::stringForState ( mamaPublisherState  state) const
virtual

§ getRoot()

virtual const char* Wombat::MamaPublisher::getRoot ( ) const
virtual

§ getSource()

virtual const char* Wombat::MamaPublisher::getSource ( ) const
virtual

§ getSymbol()

virtual const char* Wombat::MamaPublisher::getSymbol ( ) const
virtual

§ getCallback()

virtual MamaPublisherCallback* Wombat::MamaPublisher::getCallback ( ) const
virtual

Member Data Documentation

§ mTransport

MamaTransport* Wombat::MamaPublisher::mTransport
protected