| | |
|---|
| | | import com.qianwen.smartman.modules.notify.service.INotifyHistoryService; |
|---|
| | | |
|---|
| | | @RocketMQMessageListener(consumerGroup = "notify-center-history-consumerblade-api", topic = "notify-center-history-topic", selectorExpression = "success||error") |
|---|
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/notify/message/rocket/consumer/NotifyHistoryConsumer.class */ |
|---|
| | | |
|---|
| | | public class NotifyHistoryConsumer implements RocketMQListener<SerializableNotifierEvent>, RocketMQPushConsumerLifecycleListener { |
|---|
| | | private final INotifyHistoryService notifyHistoryService; |
|---|
| | | |
|---|
