diff --git a/itc-pcitc-dependencies/itc-pcitc-dependencies-service/src/main/java/com/pictc/config/PEventListenerConfig.java b/itc-pcitc-dependencies/itc-pcitc-dependencies-service/src/main/java/com/pictc/config/PEventListenerConfig.java index 4785cbc..98ba15a 100644 --- a/itc-pcitc-dependencies/itc-pcitc-dependencies-service/src/main/java/com/pictc/config/PEventListenerConfig.java +++ b/itc-pcitc-dependencies/itc-pcitc-dependencies-service/src/main/java/com/pictc/config/PEventListenerConfig.java @@ -1,6 +1,5 @@ package com.pictc.config; -import org.springframework.cloud.client.loadbalancer.LoadBalanced; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.web.client.RestTemplate; diff --git a/itc-pcitc-dependencies/itc-pcitc-dependencies-service/src/main/java/com/pictc/listener/PEventListenerPublisher.java b/itc-pcitc-dependencies/itc-pcitc-dependencies-service/src/main/java/com/pictc/listener/PEventListenerPublisher.java index d104b38..76a3c3f 100644 --- a/itc-pcitc-dependencies/itc-pcitc-dependencies-service/src/main/java/com/pictc/listener/PEventListenerPublisher.java +++ b/itc-pcitc-dependencies/itc-pcitc-dependencies-service/src/main/java/com/pictc/listener/PEventListenerPublisher.java @@ -38,12 +38,12 @@ public class PEventListenerPublisher { Set services = TNacosManager.getNotSelfServices(); boolean flag = single?false:true; if(CollectionUtils.isNotEmpty(services)) { + HttpHeaders headers = TNacosManager.createNewHeaders(); + byte[] bytes = ObjectUtils.toBytes(conetext); for (String serviceId : services) { try { URI uri = TNacosManager.getServiceURI(serviceId); if(uri!=null) { - HttpHeaders headers = TNacosManager.createNewHeaders(); - byte[] bytes = ObjectUtils.toBytes(conetext); RequestEntity request = new RequestEntity(bytes,headers,HttpMethod.POST,uri); ResponseEntity responseEntity = rest.exchange(request,boolean.class); if(single && responseEntity.hasBody() && responseEntity.getBody()) {