From 187da615bdd737b0439481cd9765dcbf11c3ed40 Mon Sep 17 00:00:00 2001 From: Benoit TELLIER Date: Thu, 6 Mar 2025 02:44:56 +0100 Subject: [PATCH] ISSUE-320 PrepareConfHandler: merge token and confToken variables --- .../apisix/plugin/runner/handler/PrepareConfHandler.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/runner-core/src/main/java/org/apache/apisix/plugin/runner/handler/PrepareConfHandler.java b/runner-core/src/main/java/org/apache/apisix/plugin/runner/handler/PrepareConfHandler.java index 6a7e9fac..eb5dceae 100644 --- a/runner-core/src/main/java/org/apache/apisix/plugin/runner/handler/PrepareConfHandler.java +++ b/runner-core/src/main/java/org/apache/apisix/plugin/runner/handler/PrepareConfHandler.java @@ -61,7 +61,6 @@ protected void channelRead0(ChannelHandlerContext ctx, A6Request request) { Req req = ((A6ConfigRequest) request).getReq(); long confToken = ThreadLocalRandom.current().nextInt(Integer.MAX_VALUE); A6Response response = new A6ConfigResponse(confToken); - long token = ((A6ConfigResponse) response).getConfToken(); PluginFilterChain chain = createFilterChain(req); /* @@ -76,9 +75,9 @@ protected void channelRead0(ChannelHandlerContext ctx, A6Request request) { config.put(conf.name(), conf.value()); } A6Conf a6Conf = new A6Conf(config, chain); - cache.put(token, a6Conf); + cache.put(confToken, a6Conf); for (A6ConfigWatcher watcher : watchers) { - watcher.watch(token, a6Conf); + watcher.watch(confToken, a6Conf); } ctx.write(response); ctx.writeAndFlush(response);