SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix typo

Browse Source
This commit is contained in:
Oleg Zhurakousky
2020-02-28 04:48:07 +01:00
parent 0debb8d64f
commit e52266c01f
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/test/OutputDestination.java
View File

@@ -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<Message<byte[]>> messageQueue = new LinkedTransferQueue<>();
this.messageQueues.put(bidningName, messageQueue);
this.getChannelByName(bidningName).subscribe(message -> this.messageQueues.get(bidningName).offer((Message<byte[]>) message));
this.messageQueues.put(bindingName, messageQueue);
this.getChannelByName(bindingName).subscribe(message -> this.messageQueues.get(bindingName).offer((Message<byte[]>) message));
}
}