Package com.solace.connector.core.customizer

Interface AsyncConsumerAcknowledgmentCustomizer

public interface AsyncConsumerAcknowledgmentCustomizer

Create a bean of this type to inject a consumer acknowledgement customizer that will be used by the Connector Framework when messages are processed asynchronously.

Mainly to be used when working with existing binders.

  • Method Summary

    Modifier and Type
    Method
    Description
    String
    binderType()
    The type of the consumer binder.
    default void
    doAck(org.springframework.integration.acks.AcknowledgmentCallback acknowledgmentCallback)
    A means for customizing how consumer messages are acknowledged for a given binder.
    default void
    doNack(org.springframework.integration.acks.AcknowledgmentCallback acknowledgmentCallback, Throwable exception)
    A means for customizing how consumer messages are negatively acknowledged for a given binder.

  • Method Details

    • binderType

      String binderType()
      The type of the consumer binder.
      Returns:
      the binder type

    • doNack

      default void doNack(org.springframework.integration.acks.AcknowledgmentCallback acknowledgmentCallback, Throwable exception)
      A means for customizing how consumer messages are negatively acknowledged for a given binder.
      Parameters:
      acknowledgmentCallback - consumer acknowledgmentCallback
      exception - because of which message would be NACKed.

    • doAck

      default void doAck(org.springframework.integration.acks.AcknowledgmentCallback acknowledgmentCallback)
      A means for customizing how consumer messages are acknowledged for a given binder.
      Parameters:
      acknowledgmentCallback - consumer acknowledgmentCallback