Interface BrokerProxy


  • public interface BrokerProxy
    BrokerProxy is responsible for handling in- and outgoing communication with brokers
    Author:
    David Dauer
    • Method Detail

      • sendMessage

        void sendMessage​(Broker broker,
                         Object messageObject)
        Send a message to a specific broker
      • sendMessages

        void sendMessages​(Broker broker,
                          List<?> messageObjects)
        Sends a list of messages to a specific broker
      • broadcastMessage

        void broadcastMessage​(Object messageObject)
        Send a message to all brokers
      • broadcastMessages

        void broadcastMessages​(List<?> messageObjects)
        Sends a list of messages to all brokers
      • routeMessage

        void routeMessage​(Object message)
        Routes a message to server components. Used to route both incoming messages and messages generated by internal "broker-like" entities, such as gencos and the default broker. Messages from non-enabled brokers will be silently dropped into the bit-bucket.
      • registerBrokerMessageListener

        void registerBrokerMessageListener​(Object listener,
                                           Class<?> msgType)
        Sets up a dispatch listener for market messages
      • setDeferredBroadcast

        void setDeferredBroadcast​(boolean b)
        Holds up message transmission when true
      • broadcastDeferredMessages

        void broadcastDeferredMessages()
        Sends deferred messages