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

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

Related Packages

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

Classes

Class	Description
DefaultErrorAcknowledgeHandler	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.
RocketMQAckCallback	A pollable MessageSource for RocketMQ.
RocketMQMessageSource