Package com.broadleafcommerce.common.messaging.retry.nonblocking

Class NonBlockingFixedRetryInfo

java.lang.Object
com.broadleafcommerce.common.messaging.retry.FixedRetryInfo
com.broadleafcommerce.common.messaging.retry.nonblocking.NonBlockingFixedRetryInfo
public class NonBlockingFixedRetryInfo extends FixedRetryInfo
Retry configuration for the non-blocking case

  • Constructor Details

    • NonBlockingFixedRetryInfo

      public NonBlockingFixedRetryInfo()

  • Method Details

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class FixedRetryInfo

    • canEqual

      protected boolean canEqual(Object other)
      Overrides:
      canEqual in class FixedRetryInfo

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class FixedRetryInfo

    • getConsumerBinding

      public String getConsumerBinding()
      The consumer binding from which to poll for candidate retryable messages. This is the binding name alone (not the fully qualified property). For example, for a fully qualified binding property spring.cloud.stream.bindings.retryInput1, the consumerBinding value assigned here will be retryInput1. You may define your own binding configuration at this name in your property files, in which case the system will use what you have defined there. However, in the absence of pre-defined configuration at this binding name, the system will auto create a consumer binding that is suitable for most non-blocking retry use cases.

    • getProducerBinding

      public String getProducerBinding()
      The producer binding used to send a message to park in the retry queue defined here. This is the binding name alone (not the fully qualified property). For example, for a fully qualified binding property spring.cloud.stream.bindings.retryOutput1, the producerBinding value assigned here will be retryOutput1. You may define your own binding configuration at this name in your property files, in which case the system will use what you have defined there. However, in the absence of pre-defined configuration at this binding name, the system will auto create a producer binding that is suitable for most non-blocking retry use cases.

    • getOriginalProducerBinding

      public String getOriginalProducerBinding()
      The producer binding used to send the message back to the original channel to re-attempt processing.

    • setConsumerBinding

      public void setConsumerBinding(String consumerBinding)
      The consumer binding from which to poll for candidate retryable messages. This is the binding name alone (not the fully qualified property). For example, for a fully qualified binding property spring.cloud.stream.bindings.retryInput1, the consumerBinding value assigned here will be retryInput1. You may define your own binding configuration at this name in your property files, in which case the system will use what you have defined there. However, in the absence of pre-defined configuration at this binding name, the system will auto create a consumer binding that is suitable for most non-blocking retry use cases.

    • setProducerBinding

      public void setProducerBinding(String producerBinding)
      The producer binding used to send a message to park in the retry queue defined here. This is the binding name alone (not the fully qualified property). For example, for a fully qualified binding property spring.cloud.stream.bindings.retryOutput1, the producerBinding value assigned here will be retryOutput1. You may define your own binding configuration at this name in your property files, in which case the system will use what you have defined there. However, in the absence of pre-defined configuration at this binding name, the system will auto create a producer binding that is suitable for most non-blocking retry use cases.

    • setOriginalProducerBinding

      public void setOriginalProducerBinding(String originalProducerBinding)
      The producer binding used to send the message back to the original channel to re-attempt processing.

    • toString

      public String toString()
      Overrides:
      toString in class FixedRetryInfo