diff --git a/spring-cloud-contract-stub-runner/src/main/java/org/springframework/cloud/contract/stubrunner/messaging/stream/StubRunnerStreamConfiguration.java b/spring-cloud-contract-stub-runner/src/main/java/org/springframework/cloud/contract/stubrunner/messaging/stream/StubRunnerStreamConfiguration.java index c8e06aa92e..9d171d4b7e 100644 --- a/spring-cloud-contract-stub-runner/src/main/java/org/springframework/cloud/contract/stubrunner/messaging/stream/StubRunnerStreamConfiguration.java +++ b/spring-cloud-contract-stub-runner/src/main/java/org/springframework/cloud/contract/stubrunner/messaging/stream/StubRunnerStreamConfiguration.java @@ -132,7 +132,7 @@ public class StubRunnerStreamConfiguration { String destination) { Map bindings = bindingProperties(context); for (Map.Entry entry : bindings.entrySet()) { - if (entry.getValue().getDestination().equals(destination)) { + if (destination.equals(entry.getValue().getDestination())) { if (log.isDebugEnabled()) { log.debug("Found a channel named [{}] with destination [{}]", entry.getKey(), destination);