Skip to content

Commit 1d9ab7b

Browse files
committed
GH-3166 Fix double binding
1 parent 798aad5 commit 1d9ab7b

1 file changed

Lines changed: 4 additions & 12 deletions

File tree

core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/BindingsLifecycleController.java

Lines changed: 4 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -278,18 +278,10 @@ private void defineBinding(BindableFunctionProxyFactory bindingProxyFactory) {
278278
bindingProxyFactory.setApplicationContext(this.applicationContext);
279279
bindingProxyFactory.afterPropertiesSet();
280280

281-
BindingService bindingService = this.applicationContext.getBean(BindingService.class);
282-
283-
AbstractBindingLifecycle bindingLifecycle;
284-
if (bindingProxyFactory.getInputs().size() > 0) {
285-
bindingProxyFactory.createAndBindInputs(bindingService);
286-
bindingLifecycle = this.applicationContext.getBean(InputBindingLifecycle.class);
287-
}
288-
else {
289-
bindingProxyFactory.createAndBindOutputs(bindingService);
290-
bindingLifecycle = this.applicationContext.getBean(OutputBindingLifecycle.class);
291-
}
292-
281+
AbstractBindingLifecycle bindingLifecycle = (bindingProxyFactory.getInputs().size() > 0)
282+
? this.applicationContext.getBean(InputBindingLifecycle.class)
283+
: this.applicationContext.getBean(OutputBindingLifecycle.class);
284+
293285
bindingLifecycle.startBindable(bindingProxyFactory);
294286
}
295287

0 commit comments

Comments
 (0)