Class AMQPBridgeManagementSupport

java.lang.Object
org.apache.activemq.artemis.protocol.amqp.connect.bridge.AMQPBridgeManagementSupport
public final class AMQPBridgeManagementSupport extends Object
Support methods for working with the AMQP bridge management types

  • Field Details

    • BRIDGE_MANAGER_RESOURCE_TEMPLATE

      public static final String BRIDGE_MANAGER_RESOURCE_TEMPLATE
      Template used to denote bridge manager instances in the server management registry.
      See Also:

    • BRIDGE_POLICY_RESOURCE_TEMPLATE

      public static final String BRIDGE_POLICY_RESOURCE_TEMPLATE
      Template used to denote bridge policy managers created on the source in the server management registry.
      See Also:

    • BRIDGE_RECEIVER_RESOURCE_TEMPLATE

      public static final String BRIDGE_RECEIVER_RESOURCE_TEMPLATE
      Template used to denote bridge receivers on the source in the server management registry. Since policy names are unique on the local broker AMQP bridge configuration these names should not collide as each policy will create only one receiver for a given address or queue.
      See Also:

    • BRIDGE_SENDER_RESOURCE_TEMPLATE

      public static final String BRIDGE_SENDER_RESOURCE_TEMPLATE
      Template used to denote bridge senders on the source in the server management registry. Since policy names are unique on the local broker AMQP bridge configuration these names should not collide as each policy will create only one sender for a given address or queue.
      See Also:

    • BRIDGE_NAME_TEMPLATE

      public static final String BRIDGE_NAME_TEMPLATE
      The template used to create the object name suffix that is appending to the broker connection object name when adding and removing AMQP bridge related control elements.
      See Also:

    • BRIDGE_POLICY_NAME_TEMPLATE

      public static final String BRIDGE_POLICY_NAME_TEMPLATE
      The template used to create the object name suffix that is appending to the broker connection object name when adding and removing AMQP bridge policy control elements.
      See Also:

    • BRIDGE_QUEUE_RECEIVER_NAME_TEMPLATE

      public static final String BRIDGE_QUEUE_RECEIVER_NAME_TEMPLATE
      The template used to create the object name suffix that is appending to the broker connection object name when adding and removing AMQP bridge queue receiver control elements.
      See Also:

    • BRIDGE_ADDRESS_RECEIVER_NAME_TEMPLATE

      public static final String BRIDGE_ADDRESS_RECEIVER_NAME_TEMPLATE
      The template used to create the object name suffix that is appending to the broker connection object name when adding and removing AMQP bridge address receiver control elements.
      See Also:

    • BRIDGE_QUEUE_SENDER_NAME_TEMPLATE

      public static final String BRIDGE_QUEUE_SENDER_NAME_TEMPLATE
      The template used to create the object name suffix that is appending to the broker connection object name when adding and removing AMQP bridge queue sender control elements.
      See Also:

    • BRIDGE_ADDRESS_SENDER_NAME_TEMPLATE

      public static final String BRIDGE_ADDRESS_SENDER_NAME_TEMPLATE
      The template used to create the object name suffix that is appending to the broker connection object name when adding and removing AMQP bridge address sender control elements.
      See Also:

  • Method Details

    • registerBridgeManager

      public static void registerBridgeManager(AMQPBridgeManager bridge) throws Exception
      Register the given AMQPBridgeManager instance with the broker management services.
      Parameters:
      bridge - The bridge manager instance being registered with management.
      Throws:
      Exception - if an error occurs while registering the bridge with the management services.

    • unregisterBridgeManager

      public static void unregisterBridgeManager(AMQPBridgeManager bridge) throws Exception
      Unregister the given AMQPBridgeManager instance with the broker management services.
      Parameters:
      bridge - The bridge manager instance being unregistered from management.
      Throws:
      Exception - if an error occurs while unregistering the bridge with the management services.

    • getBridgeManagerResourceName

      public static String getBridgeManagerResourceName(String brokerConnectionName, String bridgeName)

    • getBridgeManagerObjectName

      public static ObjectName getBridgeManagerObjectName(org.apache.activemq.artemis.core.server.management.ManagementService management, String brokerConnection, String bridgeName) throws Exception
      Throws:
      Exception

    • registerBridgePolicyManager

      public static void registerBridgePolicyManager(AMQPBridgePolicyManager manager) throws Exception
      Register an AMQP bridge policy manager with the server management services.
      Parameters:
      manager - The AMQP bridge policy manager instance that is being managed.
      Throws:
      Exception - if an error occurs while registering the manager with the management services.

    • unregisterBridgePolicyManager

      public static void unregisterBridgePolicyManager(AMQPBridgePolicyManager manager) throws Exception
      Unregister an AMQP bridge policy manager with the server management services.
      Parameters:
      manager - The AMQP bridge policy manager instance that is being managed.
      Throws:
      Exception - if an error occurs while unregistering the manager with the management services.

    • getBridgePolicyManagerResourceName

      public static String getBridgePolicyManagerResourceName(String brokerConnectionName, String bridgeName, String policyName)

    • getBridgePolicyManagerObjectName

      public static ObjectName getBridgePolicyManagerObjectName(org.apache.activemq.artemis.core.server.management.ManagementService management, String brokerConnection, String bridgeName, String policyType, String policyName) throws Exception
      Throws:
      Exception

    • registerBridgeReceiver

      public static void registerBridgeReceiver(AMQPBridgeReceiver receiver) throws Exception
      Registers the bridge receiver with the server management services on the source.
      Parameters:
      receiver - The AMQP bridge receiver instance that is being managed.
      Throws:
      Exception - if an error occurs while registering the receiver with the management services.

    • unregisterBridgeReceiver

      public static void unregisterBridgeReceiver(AMQPBridgeReceiver receiver) throws Exception
      Unregisters the bridge receiver with the server management services on the source.
      Parameters:
      receiver - The AMQP bridge receiver instance that is being managed.
      Throws:
      Exception - if an error occurs while registering the receiver with the management services.

    • getBridgeAddressReceiverResourceName

      public static String getBridgeAddressReceiverResourceName(String brokerConnectionName, String bridgeName, String policyName, String address)

    • getBridgeAddressReceiverObjectName

      public static ObjectName getBridgeAddressReceiverObjectName(org.apache.activemq.artemis.core.server.management.ManagementService management, String brokerConnection, String bridgeName, String policyType, String policyName, String address) throws Exception
      Throws:
      Exception

    • getBridgeQueueReceiverResourceName

      public static String getBridgeQueueReceiverResourceName(String brokerConnectionName, String bridgeName, String policyName, String fqqn)

    • getBridgeQueueReceiverObjectName

      public static ObjectName getBridgeQueueReceiverObjectName(org.apache.activemq.artemis.core.server.management.ManagementService management, String brokerConnection, String bridgeName, String policyType, String policyName, String fqqn) throws Exception
      Throws:
      Exception

    • registerBridgeSender

      public static void registerBridgeSender(AMQPBridgeToSenderController sender) throws Exception
      Registers the bridge sender with the server management services on the source.
      Parameters:
      sender - The AMQP bridge sender controller that manages the bridgeManager sender.
      Throws:
      Exception - if an error occurs while registering the producer with the management services.

    • unregisterBridgeSender

      public static void unregisterBridgeSender(AMQPBridgeToSenderController sender) throws Exception
      Unregisters the bridge sender with the server management services on the source.
      Parameters:
      sender - The AMQP bridge sender controller that manages the bridge producer.
      Throws:
      Exception - if an error occurs while registering the sender with the management services.

    • getBridgeAddressSenderResourceName

      public static String getBridgeAddressSenderResourceName(String brokerConnectionName, String bridgeName, String policyName, String address)

    • getBridgeAddressSenderObjectName

      public static ObjectName getBridgeAddressSenderObjectName(org.apache.activemq.artemis.core.server.management.ManagementService management, String brokerConnection, String bridgeName, String policyType, String policyName, String address) throws Exception
      Throws:
      Exception

    • getBridgeQueueSenderResourceName

      public static String getBridgeQueueSenderResourceName(String brokerConnectionName, String bridgeName, String policyName, String fqqn)

    • getBridgeQueueSenderObjectName

      public static ObjectName getBridgeQueueSenderObjectName(org.apache.activemq.artemis.core.server.management.ManagementService management, String brokerConnection, String bridgeName, String policyType, String policyName, String fqqn) throws Exception
      Throws:
      Exception