From ed3b6354b449971acaac3372eece050d8bda0ec5 Mon Sep 17 00:00:00 2001 From: houxinyu Date: Sun, 9 Jul 2023 00:28:49 +0800 Subject: [PATCH] add data --- .../liteflow/parser/redis/util/RedisParserByPolling.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/liteflow-rule-plugin/liteflow-rule-redis/src/main/java/com/yomahub/liteflow/parser/redis/util/RedisParserByPolling.java b/liteflow-rule-plugin/liteflow-rule-redis/src/main/java/com/yomahub/liteflow/parser/redis/util/RedisParserByPolling.java index b49844371..5cdf59b98 100644 --- a/liteflow-rule-plugin/liteflow-rule-redis/src/main/java/com/yomahub/liteflow/parser/redis/util/RedisParserByPolling.java +++ b/liteflow-rule-plugin/liteflow-rule-redis/src/main/java/com/yomahub/liteflow/parser/redis/util/RedisParserByPolling.java @@ -187,6 +187,13 @@ public class RedisParserByPolling implements RedisParserHelper{ //轮询chain内容的定时任务 pool.scheduleAtFixedRate(pollChainTask(keyLuaOfChain, valueLuaOfChain), 60, Long.valueOf(redisParserVO.getPollingInterval()), TimeUnit.SECONDS); + + //如果有脚本内容 + if (ObjectUtil.isNotNull(scriptJedis) && ObjectUtil.isNotNull(redisParserVO.getScriptDataBase())) { + String keyLuaOfScript = scriptJedis.scriptLoad(luaOfKey); + String valueLuaOfScript = scriptJedis.scriptLoad(luaOfValue); + } + }