jd-opensource#6: add requests metadata to all Syncers

yuanjinzhong · Aug 31, 2024 · 67c7e35 · 67c7e35
1 parent 2f38996
commit 67c7e35
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/...main/java/com/jd/live/agent/implement/service/policy/microservice/MicroServiceSyncer.java b/...main/java/com/jd/live/agent/implement/service/policy/microservice/MicroServiceSyncer.java
@@ -332,6 +332,7 @@ private Response<Service> getService(String name, ServiceSyncMeta meta, SyncConf
      */
     private void configure(SyncConfig config, HttpURLConnection conn) {
         config.header(conn::setRequestProperty);
+        application.sync(conn::setRequestProperty);
         conn.setRequestProperty("Accept", "application/json");
         conn.setConnectTimeout((int) config.getTimeout());
     }

diff --git a/...src/main/java/com/jd/live/agent/implement/service/policy/multilive/LiveServiceSyncer.java b/...src/main/java/com/jd/live/agent/implement/service/policy/multilive/LiveServiceSyncer.java
@@ -27,6 +27,7 @@
 import com.jd.live.agent.core.inject.annotation.Config;
 import com.jd.live.agent.core.inject.annotation.Inject;
 import com.jd.live.agent.core.inject.annotation.Injectable;
+import com.jd.live.agent.core.instance.Application;
 import com.jd.live.agent.core.parser.ObjectParser;
 import com.jd.live.agent.core.parser.TypeReference;
 import com.jd.live.agent.core.service.AbstractService;
@@ -85,6 +86,9 @@ public class LiveServiceSyncer extends AbstractService implements PolicyService,
     @Inject(PolicySupervisor.COMPONENT_POLICY_SUPERVISOR)
     private PolicySupervisor policySupervisor;
 
+    @Inject(Application.COMPONENT_APPLICATION)
+    private Application application;
+
     @Inject(Timer.COMPONENT_TIMER)
     private Timer timer;
 
@@ -320,6 +324,7 @@ private Response<Service> getService(String name, ServiceSyncMeta meta, SyncConf
      */
     private void configure(SyncConfig config, HttpURLConnection conn) {
         config.header(conn::setRequestProperty);
+        application.sync(conn::setRequestProperty);
         conn.setRequestProperty("Accept", "application/json");
         conn.setConnectTimeout((int) config.getTimeout());
     }