From 779e979389ee92bb0a53a9ab464a90977137c5d1 Mon Sep 17 00:00:00 2001
From: mingri31164 <3116430062@qq.com>
Date: Sun, 19 Oct 2025 15:48:44 +0800
Subject: [PATCH] Centralize protocol version constant

---
 .../cn/hippo4j/springboot/starter/core/ClientWorker.java  | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)

diff --git a/starters/threadpool/server/src/main/java/cn/hippo4j/springboot/starter/core/ClientWorker.java b/starters/threadpool/server/src/main/java/cn/hippo4j/springboot/starter/core/ClientWorker.java
index 5e7aefac..e454394c 100644
--- a/starters/threadpool/server/src/main/java/cn/hippo4j/springboot/starter/core/ClientWorker.java
+++ b/starters/threadpool/server/src/main/java/cn/hippo4j/springboot/starter/core/ClientWorker.java
@@ -71,8 +71,6 @@ public class ClientWorker implements DisposableBean {
     private final String identify;
     private final String version;
 
-    // Client protocol version for incremental updates
-    private static final int PROTOCOL_VERSION = 2;
     private final HttpAgent agent;
     private final ServerHealthCheck serverHealthCheck;
     private final ScheduledExecutorService executorService;
@@ -161,7 +159,7 @@ public class ClientWorker implements DisposableBean {
                     CacheData cacheData = cacheMap.get(tpId);
                     ThreadPoolParameterInfo poolInfo = JSONUtil.parseObject(content, ThreadPoolParameterInfo.class);
                     // Use incremental content for protocol version 2+ clients
-                    String poolContent = IncrementalContentUtil.getIncrementalContent(poolInfo, PROTOCOL_VERSION);
+                    String poolContent = IncrementalContentUtil.getIncrementalContent(poolInfo, IncrementalContentUtil.PROTOCOL_VERSION);
                     cacheData.setContent(poolContent);
                 } catch (Exception ignored) {
                     log.error("Failed to get the latest thread pool configuration.", ignored);
@@ -212,7 +210,7 @@ public class ClientWorker implements DisposableBean {
         }
         headers.put(CLIENT_VERSION, version);
         // Add protocol version header for incremental updates
-        headers.put("X-Hippo4j-Protocol-Version", String.valueOf(PROTOCOL_VERSION));
+        headers.put("X-Hippo4j-Protocol-Version", String.valueOf(IncrementalContentUtil.PROTOCOL_VERSION));
         try {
             long readTimeoutMs = timeout + Math.round(timeout >> 1);
             Result result = agent.httpPostByConfig(LISTENER_PATH, headers, params, readTimeoutMs);
@@ -291,7 +289,7 @@ public class ClientWorker implements DisposableBean {
                 serverConfig = getServerConfig(namespace, itemId, threadPoolId, defaultTimedOut);
                 ThreadPoolParameterInfo poolInfo = JSONUtil.parseObject(serverConfig, ThreadPoolParameterInfo.class);
                 // Use incremental content for protocol version 2+ clients
-                String content = IncrementalContentUtil.getIncrementalContent(poolInfo, PROTOCOL_VERSION);
+                String content = IncrementalContentUtil.getIncrementalContent(poolInfo, IncrementalContentUtil.PROTOCOL_VERSION);
                 cacheData.setContent(content);
             } catch (Exception ex) {
                 log.error("Cache Data Error. Service Unavailable: {}", ex.getMessage());