Package com.broadleafcommerce.workflow.messaging

Class KafkaAck

java.lang.Object

com.broadleafcommerce.workflow.messaging.KafkaAck

All Implemented Interfaces:

Ack

public class KafkaAck
extends Object
implements Ack

Kafka specific implementation of Ack

Constructor Summary

Constructors

Constructor	Description
KafkaAck()

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KafkaAck

public KafkaAck()

Method Details

canHandle

public boolean canHandle(String binderType)

Description copied from interface: Ack

Whether capable of handling messages for this binder type

Specified by:

canHandle in interface Ack

Parameters:

binderType - The type of binder (relates to a broker platform)

Returns:

Whether capable of handling messages for this binder type

ack

public boolean ack(boolean rejected,
 org.springframework.messaging.Message<WorkflowEvent> message,
 Duration delay)

Description copied from interface: Ack

Perform ack or nack on a message

Specified by:

ack in interface Ack

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.