Class AMQPBridgeConfiguration

java.lang.Object
org.apache.activemq.artemis.protocol.amqp.connect.bridge.AMQPBridgeConfiguration
public class AMQPBridgeConfiguration extends Object
A configuration class that contains API for getting AMQP bridge specific configuration either from a Map of configuration elements or from the connection associated with the bridge instance, or possibly from a set default value.

  • 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

    • 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 bridge is configured to tunnel core messages as AMQP custom messages.
      Returns:
      true if the bridge is configured to tunnel core messages as AMQP custom messages

    • isIgnoreSubscriptionFilters

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

    • isIgnoreQueueFilters

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

    • isReceiverPriorityDisabled

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

    • isReceiverDemandTrackingDisabled

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

    • getReceiverQuiesceTimeout

      public int getReceiverQuiesceTimeout()
      Returns the receive quiesce timeout when shutting down a receiver when local demand is removed.
      Returns:
      the receive quiesce timeout when shutting down a receiver when local demand is removed

    • getAddressReceiverIdleTimeout

      public int getAddressReceiverIdleTimeout()
      Returns the receive idle timeout when shutting down a address Receiver when local demand is removed.
      Returns:
      the receive idle timeout when shutting down a address Receiver when local demand is removed

    • getQueueReceiverIdleTimeout

      public int getQueueReceiverIdleTimeout()
      Returns the receive idle timeout when shutting down a queue Receiver when local demand is removed.
      Returns:
      the receive idle timeout when shutting down a queue Receiver when local demand is removed

    • isUsingPresettledSenders

      public boolean isUsingPresettledSenders()
      Returns true if bridge is configured to create links with the sender settle mode set to settled.
      Returns:
      true if bridge is configured to create links with the sender settle mode set to settled

    • getMaxLinkRecoveryAttempts

      public int getMaxLinkRecoveryAttempts()
      Returns the maximum number of link recovery attempts, or zero if no attempts allowed.
      Returns:
      the maximum number of link recovery attempts, or zero if no attempts allowed

    • getLinkRecoveryInitialDelay

      public long getLinkRecoveryInitialDelay()
      Returns the initial delay before a link recovery attempt is made.
      Returns:
      the initial delay before a link recovery attempt is made

    • getLinkRecoveryDelay

      public long getLinkRecoveryDelay()
      Returns the delay that will be used between successive link recovery attempts.
      Returns:
      the delay that will be used between successive link recovery attempts

    • isAutoDeleteDurableSubscriptions

      public boolean isAutoDeleteDurableSubscriptions()
      Returns true if bridge is configured to auto delete address senders using durable subscription bindings.
      Returns:
      true if bridge is configured to auto delete address senders using durable subscription bindings

    • getAutoDeleteDurableSubscriptionMsgCount

      public long getAutoDeleteDurableSubscriptionMsgCount()
      Returns the auto delete subscription message count for address senders using durable bindings.
      Returns:
      the auto delete subscription message count for address senders using durable bindings

    • getAutoDeleteDurableSubscriptionDelay

      public long getAutoDeleteDurableSubscriptionDelay()
      Returns the auto delete subscription delay for address senders using durable bindings.
      Returns:
      the auto delete subscription delay for address senders using durable bindings

    • 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 bridge receiver link quiesce timeout configuration.
      Returns:
      the bridge receiver link quiesce timeout configuration