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

Make SingleChannelBindable more generic

Browse Source 
- Use `MessageChannel` instead of `PublishSubscribableChannel`
 - Remove error channel references
This commit is contained in:
Ilayaperumal Gopinathan
2016-03-02 11:18:39 +05:30
parent d7c73fff00
commit e77bcc3e4c
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/SingleChannelBindable.java
View File

@@ -20,7 +20,7 @@ import java.util.Collections;
import java.util.HashSet;
import java.util.Set;
import org.springframework.integration.channel.PublishSubscribeChannel;
import org.springframework.messaging.MessageChannel;
/**
* A {@link Bindable} component that wraps a generic channel. Useful for binding channels outside the
@@ -33,16 +33,16 @@ public class SingleChannelBindable extends BindableAdapter {
private final String name;
private final PublishSubscribeChannel errorChannel;
private final MessageChannel messageChannel;
public SingleChannelBindable(String name, PublishSubscribeChannel errorChannel) {
public SingleChannelBindable(String name, MessageChannel messageChannel) {
this.name = name;
this.errorChannel = errorChannel;
this.messageChannel = messageChannel;
}
@Override
public void bindOutputs(ChannelBindingService adapter) {
adapter.bindProducer(errorChannel, name);
adapter.bindProducer(messageChannel, name);
}
@Override