From a87aa74a3af27960276ed02f4273386d25d2a231 Mon Sep 17 00:00:00 2001
From: duxinglangzi <871364441@qq.com>
Date: 星期五, 24 六月 2022 15:41:11 +0800
Subject: [PATCH] 支持动态参数配置
---
src/main/java/com/duxinglangzi/canal/starter/container/DmlMessageTransponderContainer.java | 5 ++---
1 files changed, 2 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/duxinglangzi/canal/starter/container/DmlMessageTransponderContainer.java b/src/main/java/com/duxinglangzi/canal/starter/container/DmlMessageTransponderContainer.java
index 4214713..0374716 100644
--- a/src/main/java/com/duxinglangzi/canal/starter/container/DmlMessageTransponderContainer.java
+++ b/src/main/java/com/duxinglangzi/canal/starter/container/DmlMessageTransponderContainer.java
@@ -29,8 +29,7 @@
public void initConnect() {
try {
// init supportAllTypes
- registrars.forEach(e -> SUPPORT_ALL_TYPES.addAll(
- Arrays.asList(e.getListenerEntry().getValue().eventType())));
+ registrars.forEach(e -> SUPPORT_ALL_TYPES.addAll(Arrays.asList(e.getEventType())));
connector.connect();
connector.subscribe(endpointInstance.getSubscribe());
connector.rollback();
@@ -114,7 +113,7 @@
eventType))
.forEach(element -> {
try {
- element.getListenerEntry().getKey().invoke(element.getBean(), eventType, rowData);
+ element.getMethod().invoke(element.getBean(), eventType, rowData);
} catch (IllegalAccessException | InvocationTargetException e) {
logger.error("[DmlMessageTransponderContainer_consumer] RowData Callback Method invoke error message", e);
throw new RuntimeException("RowData Callback Method invoke error message锛� " + e.getMessage(), e);
--
Gitblit v1.8.0