Package com.wombat.mamda.examples

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)