Class FixedOrderConnectionRequestRouter

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      com.caplin.ret.trapi.connection.pool.ConnectionPool<com.caplin.ret.trapi.connection.OrderTradingConnection> getConnectionPool()  
      java.util.Map<java.lang.String,​java.util.List<BulkOrder>> groupOrdersByConnection​(java.util.List<BulkOrder> bulkOrders)
      This creates a partition based on the original list.
      void initialise​(OrderConnectionRequestRouter.Context context)
      This notifies the ConnectionRequestRouter that it is about to be loaded.
      void requestConnection​(java.lang.String connectionPoolKey, com.caplin.ret.trapi.connection.pool.ConnectionPoolListener<com.caplin.ret.trapi.connection.OrderTradingConnection> listener)
      This routes a connection request to a connection from the ConnectionPool
      void requestConnection​(java.lang.String retClientName, java.lang.String assetClass, com.caplin.ret.trapi.connection.pool.ConnectionPoolListener<com.caplin.ret.trapi.connection.OrderTradingConnection> listener)
      This routes a connection request to a connection from the ConnectionPool
      • Methods inherited from class java.lang.Object

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

      • FixedOrderConnectionRequestRouter

        public FixedOrderConnectionRequestRouter()
    • Method Detail

      • requestConnection

        public void requestConnection​(java.lang.String retClientName,
                                      java.lang.String assetClass,
                                      com.caplin.ret.trapi.connection.pool.ConnectionPoolListener<com.caplin.ret.trapi.connection.OrderTradingConnection> listener)
        Description copied from interface: OrderConnectionRequestRouter
        This routes a connection request to a connection from the ConnectionPool

        You should use this method to perform any matching based on the request parameters to the most appropriate connection.

        Specified by:
        requestConnection in interface OrderConnectionRequestRouter
      • requestConnection

        public void requestConnection​(java.lang.String connectionPoolKey,
                                      com.caplin.ret.trapi.connection.pool.ConnectionPoolListener<com.caplin.ret.trapi.connection.OrderTradingConnection> listener)
        Description copied from interface: OrderConnectionRequestRouter
        This routes a connection request to a connection from the ConnectionPool

        You should use this method to perform any matching based on the request parameters to the most appropriate connection.

        Specified by:
        requestConnection in interface OrderConnectionRequestRouter
      • groupOrdersByConnection

        public java.util.Map<java.lang.String,​java.util.List<BulkOrder>> groupOrdersByConnection​(java.util.List<BulkOrder> bulkOrders)
        Description copied from interface: OrderConnectionRequestRouter
        This creates a partition based on the original list.

        You should use this method to process the set of related BulkActionOrder, and compute the connections required to successfully dispatch them.

        Specified by:
        groupOrdersByConnection in interface OrderConnectionRequestRouter
      • getConnectionPool

        public com.caplin.ret.trapi.connection.pool.ConnectionPool<com.caplin.ret.trapi.connection.OrderTradingConnection> getConnectionPool()
        Specified by:
        getConnectionPool in interface OrderConnectionRequestRouter