com.wombat.mama
public class MamaDQPublisherManager extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
MamaDQPublisherManager.MamaPublishTopic |
Constructor and Description |
---|
MamaDQPublisherManager() |
Modifier and Type | Method and Description |
---|---|
void |
addPublisher(java.lang.String symbol,
MamaDQPublisher publisher,
MamaSubscriptionCallback cache) |
void |
create(MamaTransport transport,
MamaQueue queue,
MamaDQPublisherManagerCallback callback,
java.lang.String source) |
void |
create(MamaTransport transport,
MamaQueue queue,
MamaDQPublisherManagerCallback callback,
java.lang.String source,
java.lang.String root) |
MamaDQPublisher |
createPublisher(java.lang.String symbol,
java.lang.Object cache) |
void |
destroy() |
void |
destroyPublisher(java.lang.String symbol) |
MamaDQPublisher |
removePublisher(java.lang.String symbol) |
void |
sendNoSubscribers(java.lang.String symbol) |
void |
sendSyncRequest(int numMsg,
double delay,
double duration) |
void |
setSenderId(long id) |
void |
setSeqNum(long seqNum) |
void |
setStatus(int status) |
public void create(MamaTransport transport, MamaQueue queue, MamaDQPublisherManagerCallback callback, java.lang.String source)
public void create(MamaTransport transport, MamaQueue queue, MamaDQPublisherManagerCallback callback, java.lang.String source, java.lang.String root)
public void destroy()
public void addPublisher(java.lang.String symbol, MamaDQPublisher publisher, MamaSubscriptionCallback cache)
public MamaDQPublisher removePublisher(java.lang.String symbol)
public void destroyPublisher(java.lang.String symbol)
public MamaDQPublisher createPublisher(java.lang.String symbol, java.lang.Object cache)
public void setStatus(int status)
public void setSeqNum(long seqNum)
public void setSenderId(long id)
public void sendSyncRequest(int numMsg, double delay, double duration)
public void sendNoSubscribers(java.lang.String symbol)
Copyright 2011 NYSE Technologies