Class MamdaBookPublisher

  • All Implemented Interfaces:
    com.wombat.mama.MamaTimerCallback

    public class MamdaBookPublisher
    extends com.wombat.mama.MamaDQPublisherManagerCallback
    implements com.wombat.mama.MamaTimerCallback
    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void createBook​(java.lang.String symbol, java.lang.String partId)  
      void createMsg()  
      void createPublisherManager​(java.lang.String pubSource, com.wombat.mama.MamaBridge bridge)  
      void createPublisherTransport​(com.wombat.mama.MamaBridge bridge)  
      void createTimer​(java.lang.String symbol, com.wombat.mama.MamaBridge bridge)  
      MamdaOrderBook getBook()  
      com.wombat.mama.MamaMsg getPublishMsg()  
      com.wombat.mama.MamaQueueGroup getQueueGroup()  
      static void main​(java.lang.String[] args)  
      void onCreate​(com.wombat.mama.MamaDQPublisherManager publisher)  
      void onDestroy​(com.wombat.mama.MamaTimer timer)  
      void onError​(com.wombat.mama.MamaDQPublisherManager publisher, short status, java.lang.String errortxt, com.wombat.mama.MamaMsg msg)  
      void onNewRequest​(com.wombat.mama.MamaDQPublisherManager publisherManager, java.lang.String symbol, short subType, short msgType, com.wombat.mama.MamaMsg msg)  
      void onRefresh​(com.wombat.mama.MamaDQPublisherManager publisherManager, com.wombat.mama.MamaDQPublisherManager.MamaPublishTopic mamaPublishTopic, short subType, short msgType, com.wombat.mama.MamaMsg msg)  
      void onRequest​(com.wombat.mama.MamaDQPublisherManager publisherManager, com.wombat.mama.MamaDQPublisherManager.MamaPublishTopic mamaPublishTopic, short subType, short msgType, com.wombat.mama.MamaMsg msg)  
      void onTimer​(com.wombat.mama.MamaTimer timer)  
      void processOrder()  
      boolean publishingSymbol​(java.lang.String symbol)  
      void publishMessage​(com.wombat.mama.MamaMsg request)  
      void setProcessEntries​(boolean process)  
      void setQueueGroup​(com.wombat.mama.MamaQueueGroup queues)  
      • Methods inherited from class com.wombat.mama.MamaDQPublisherManagerCallback

        onError
      • Methods inherited from class java.lang.Object

        equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • MamdaBookPublisher

        public MamdaBookPublisher()
    • Method Detail

      • onTimer

        public void onTimer​(com.wombat.mama.MamaTimer timer)
        Specified by:
        onTimer in interface com.wombat.mama.MamaTimerCallback
      • processOrder

        public void processOrder()
      • getPublishMsg

        public com.wombat.mama.MamaMsg getPublishMsg()
      • publishMessage

        public void publishMessage​(com.wombat.mama.MamaMsg request)
      • createMsg

        public void createMsg()
      • createBook

        public void createBook​(java.lang.String symbol,
                               java.lang.String partId)
      • createPublisherTransport

        public void createPublisherTransport​(com.wombat.mama.MamaBridge bridge)
      • createPublisherManager

        public void createPublisherManager​(java.lang.String pubSource,
                                           com.wombat.mama.MamaBridge bridge)
      • createTimer

        public void createTimer​(java.lang.String symbol,
                                com.wombat.mama.MamaBridge bridge)
      • setProcessEntries

        public void setProcessEntries​(boolean process)
      • setQueueGroup

        public void setQueueGroup​(com.wombat.mama.MamaQueueGroup queues)
      • publishingSymbol

        public boolean publishingSymbol​(java.lang.String symbol)
      • getQueueGroup

        public com.wombat.mama.MamaQueueGroup getQueueGroup()
      • onNewRequest

        public void onNewRequest​(com.wombat.mama.MamaDQPublisherManager publisherManager,
                                 java.lang.String symbol,
                                 short subType,
                                 short msgType,
                                 com.wombat.mama.MamaMsg msg)
        Overrides:
        onNewRequest in class com.wombat.mama.MamaDQPublisherManagerCallback
      • onRequest

        public void onRequest​(com.wombat.mama.MamaDQPublisherManager publisherManager,
                              com.wombat.mama.MamaDQPublisherManager.MamaPublishTopic mamaPublishTopic,
                              short subType,
                              short msgType,
                              com.wombat.mama.MamaMsg msg)
        Overrides:
        onRequest in class com.wombat.mama.MamaDQPublisherManagerCallback
      • onRefresh

        public void onRefresh​(com.wombat.mama.MamaDQPublisherManager publisherManager,
                              com.wombat.mama.MamaDQPublisherManager.MamaPublishTopic mamaPublishTopic,
                              short subType,
                              short msgType,
                              com.wombat.mama.MamaMsg msg)
        Overrides:
        onRefresh in class com.wombat.mama.MamaDQPublisherManagerCallback
      • onError

        public void onError​(com.wombat.mama.MamaDQPublisherManager publisher,
                            short status,
                            java.lang.String errortxt,
                            com.wombat.mama.MamaMsg msg)
      • onCreate

        public void onCreate​(com.wombat.mama.MamaDQPublisherManager publisher)
        Overrides:
        onCreate in class com.wombat.mama.MamaDQPublisherManagerCallback
      • onDestroy

        public void onDestroy​(com.wombat.mama.MamaTimer timer)
        Specified by:
        onDestroy in interface com.wombat.mama.MamaTimerCallback
      • main

        public static void main​(java.lang.String[] args)