Interface BridgeControl

All Superinterfaces:
ActiveMQComponentControl
public interface BridgeControl extends ActiveMQComponentControl
A BridgeControl is used to manage a Bridge.

  • Method Details

    • getName

      String getName()
      Returns the name of this bridge.
      Returns:
      the name of this bridge

    • getQueueName

      String getQueueName()
      Returns the name of the queue this bridge is consuming messages from.
      Returns:
      the name of the queue this bridge is consuming messages from

    • getForwardingAddress

      String getForwardingAddress()
      Returns the address this bridge will forward messages to.
      Returns:
      the address this bridge will forward messages to

    • getFilterString

      String getFilterString()
      Returns the filter string associated with this bridge.
      Returns:
      the filter string associated with this bridge

    • getTransformerClassName

      String getTransformerClassName()
      Returns the name of the org.apache.activemq.artemis.core.server.cluster.Transformer implementation associated with this bridge.
      Returns:
      the name of the org.apache.activemq.artemis.core.server.cluster.Transformer implementation associated with this bridge

    • getTransformerPropertiesAsJSON

      String getTransformerPropertiesAsJSON() throws Exception
      Returns a map of the properties configured for the transformer.
      Returns:
      a map of the properties configured for the transformer
      Throws:
      Exception

    • getTransformerProperties

      Map<String,String> getTransformerProperties() throws Exception
      Returns a map of the properties configured for the transformer.
      Returns:
      a map of the properties configured for the transformer
      Throws:
      Exception

    • getStaticConnectors

      String[] getStaticConnectors() throws Exception
      Returns any list of static connectors used by this bridge.
      Returns:
      any list of static connectors used by this bridge
      Throws:
      Exception

    • getDiscoveryGroupName

      String getDiscoveryGroupName()
      Returns the name of the discovery group used by this bridge.
      Returns:
      the name of the discovery group used by this bridge

    • getRetryInterval

      long getRetryInterval()
      Returns the retry interval used by this bridge.
      Returns:
      the retry interval used by this bridge

    • getRetryIntervalMultiplier

      double getRetryIntervalMultiplier()
      Returns the retry interval multiplier used by this bridge.
      Returns:
      the retry interval multiplier used by this bridge

    • getMaxRetryInterval

      long getMaxRetryInterval()
      Returns the max retry interval used by this bridge.
      Returns:
      the max retry interval used by this bridge

    • getReconnectAttempts

      int getReconnectAttempts()
      Returns the number of reconnection attempts used by this bridge.
      Returns:
      the number of reconnection attempts used by this bridge

    • isUseDuplicateDetection

      boolean isUseDuplicateDetection()
      Returns whether this bridge is using duplicate detection.
      Returns:
      whether this bridge is using duplicate detection

    • isHA

      boolean isHA()
      Returns whether this bridge is using high availability.
      Returns:
      whether this bridge is using high availability

    • getMessagesPendingAcknowledgement

      long getMessagesPendingAcknowledgement()
      The messagesPendingAcknowledgement counter is incremented when the bridge is has forwarded a message but is waiting acknowledgement from the other broker. This is a cumulative total and the number of outstanding pending messages can be computed by subtracting messagesAcknowledged from messagesPendingAcknowledgement.

    • getMessagesAcknowledged

      long getMessagesAcknowledged()
      The messagesAcknowledged counter is the number of messages actually received by the remote broker. This is a cumulative total and the number of outstanding pending messages can be computed by subtracting messagesAcknowledged from messagesPendingAcknowledgement.

    • getMetrics

      Map<String,Object> getMetrics()
      The bridge metrics for this bridge

      The messagesPendingAcknowledgement counter is incremented when the bridge is has forwarded a message but is waiting acknowledgement from the other broker. The messagesAcknowledged counter is the number of messages actually received by the remote broker.

    • isConnected

      boolean isConnected()
      Returns whether the bridge is actively connected to the remote broker.
      Returns:
      whether the bridge is actively connected to the remote broker