diff --git a/grpc-java-polaris/src/main/java/com/tencent/polaris/grpc/resolver/PolarisNameResolver.java b/grpc-java-polaris/src/main/java/com/tencent/polaris/grpc/resolver/PolarisNameResolver.java index 1a80717..7313325 100644 --- a/grpc-java-polaris/src/main/java/com/tencent/polaris/grpc/resolver/PolarisNameResolver.java +++ b/grpc-java-polaris/src/main/java/com/tencent/polaris/grpc/resolver/PolarisNameResolver.java @@ -149,23 +149,21 @@ private void doWatch(Listener2 listener) { private void notifyListener(Listener2 listener, InstancesResponse response) { ServiceInstances serviceInstances = response.toServiceInstances(); - if (!serviceInstances.getInstances().isEmpty()) { - List equivalentAddressGroups = serviceInstances.getInstances() - .stream() - .map(this::buildEquivalentAddressGroup) - .collect(Collectors.toList()); + List equivalentAddressGroups = serviceInstances.getInstances() + .stream() + .map(this::buildEquivalentAddressGroup) + .collect(Collectors.toList()); - Attributes.Builder builder = Attributes.newBuilder(); + Attributes.Builder builder = Attributes.newBuilder(); - if (sourceService != null) { - builder.set(Common.SOURCE_SERVICE_INFO, sourceService); - } - - listener.onResult(ResolutionResult.newBuilder() - .setAddresses(equivalentAddressGroups) - .setAttributes(builder.build()) - .build()); + if (sourceService != null) { + builder.set(Common.SOURCE_SERVICE_INFO, sourceService); } + + listener.onResult(ResolutionResult.newBuilder() + .setAddresses(equivalentAddressGroups) + .setAttributes(builder.build()) + .build()); } @Override