diff --git a/spring-cloud-contract-stub-runner/src/main/java/org/springframework/cloud/contract/stubrunner/spring/cloud/StubRunnerDiscoveryClient.java b/spring-cloud-contract-stub-runner/src/main/java/org/springframework/cloud/contract/stubrunner/spring/cloud/StubRunnerDiscoveryClient.java index eeafe3eb43..05af101388 100644 --- a/spring-cloud-contract-stub-runner/src/main/java/org/springframework/cloud/contract/stubrunner/spring/cloud/StubRunnerDiscoveryClient.java +++ b/spring-cloud-contract-stub-runner/src/main/java/org/springframework/cloud/contract/stubrunner/spring/cloud/StubRunnerDiscoveryClient.java @@ -28,7 +28,6 @@ import org.apache.commons.logging.LogFactory; import org.springframework.cloud.client.DefaultServiceInstance; import org.springframework.cloud.client.ServiceInstance; import org.springframework.cloud.client.discovery.DiscoveryClient; -import org.springframework.cloud.client.discovery.noop.NoopDiscoveryClient; import org.springframework.cloud.contract.stubrunner.RunningStubs; import org.springframework.cloud.contract.stubrunner.StubFinder; import org.springframework.cloud.contract.stubrunner.util.StringUtils; @@ -70,8 +69,8 @@ class StubRunnerDiscoveryClient implements DiscoveryClient { this.stubMapperProperties = stubMapperProperties; } - private NoopDiscoveryClient noOpDiscoveryClient(String springAppName) { - return new NoopDiscoveryClient(new DefaultServiceInstance(springAppName, "localhost", 0, false)); + private StubRunnerNoOpDiscoveryClient noOpDiscoveryClient(String springAppName) { + return new StubRunnerNoOpDiscoveryClient(new DefaultServiceInstance(springAppName, "localhost", 0, false)); } @Override @@ -153,3 +152,32 @@ class StubRunnerDiscoveryClient implements DiscoveryClient { return new ArrayList<>(); } } + +class StubRunnerNoOpDiscoveryClient implements DiscoveryClient { + + private final ServiceInstance instance; + + public StubRunnerNoOpDiscoveryClient(ServiceInstance instance) { + this.instance = instance; + } + + @Override + public String description() { + return "Spring Cloud Stub Runner No-op DiscoveryClient"; + } + + @Override + public ServiceInstance getLocalServiceInstance() { + return this.instance; + } + + @Override + public List getInstances(String serviceId) { + return Collections.emptyList(); + } + + @Override + public List getServices() { + return Collections.emptyList(); + } +} diff --git a/spring-cloud-contract-verifier/src/main/java/org/springframework/cloud/contract/verifier/messaging/stream/StreamStubMessages.java b/spring-cloud-contract-verifier/src/main/java/org/springframework/cloud/contract/verifier/messaging/stream/StreamStubMessages.java index 26f3b655d5..00cebd3016 100644 --- a/spring-cloud-contract-verifier/src/main/java/org/springframework/cloud/contract/verifier/messaging/stream/StreamStubMessages.java +++ b/spring-cloud-contract-verifier/src/main/java/org/springframework/cloud/contract/verifier/messaging/stream/StreamStubMessages.java @@ -24,7 +24,7 @@ import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.cloud.contract.verifier.messaging.MessageVerifier; import org.springframework.cloud.stream.config.BindingProperties; -import org.springframework.cloud.stream.config.ChannelBindingServiceProperties; +import org.springframework.cloud.stream.config.BindingServiceProperties; import org.springframework.cloud.stream.test.binder.MessageCollector; import org.springframework.context.ApplicationContext; import org.springframework.messaging.Message; @@ -82,8 +82,8 @@ public class StreamStubMessages implements MessageVerifier> { private String resolvedDestination(String destination) { try { - ChannelBindingServiceProperties channelBindingServiceProperties = this.context - .getBean(ChannelBindingServiceProperties.class); + BindingServiceProperties channelBindingServiceProperties = this.context + .getBean(BindingServiceProperties.class); for (Map.Entry entry : channelBindingServiceProperties .getBindings().entrySet()) { if (destination.equals(entry.getValue().getDestination())) {