Constructor Detail

• MamaDQPublisherManager

  public MamaDQPublisherManager()

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)