diff --git a/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/test/OutputDestination.java b/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/test/OutputDestination.java index 99da07381..53c7e1cd0 100644 --- a/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/test/OutputDestination.java +++ b/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/test/OutputDestination.java @@ -79,10 +79,10 @@ public class OutputDestination extends AbstractDestination { @SuppressWarnings("unchecked") @Override - void afterChannelIsSet(int channelIndex, String bidningName) { + void afterChannelIsSet(int channelIndex, String bindingName) { BlockingQueue> messageQueue = new LinkedTransferQueue<>(); - this.messageQueues.put(bidningName, messageQueue); - this.getChannelByName(bidningName).subscribe(message -> this.messageQueues.get(bidningName).offer((Message) message)); + this.messageQueues.put(bindingName, messageQueue); + this.getChannelByName(bindingName).subscribe(message -> this.messageQueues.get(bindingName).offer((Message) message)); } }