com::wombat::mama::MamaDQPublisher

More…

Public Functions

Detailed Description

class com::wombat::mama::MamaDQPublisher;

See: Mama

The [MamaDQPublisher](classcom_1_1wombat_1_1mama_1_1MamaDQPublisher.html) interface represents a subscription for a symbol. It can also allow for the broadcast and point-to-point publishing of messages to clients.

Public Functions Documentation

function MamaDQPublisher

inline MamaDQPublisher()

Constructor for MamaDQPublisher

function create

inline void create(
    MamaTransport transport,
    String topic
)

Parameters:

• transport The transport for which to create the new publisher against
• topic The topic associated with the new publisher

Create a new MamaDQPublisher

function send

inline void send(
    MamaMsg msg
)

Parameters:

• msg The MamaMsg that will be sent from this publisher

Send a message (broadcast) from the MamaDQPublisher

function sendReply

inline void sendReply(
    MamaMsg request,
    MamaMsg reply
)

Parameters:

• request The request message (from an inbox)
• reply The reply message containing the relevant data

Send a message (point-to-point) from the MamaDQPublisher

function destroy

inline void destroy()

Destroy the MamaDQPublisher

function setStatus

inline void setStatus(
    int status
)

Parameters:

• status The mamaMsgStatus to set for the publisher

Set the status for the MamaDQPublisher

function setSenderId

inline void setSenderId(
    long id
)

Parameters:

• id The publisher sender id to set for the publisher

Set the sender ID for the MamaDQPublisher

function setSeqNum

inline void setSeqNum(
    long num
)

Parameters:

• num The sequence number to set for the publisher

Set the message sequence number for the MamaDQPublisher

function setCache

inline void setCache(
    Object cache
)

Parameters:

• cache The cache to save against the publisher

Set a cache for the MamaDQPublisher

function getCache

inline Object getCache()

Return: Object The cache for the publisher

Return the cache for the MamaDQPublisher

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