From f6348318d0511d54babc870d5bd7dd9e4ea00313 Mon Sep 17 00:00:00 2001
From: lrj <386002446@qq.com>
Date: 星期五, 25 十月 2024 09:48:20 +0800
Subject: [PATCH] 修改参数传入 ，支持 canal
---
src/main/java/com/ycl/scheme/AbstractSchemeRunner.java | 9 ++++++++-
1 files changed, 8 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/ycl/scheme/AbstractSchemeRunner.java b/src/main/java/com/ycl/scheme/AbstractSchemeRunner.java
index 421b77b..a152645 100644
--- a/src/main/java/com/ycl/scheme/AbstractSchemeRunner.java
+++ b/src/main/java/com/ycl/scheme/AbstractSchemeRunner.java
@@ -2,9 +2,16 @@
import com.ycl.scheme.service.SchemeService;
+import java.util.HashMap;
+import java.util.Map;
+
public abstract class AbstractSchemeRunner {
- public abstract void run(SchemeService service);
+ protected Map<String,Parameter> parameters= new HashMap<>();
+
+ public void run(Map<String,Parameter> pars, SchemeService service){
+ parameters.putAll(pars);
+ }
}
--
Gitblit v1.8.0