com::wombat::mama::MamaDQPublisherManager

Public Classes

	Name
class	MamaPublishTopic

Public Functions

	Name
void	create(MamaTransport transport, MamaQueue queue, MamaDQPublisherManagerCallback callback, String source)
void	create(MamaTransport transport, MamaQueue queue, MamaDQPublisherManagerCallback callback, String source, String root)
void	destroy()
void	addPublisher(String symbol, MamaDQPublisher publisher, MamaSubscriptionCallback cache)
MamaDQPublisher	removePublisher(String symbol)
void	destroyPublisher(String symbol)
MamaDQPublisher	createPublisher(String symbol, Object cache)
void	setStatus(int status)
void	setSeqNum(long seqNum)
void	setSenderId(long id)
void	sendSyncRequest(int numMsg, double delay, double duration)
void	sendNoSubscribers(String symbol)
Object	getCache(String symbol)
MamaDQPublisher	getPublisher(String symbol)

Detailed Description

class com::wombat::mama::MamaDQPublisherManager;

See: Mama

The [MamaDQPublisherManager](classcom_1_1wombat_1_1mama_1_1MamaDQPublisherManager.html) interface represents a collection of subscriptions. It has the ability to provide all the aspects of a Mama Publisher including initials, recaps, and data quality.

Public Functions Documentation

function create

inline void create(
    MamaTransport transport,
    MamaQueue queue,
    MamaDQPublisherManagerCallback callback,
    String source
)

Parameters:

transport The transport to create the publishermanager on
queue The queue to create the publisher manager on
callback The associated callback to use
source The source namepaceto create the publisher manager with

Create in instance of the MamaDQPublisherManager

function create

inline void create(
    MamaTransport transport,
    MamaQueue queue,
    MamaDQPublisherManagerCallback callback,
    String source,
    String root
)

Parameters:

transport The transport to create the publishermanager on
queue The queue to create the publisher manager on
callback The associated callback to use
source The source name to create the publisher manager with
root The root of the source namespace

Create in instance of the MamaDQPublisherManager

function destroy

inline void destroy()

Destroy the instance of the MamaDQPublisherManager

function addPublisher

inline void addPublisher(
    String symbol,
    MamaDQPublisher publisher,
    MamaSubscriptionCallback cache
)

Parameters:

symbol The symbol associated with the new publisher
publisher The new publisher instance
cache The callback associated with the new publisher

Add a new Publisher to the MamaDQPublisherManager

function removePublisher

inline MamaDQPublisher removePublisher(
    String symbol
)

Parameters:

symbol The symbol for which the associated publisher will be removed

Remove a Publisher from the MamaDQPublisherManager

function destroyPublisher

inline void destroyPublisher(
    String symbol
)

Parameters:

symbol The symbol for which the associated publisher will be destroyed and free’d

Remove a Publisher from the MamaDQPublisherManager

function createPublisher

inline MamaDQPublisher createPublisher(
    String symbol,
    Object cache
)

Parameters:

symbol The symbol for which the new publisher will be created
cache The callback that will be associated with the new publisher

Return: MamaDQPublisher The newly created MamaDQPublisher

Create a new Publisher and associate it with the MamaDQPublisherManager

function setStatus

inline void setStatus(
    int status
)

Parameters:

status The mamaMsgStatus to set for the publisher manager

Set the status for the MamaDQPublisherManager

function setSeqNum

inline void setSeqNum(
    long seqNum
)

Parameters:

seqNum The sequence number to set for the publisher manager

Set the message sequence number for the MamaDQPublisherManager

function setSenderId

inline void setSenderId(
    long id
)

Parameters:

id The publisher sender id to set for the publisher manager

Set the sender ID for the MamaDQPublisherManager

function sendSyncRequest

inline void sendSyncRequest(
    int numMsg,
    double delay,
    double duration
)

Parameters:

numMsg The number of topics to include per sync response message
delay The Interval (in seconds) for the responder to wait before sending the first response
duration The Interval (in seconds) over which to send the responses

Send out a synchronization request from the MamaDQPublisherManager

function sendNoSubscribers

inline void sendNoSubscribers(
    String symbol
)

Parameters:

symbol The symbol to publish a NO_SUBSCRIBERS message against

Publish a NO_SUBSCRIBERS message for the given symbol

function getCache

static inline Object getCache(
    String symbol
)

Parameters:

symbol The symbol for the which you want to get the cache

Return: The cache associated with the symbol/publisher

Accessor for the internal ArrayList that contains all the current publishers

function getPublisher

static inline MamaDQPublisher getPublisher(
    String symbol
)

Parameters:

symbol The symbol for the which you want to get the publisher

Return: The MamaDQPublisher associated with the given symbol

Accessor for the internal ArrayList that contains all the current publishers

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