Class AMQPBridgeReceiverConfiguration

java.lang.Object
org.apache.activemq.artemis.protocol.amqp.connect.bridge.AMQPBridgeLinkConfiguration
org.apache.activemq.artemis.protocol.amqp.connect.bridge.AMQPBridgeReceiverConfiguration
public final class AMQPBridgeReceiverConfiguration extends AMQPBridgeLinkConfiguration
Configuration options applied to a receiver created from bridge from policies for address or queue bridging. The options first check the policy properties for matching configuration settings before looking at the bridgeManager'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

    • 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

    • getReceiverQuiesceTimeout

      public int getReceiverQuiesceTimeout()
      Returns the configured receiver quiesce timeout before the operation is assumed to have failed.
      Returns:
      the configured receiver quiesce timeout before the operation is assumed to have failed

    • getAddressReceiverIdleTimeout

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

    • getQueueReceiverIdleTimeout

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

    • 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

    • isIgnoreSubscriptionFilters

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

    • isIgnoreQueueFilters

      public boolean isIgnoreQueueFilters()
      Returns true if the bridgeManager is configured to ignore filters on the bridged Queue.
      Returns:
      true if the bridgeManager is configured to ignore filters on the bridged Queue

    • isReceiverPriorityDisabled

      public boolean isReceiverPriorityDisabled()
      Returns true if bridgeManager is configured to omit any priority properties on receiver links.
      Returns:
      true if bridgeManager is configured to omit any priority properties on receiver links

    • isReceiverDemandTrackingDisabled

      public boolean isReceiverDemandTrackingDisabled()
      Returns true if bridgeManager is configured to ignore local demand and always create a receiver.
      Returns:
      true if bridgeManager is configured to ignore local demand and always create a receiver

    • isPreferSharedDurableSubscriptions

      public boolean isPreferSharedDurableSubscriptions()
      Returns true if bridge from address policies are configured to prefer using shared durable address subscriptions.
      Returns:
      true if bridge from address policies are configured to prefer using shared durable address subscriptions

    • 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