Package com.wombat.mama
Class MamaDQPublisherManager
- java.lang.Object
-
- com.wombat.mama.MamaDQPublisherManager
-
public class MamaDQPublisherManager extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
MamaDQPublisherManager.MamaPublishTopic
-
Constructor Summary
Constructors Constructor Description MamaDQPublisherManager()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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)
-
-
-
Method Detail
-
create
public void create(MamaTransport transport, MamaQueue queue, MamaDQPublisherManagerCallback callback, java.lang.String source)
-
create
public void create(MamaTransport transport, MamaQueue queue, MamaDQPublisherManagerCallback callback, java.lang.String source, java.lang.String root)
-
destroy
public void destroy()
-
addPublisher
public void addPublisher(java.lang.String symbol, MamaDQPublisher publisher, MamaSubscriptionCallback cache)
-
removePublisher
public MamaDQPublisher removePublisher(java.lang.String symbol)
-
destroyPublisher
public void destroyPublisher(java.lang.String symbol)
-
createPublisher
public MamaDQPublisher createPublisher(java.lang.String symbol, java.lang.Object cache)
-
setStatus
public void setStatus(int status)
-
setSeqNum
public void setSeqNum(long seqNum)
-
setSenderId
public void setSenderId(long id)
-
sendSyncRequest
public void sendSyncRequest(int numMsg, double delay, double duration)
-
sendNoSubscribers
public void sendNoSubscribers(java.lang.String symbol)
-
-