Merge pull request #1212 from LittleBaiBai/add-filter-to-replication-…

…client add ClientFilter to HttpReplicationClient
Netflix · Jun 7, 2019 · e71be8c · e71be8c
2 parents c416de5 + 8325086
commit e71be8c
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 2 deletions.
diff --git a/eureka-core/src/main/java/com/netflix/eureka/cluster/HttpReplicationClient.java b/eureka-core/src/main/java/com/netflix/eureka/cluster/HttpReplicationClient.java
@@ -14,5 +14,4 @@ public interface HttpReplicationClient extends EurekaHttpClient {
     EurekaHttpResponse<Void> statusUpdate(String asgName, ASGStatus newStatus);
 
     EurekaHttpResponse<ReplicationListResponse> submitBatchUpdates(ReplicationList replicationList);
-
 }
diff --git a/eureka-core/src/main/java/com/netflix/eureka/cluster/PeerEurekaNodes.java b/eureka-core/src/main/java/com/netflix/eureka/cluster/PeerEurekaNodes.java
@@ -18,7 +18,6 @@
 import com.netflix.appinfo.InstanceInfo;
 import com.netflix.discovery.EurekaClientConfig;
 import com.netflix.discovery.endpoint.EndpointUtils;
-import com.netflix.discovery.shared.Application;
 import com.netflix.eureka.EurekaServerConfig;
 import com.netflix.eureka.registry.PeerAwareInstanceRegistry;
 import com.netflix.eureka.resources.ServerCodecs;

diff --git a/eureka-core/src/main/java/com/netflix/eureka/transport/JerseyReplicationClient.java b/eureka-core/src/main/java/com/netflix/eureka/transport/JerseyReplicationClient.java
@@ -26,6 +26,7 @@
 import com.sun.jersey.api.client.ClientResponse;
 import com.sun.jersey.api.client.WebResource;
 import com.sun.jersey.api.client.WebResource.Builder;
+import com.sun.jersey.api.client.filter.ClientFilter;
 import com.sun.jersey.client.apache4.ApacheHttpClient4;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -126,6 +127,10 @@ public EurekaHttpResponse<ReplicationListResponse> submitBatchUpdates(Replicatio
         }
     }
 
+    public void addReplicationClientFilter(ClientFilter clientFilter) {
+        jerseyApacheClient.addFilter(clientFilter);
+    }
+
     @Override
     public void shutdown() {
         super.shutdown();
Original file line number	Diff line number	Diff line change
Expand Up		@@ -14,5 +14,4 @@ public interface HttpReplicationClient extends EurekaHttpClient {
		EurekaHttpResponse<Void> statusUpdate(String asgName, ASGStatus newStatus);

		EurekaHttpResponse<ReplicationListResponse> submitBatchUpdates(ReplicationList replicationList);

		}