[apisix-java-plugin-runner] branch feat/watch updated: chore: add check for config token

[chenjunxu]

This is an automated email from the ASF dual-hosted git repository.

chenjunxu pushed a commit to branch feat/watch
in repository https://gitbox.apache.org/repos/asf/apisix-java-plugin-runner.git


The following commit(s) were added to refs/heads/feat/watch by this push:
     new b96b531  chore: add check for config token
b96b531 is described below

commit b96b531c544234b14a66ca9b4cd383787f7448e4
Author: nic-chen <chenjun...@gmail.com>
AuthorDate: Mon Oct 31 18:02:14 2022 +0800

    chore: add check for config token
---
 .../apache/apisix/plugin/runner/handler/A6ConfigHandlerTest.java  | 1 +
 .../java/org/apache/apisix/plugin/runner/handler/TestWatcher.java | 8 +++++++-
 2 files changed, 8 insertions(+), 1 deletion(-)

diff --git 
a/runner-core/src/test/java/org/apache/apisix/plugin/runner/handler/A6ConfigHandlerTest.java
 
b/runner-core/src/test/java/org/apache/apisix/plugin/runner/handler/A6ConfigHandlerTest.java
index ced6711..b1a09ab 100644
--- 
a/runner-core/src/test/java/org/apache/apisix/plugin/runner/handler/A6ConfigHandlerTest.java
+++ 
b/runner-core/src/test/java/org/apache/apisix/plugin/runner/handler/A6ConfigHandlerTest.java
@@ -133,6 +133,7 @@ class A6ConfigHandlerTest {
         Assertions.assertEquals(config.getChain().getIndex(), 0);
         Assertions.assertEquals(config.get("FooFilter"), "Bar");
         Assertions.assertEquals(tWatcher.getConfig(), config.getConfig());
+        Assertions.assertEquals(tWatcher.getToken(), response.getConfToken());
     }
 
     @Test
diff --git 
a/runner-core/src/test/java/org/apache/apisix/plugin/runner/handler/TestWatcher.java
 
b/runner-core/src/test/java/org/apache/apisix/plugin/runner/handler/TestWatcher.java
index e01d41c..ae931a2 100644
--- 
a/runner-core/src/test/java/org/apache/apisix/plugin/runner/handler/TestWatcher.java
+++ 
b/runner-core/src/test/java/org/apache/apisix/plugin/runner/handler/TestWatcher.java
@@ -6,12 +6,17 @@ import org.apache.apisix.plugin.runner.A6Conf;
 import org.apache.apisix.plugin.runner.A6ConfigWatcher;
 
 class TestWatcher implements A6ConfigWatcher {
-    public Map<String, String> config;
+    private Map<String, String> config;
+    private long token;
 
     public Map<String, String> getConfig() {
         return config;
     }
 
+    public long getToken() {
+        return token;
+    }
+
     @Override
     public String name() {
         return "test";
@@ -20,5 +25,6 @@ class TestWatcher implements A6ConfigWatcher {
     @Override
     public void watch(long confToken, A6Conf a6Conf) {
         config = a6Conf.getConfig();
+        token = confToken;
     }
 }