Class MamaDQPublisherManager


  • public class MamaDQPublisherManager
    extends java.lang.Object
    • Constructor Detail

      • MamaDQPublisherManager

        public MamaDQPublisherManager()
    • Method Detail

      • destroy

        public void destroy()
      • 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)