Interface Connector

    • Method Detail

      • getBrokerInfo

        BrokerInfo getBrokerInfo()
        Returns:
        brokerInfo
      • getStatistics

        ConnectorStatistics getStatistics()
        Returns:
        the statistics for this connector
      • isUpdateClusterClients

        boolean isUpdateClusterClients()
        Returns:
        true if update client connections when brokers leave/join a cluster
      • isRebalanceClusterClients

        boolean isRebalanceClusterClients()
        Returns:
        true if clients should be re-balanced across the cluster
      • updateClientClusterInfo

        void updateClientClusterInfo()
        Update all the connections with information about the connected brokers in the cluster
      • isUpdateClusterClientsOnRemove

        boolean isUpdateClusterClientsOnRemove()
        Returns:
        true if clients should be updated when a broker is removed from a broker
      • connectionCount

        int connectionCount()
      • isAllowLinkStealing

        boolean isAllowLinkStealing()
        If enabled, older connections with the same clientID are stopped
        Returns:
        true/false if link stealing is enabled
      • getUpdateClusterFilter

        String getUpdateClusterFilter()
        Returns:
        The comma separated string of regex patterns to match broker names for cluster client updates