Interface ConsumerBindingCapabilities


public interface ConsumerBindingCapabilities
Capabilities for a specific consumer binding.

This interface defines the capabilities of a consumer binding, including its acknowledgment mode and error handling configuration. Instances are created by ConsumerBindingCapabilitiesFactory.create(org.springframework.cloud.stream.binder.ConsumerProperties) during workflow initialization.

See Also:
  • Method Details

    • getBindingName

      String getBindingName()
      Get the binding name.
      Returns:
      the consumer binding name
    • getAcknowledgmentMode

      default ConsumerBindingCapabilities.ConsumerAckMode getAcknowledgmentMode()
      Get the acknowledgment mode for this consumer binding.
      Returns:
      the consumer acknowledgment mode
    • getErrorsBaseName

      default String getErrorsBaseName(String destination, String group, org.springframework.cloud.stream.binder.Binder<?,?,?> binder)
      Get the errors base name for this consumer binding.

      TIP: Only need to override this if the binder overwrites AbstractMessageChannelBinder.errorsBaseName(ConsumerDestination, String, ConsumerProperties).

      Parameters:
      destination - the consumer binding's destination
      group - the consumer binding's group ID
      binder - the binder instance
      Returns:
      consumer errors base name