All Classes and Interfaces
Class
Description
Base for RocketMQ header mappers.
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.
jackson header mapper for RocketMQ.
Represents a header that could not be decoded due to an untrusted type.
A pollable
MessageSource for RocketMQ.Gets the beans configured in the configuration file.
issue:https://github.com/alibaba/spring-cloud-alibaba/issues/1681 .
binding rocketMq properties.
find RocketMQ bean by annotations.
It is mainly provided for conversion between rocketMq-message and Spring-message,
and parameters are passed through HEADERS.
Extended function related to producer . eg:initial
Extended consumer properties for RocketMQ binder.
rocketMQ specific extended binding properties class that extends from
AbstractExtendedBindingProperties.header value mapper for RocketMQ.
A
Binder that uses RocketMQ as the
underlying middleware.The default message converter of rocketMq,its bean name is
DEFAULT_NAME .Extended function related to producer . eg:initial .
Extended producer properties for RocketMQ binder.
Container object for RocketMQ specific extended producer and consumer binding
properties.