wangli/nanopart
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(REQ-3300) - 添加变洽签日志事件处理类

Browse Source
This commit is contained in:
wangli 2025-02-08 11:24:56 +08:00
parent 0d5b31c217
commit 9859e8d29a
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
visa/visa-server/src/main/java/cn/axzo/nanopart/visa/server/mq/listener/visa/ChangeRecordLogEventHandle.java
View File

@ -3,7 +3,11 @@ package cn.axzo.nanopart.visa.server.mq.listener.visa;
import cn.axzo.framework.rocketmq.Event;
import cn.axzo.framework.rocketmq.EventConsumer;
import cn.axzo.framework.rocketmq.EventHandler;
import cn.axzo.nanopart.visa.api.enums.MQEventEnum;
import cn.axzo.nanopart.visa.server.mq.producer.VisaChangeLogPayload;
import lombok.AllArgsConstructor;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.stereotype.Component;
/**
* TODO
@ -11,14 +15,17 @@ import org.springframework.beans.factory.InitializingBean;
* @author wangli
* @since 2025-02-08 11:18
*/
@Component
@AllArgsConstructor
public class ChangeRecordLogEventHandle implements EventHandler, InitializingBean {
private final EventConsumer eventConsumer;
@Override
public void onEvent(Event event, EventConsumer.Context context) {
VisaChangeLogPayload log = event.normalizedData(VisaChangeLogPayload.class);
}
@Override
public void afterPropertiesSet() throws Exception {
eventConsumer.registerHandler(MQEventEnum.VISA_CHANGE_LOG.getEventCode(), this);
}
}