Class AMQPFederationConsumerConfiguration

java.lang.Object
org.apache.activemq.artemis.protocol.amqp.connect.federation.AMQPFederationConsumerConfiguration
public final class AMQPFederationConsumerConfiguration extends Object
Configuration options applied to a consumer created from federation policies for address or queue federation. The options first check the policy properties for matching configuration settings before looking at the federation's own configuration for the options managed here.

  • Constructor Details

  • Method Details

    • getReceiverCredits

      public int getReceiverCredits()
      Returns the credit batch size offered to a Receiver link.
      Returns:
      the credit batch size offered to a Receiver link

    • getReceiverCreditsLow

      public int getReceiverCreditsLow()
      Returns the number of remaining credits on a Receiver before the batch is replenished.
      Returns:
      the number of remaining credits on a Receiver before the batch is replenished

    • getReceiverQuiesceTimeout

      public int getReceiverQuiesceTimeout()
      Returns the receiver drain timeout for a stopping federation consumer before it is closed.
      Returns:
      the receiver drain timeout for a stopping federation consumer before it is closed

    • getAddressReceiverIdleTimeout

      public int getAddressReceiverIdleTimeout()
      Returns the idle timeout for a drained federation address consumer before it is closed.
      Returns:
      the idle timeout for a drained federation address consumer before it is closed

    • getQueueReceiverIdleTimeout

      public int getQueueReceiverIdleTimeout()
      Returns the idle timeout for a drained federation queue consumer before it is closed.
      Returns:
      the idle timeout for a drained federation queue consumer before it is closed

    • getPullReceiverBatchSize

      public int getPullReceiverBatchSize()
      Returns the credit batch size offered to a Receiver link that is in pull mode.
      Returns:
      the credit batch size offered to a Receiver link that is in pull mode

    • getLargeMessageThreshold

      public int getLargeMessageThreshold()
      Returns the size in bytes of an incoming message after which the Receiver treats it as large.
      Returns:
      the size in bytes of an incoming message after which the Receiver treats it as large

    • getLinkAttachTimeout

      public int getLinkAttachTimeout()
      Returns the timeout value to use when waiting for a corresponding link attach from the remote.
      Returns:
      the timeout value to use when waiting for a corresponding link attach from the remote

    • isCoreMessageTunnelingEnabled

      public boolean isCoreMessageTunnelingEnabled()
      Returns true if the federation is configured to tunnel core messages as AMQP custom messages.
      Returns:
      true if the federation is configured to tunnel core messages as AMQP custom messages

    • isIgnoreAddressBindingFilters

      public boolean isIgnoreAddressBindingFilters()
      Returns true if federation is configured to ignore filters on individual address bindings.
      Returns:
      true if federation is configured to ignore filters on individual address bindings

    • isIgnoreSubscriptionFilters

      public boolean isIgnoreSubscriptionFilters()
      Returns true if federation is configured to ignore filters on individual queue consumers.
      Returns:
      true if federation is configured to ignore filters on individual queue consumers

    • isIgnoreSubscriptionPriorities

      public boolean isIgnoreSubscriptionPriorities()
      Returns true if federation is configured to ignore priorities on individual queue consumers.
      Returns:
      true if federation is configured to ignore priorities on individual queue consumers

    • isUseModifiedForTransientDeliveryErrors

      public boolean isUseModifiedForTransientDeliveryErrors()
      (@return the use modified for transient delivery errors configuration}

    • isDrainOnTransientDeliveryErrors

      public boolean isDrainOnTransientDeliveryErrors()
      (@return the drain link credit on transient delivery errors configuration}

    • getLinkQuiesceTimeout

      public int getLinkQuiesceTimeout()
      Returns the federation receiver link quiesce timeout configuration.
      Returns:
      the federation receiver link quiesce timeout configuration