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

GH-1770 additional fixes on BindingService lifecycle

Browse Source
This commit is contained in:
Oleg Zhurakousky
2019-08-07 10:46:33 +02:00
parent c35e362d10
commit 10682c6805
1 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/AbstractBindingLifecycle.java
View File

@@ -18,6 +18,8 @@ package org.springframework.cloud.stream.binding;
import java.util.Map;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.context.SmartLifecycle;
/**
@@ -34,6 +36,9 @@ abstract class AbstractBindingLifecycle implements SmartLifecycle {
private final Map<String, Bindable> bindables;
@Autowired
private ApplicationContext context;
private volatile boolean running;
AbstractBindingLifecycle(BindingService bindingService,
@@ -45,6 +50,10 @@ abstract class AbstractBindingLifecycle implements SmartLifecycle {
@Override
public void start() {
if (!this.running) {
if (this.context != null) {
this.bindables.putAll(context.getBeansOfType(Bindable.class));
}
this.bindables.values().forEach(this::doStartWithBindable);
this.running = true;
}
@@ -53,6 +62,9 @@ abstract class AbstractBindingLifecycle implements SmartLifecycle {
@Override
public void stop() {
if (this.running) {
if (this.context != null) {
this.bindables.putAll(context.getBeansOfType(Bindable.class));
}
this.bindables.values().forEach(this::doStopWithBindable);
this.running = false;
}