Class AMQPFederationCapabilities

java.lang.Object
org.apache.activemq.artemis.protocol.amqp.connect.federation.AMQPFederationCapabilities

public final class AMQPFederationCapabilities extends Object
Capabilities class that provides a reconciliation between what the remote offered as compared to what this federation instance desired in order to determine what features can and cannot be used.
  • Constructor Details

    • AMQPFederationCapabilities

      public AMQPFederationCapabilities()
  • Method Details

    • initialize

      public AMQPFederationCapabilities initialize(org.apache.qpid.proton.engine.Link controlLink)
      Initialize the federation versions all federation capabilities using the state of the opened control link to match on locally set desired capabilities sent to the remote and remotely offered capabilities.

      We cannot use any feature that was not indicated as locally desired when offered by the remote.

      Parameters:
      controlLink - The federation control link on the source or target side of the connection.
      Returns:
      this federation capabilities instance fully initialized.
    • getLocalVersion

      public int getLocalVersion()
      Returns the federation version in use on the local side of the connection..
      Returns:
      the federation version in use on the local side of the connection.
    • getRemoteVersion

      public int getRemoteVersion()
      Returns the federation version in use on the remote side of the connection..
      Returns:
      the federation version in use on the remote side of the connection.
    • isUseFQQNAddressSubscriptions

      public boolean isUseFQQNAddressSubscriptions()
      Returns true if federation address receivers can use FQQN source addresses or only legacy style..
      Returns:
      true if federation address receivers can use FQQN source addresses or only legacy style.