Interface BrokerCPSelectionCallback


  • public interface BrokerCPSelectionCallback
    This class is implemented by any object which implements a cluster publisher selection callback for cluster operations.
    • Method Detail

      • chooseClusterClient

        int chooseClusterClient​(BrokerClusterPublisher bcp,
                                BrokerEvent event,
                                BrokerInfo[] bi,
                                java.lang.Object client_data)
        Implement this method to select a cluster client to be used for single publish operation. Returning an invalid index value (less than 0 or out of the bi array bounds would cause the BrokerClusterPublisher to resort to the default selection policy.
      • chooseClusterClient

        int chooseClusterClient​(BrokerClusterPublisher bcp,
                                BrokerEvent[] event,
                                BrokerInfo[] bi,
                                java.lang.Object client_data)
        Implement this method to select a cluster client to be used for multi-publish operation. Returning an invalid index value (less than 0 or out of the bi array bounds would cause the BrokerClusterPublisher to resort to the default selection policy.