Package com.alibaba.cloud.stream.binder.rocketmq.integration.inbound.pull

Class DefaultErrorAcknowledgeHandler

java.lang.Object

com.alibaba.cloud.stream.binder.rocketmq.integration.inbound.pull.DefaultErrorAcknowledgeHandler

All Implemented Interfaces:

ErrorAcknowledgeHandler

public class DefaultErrorAcknowledgeHandler
extends Object
implements ErrorAcknowledgeHandler

By default, if consumption fails, the corresponding MessageQueue will always be retried, that is, the consumption of other messages in the MessageQueue will be blocked.

Author:

zkzlx

Constructor Summary

Constructors

Constructor	Description
DefaultErrorAcknowledgeHandler()

Method Summary

Modifier and Type	Method	Description
org.springframework.integration.acks.AcknowledgmentCallback.Status	handler(org.springframework.messaging.Message<?> message)	Ack state handling, including receive, reject, and retry, when a consumption exception occurs.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultErrorAcknowledgeHandler

public DefaultErrorAcknowledgeHandler()

Method Details

handler

public org.springframework.integration.acks.AcknowledgmentCallback.Status handler(org.springframework.messaging.Message<?> message)

Ack state handling, including receive, reject, and retry, when a consumption exception occurs.

Specified by:

handler in interface ErrorAcknowledgeHandler

Parameters:

message - message

Returns:

see AcknowledgmentCallback.Status