Interface Connector

All Superinterfaces:
org.apache.activemq.Service
All Known Implementing Classes:
ManagedTransportConnector, TransportConnector
public interface Connector extends org.apache.activemq.Service
A connector creates and manages client connections that talk to the Broker.

  • Method Details

    • getBrokerInfo

      org.apache.activemq.command.BrokerInfo getBrokerInfo()
      Returns:
      brokerInfo

    • getStatistics

      ConnectorStatistics getStatistics()
      Returns:
      the statistics for this connector

    • resetStatistics

      void resetStatistics()
      Reset Connector statistics

    • 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

      @Deprecated(forRemoval=true) int connectionCount()
      Deprecated, for removal: This API element is subject to removal in a future version.

    • 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

    • getMaxConnectionExceededCount

      long getMaxConnectionExceededCount()

    • isAutoStart

      boolean isAutoStart()

    • isStarted

      boolean isStarted()
      Returns:
      true if connector is started

    • getConnectUri

      URI getConnectUri() throws IOException, URISyntaxException
      Throws:
      IOException
      URISyntaxException

    • getPublishableConnectURI

      URI getPublishableConnectURI() throws Exception
      Throws:
      Exception

    • isEnableStatusMonitor

      boolean isEnableStatusMonitor()

    • getUri

      URI getUri()

    • getDiscoveryUri

      URI getDiscoveryUri()

    • isAuditNetworkProducers

      boolean isAuditNetworkProducers()

    • getMaximumProducersAllowedPerConnection

      int getMaximumProducersAllowedPerConnection()

    • getMaximumConsumersAllowedPerConnection

      int getMaximumConsumersAllowedPerConnection()

    • getConnectionCount

      int getConnectionCount()

    • getName

      String getName()
      Returns:
      connector name