Class RocketMqSender
-
- All Implemented Interfaces:
-
io.github.caijiang.common.debounce.MqSender
@Service() public final class RocketMqSender implements MqSender
CJ
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description public classRocketMqSender.Companion
-
Field Summary
Fields Modifier and Type Field Description public final static RocketMqSender.CompanionCompanion
-
Constructor Summary
Constructors Constructor Description RocketMqSender(RocketMQTemplate template, DebounceProperties properties)
-
Method Summary
Modifier and Type Method Description UnitsendDelay(Message<DelayMQData> message, Duration duration)发送延时消息 -
-
Constructor Detail
-
RocketMqSender
RocketMqSender(RocketMQTemplate template, DebounceProperties properties)
-
-
Method Detail
-
sendDelay
Unit sendDelay(Message<DelayMQData> message, Duration duration)
发送延时消息
- Parameters:
duration- 间隔
-
-
-
-