wangli/axzo-lib-box
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: 优化事件

Browse Source
This commit is contained in:
zengxiaobo 2024-06-05 16:31:02 +08:00
parent 223bb5cfeb
commit d43fedf5ba
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
event-support-lib/src/main/java/cn/axzo/foundation/event/support/consumer/DefaultRocketMQListener.java
View File

@ -3,6 +3,7 @@ package cn.axzo.foundation.event.support.consumer;
import com.google.common.base.Preconditions;
import com.google.common.collect.Maps;
import lombok.Builder;
import lombok.Getter;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.common.message.MessageConst;
import org.apache.rocketmq.common.message.MessageExt;
@ -14,6 +15,7 @@ import java.util.Optional;
@Slf4j
public class DefaultRocketMQListener implements RocketMQListener<MessageExt> {
@Getter
protected EventConsumer eventConsumer;
@Builder