Interface BridgeControl

    • Method Detail

      • getName

        String getName()
        Returns the name of this bridge
      • getQueueName

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

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

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

        String getTransformerClassName()
        Return 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.
        Throws:
        Exception
      • getTransformerProperties

        Map<String,​String> getTransformerProperties()
                                                   throws Exception
        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
        Throws:
        Exception
      • getDiscoveryGroupName

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

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

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

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

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

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

        boolean isHA()
        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.