diff --git a/server/src/main/java/io/wdd/rpc/execute/result/CreateStreamReader.java b/server/src/main/java/io/wdd/rpc/execute/result/CreateStreamReader.java index 4532196..9373180 100644 --- a/server/src/main/java/io/wdd/rpc/execute/result/CreateStreamReader.java +++ b/server/src/main/java/io/wdd/rpc/execute/result/CreateStreamReader.java @@ -38,6 +38,12 @@ public class CreateStreamReader implements ApplicationContextAware { // prepare the environment prepareEnv(); + // oldStreamKey equals streamKey don't need to do anything , just return + if (redisStreamReaderConfig.getStreamKey().equals(streamKey)) { + log.debug("redis listener container not change !"); + return; + } + // destroy the REDIS_STREAM_LISTENER_CONTAINER destroyStreamReader(streamKey); diff --git a/source/src/main/java/io/wdd/source/shell/agent-bootup.sh b/source/src/main/java/io/wdd/source/shell/agent-bootup.sh index a6b2347..4854a18 100644 --- a/source/src/main/java/io/wdd/source/shell/agent-bootup.sh +++ b/source/src/main/java/io/wdd/source/shell/agent-bootup.sh @@ -13,7 +13,6 @@ DependLibFiles=( wdd-lib-sys.sh ) - OctopusAgentUrl=https://happybirthday.107421.xyz/octopus-agent/ RepoSourcePath=https://raw.githubusercontent.com/zeaslity/ProjectOctopus/main/source/src/main/java/io/wdd/source/shell @@ -216,7 +215,6 @@ DownloadAllFile() { . ./lib/wdd-lib-os.sh CheckAndDownloadLatestVersion - FunctionSuccess FunctionEnd @@ -230,11 +228,6 @@ ModifySystemConfig(){ ## 配置内核参数 cat >/etc/sysctl.d/k8s.conf <" -f2 | cut -d"<" -f1) log "octopus agent latest version is => [ $latestVersion ]" - + echo "" rm -rf /octopus-agent/*.jar cd /octopus-agent log "start to download the latest version !" - wget "$OctopusAgentUrl$latestVersion" cp "$latestVersion" agent.jar - - log "" + echo "" echo "" log "----------------------------------------------" ls /octopus-agent/ | grep jar