Package com.broadleafcommerce.workflow.messaging

Interface Ack

All Known Implementing Classes:
KafkaAck
public interface Ack
Handles broker acknowledgement for a specific message. By performing manual message handling, the system can reject messages when at capacity - providing a form of flow control and throttling. Different implementations will handle different broker types.

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    ack(boolean rejected, org.springframework.messaging.Message<WorkflowEvent> message, Duration delay)
    Perform ack or nack on a message
    boolean
    canHandle(String binderType)
    Whether capable of handling messages for this binder type

  • Method Details

    • canHandle

      boolean canHandle(String binderType)
      Whether capable of handling messages for this binder type
      Parameters:
      binderType - The type of binder (relates to a broker platform)
      Returns:
      Whether capable of handling messages for this binder type

    • ack

      boolean ack(boolean rejected, org.springframework.messaging.Message<WorkflowEvent> message, Duration delay)
      Perform ack or nack on a message
      Parameters:
      rejected - Whether the system rejected the workflow request. If so, should be a nack.
      message - The message that was requested for execution.
      delay - The delay should a nack be requested. The delay will elapse before the message is pulled again by a consumer.
      Returns:
      Whether the ack or nack handling was performed. False if this instance is not capable of handling the message.