From cdbe5a610094c10f7ea8be11c6a53374b9c06299 Mon Sep 17 00:00:00 2001
From: mrz <17966059@qq.com>
Date: Thu, 1 Apr 2021 10:26:19 +0800
Subject: [PATCH] 将kafka的相关BEAN初始化配置，增加过滤器接口
---
src/main/java/com/sunyo/wlpt/message/bus/service/service/impl/MessageRouterReciverFilterImpl.java | 2 ++
1 file changed, 2 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/sunyo/wlpt/message/bus/service/service/impl/MessageRouterReciverFilterImpl.java b/src/main/java/com/sunyo/wlpt/message/bus/service/service/impl/MessageRouterReciverFilterImpl.java
index 72ecd45..09f1490 100644
--- a/src/main/java/com/sunyo/wlpt/message/bus/service/service/impl/MessageRouterReciverFilterImpl.java
+++ b/src/main/java/com/sunyo/wlpt/message/bus/service/service/impl/MessageRouterReciverFilterImpl.java
@@ -6,6 +6,7 @@ import com.sunyo.wlpt.message.bus.service.mapper.MessageRouterReciverFilterMappe
import com.sunyo.wlpt.message.bus.service.model.MessageRouter;
import com.sunyo.wlpt.message.bus.service.model.MessageRouterReciverFilter;
import com.sunyo.wlpt.message.bus.service.service.MessageRouterReciverFilterService;
+import com.sunyo.wlpt.message.bus.service.utils.IdUtils;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
@@ -19,6 +20,7 @@ public class MessageRouterReciverFilterImpl implements MessageRouterReciverFilte
@Override
public int addMessageRouterReciverFilter(MessageRouterReciverFilter messageRouterReciverFilter) {
+ messageRouterReciverFilter.setId(IdUtils.generateId());
return messageRouterReciverFilterMapper.insertSelective(messageRouterReciverFilter);
}
--
libgit2 0.24.0