INT-393: destroy() on DefaultMessageBus will automatically attempt to stop it, if that didn't happen already.
This commit is contained in:
@@ -331,6 +331,7 @@ public class DefaultMessageBus implements MessageBus, ApplicationContextAware, A
|
||||
}
|
||||
|
||||
public void destroy() throws Exception {
|
||||
this.stop();
|
||||
if (this.taskScheduler instanceof DisposableBean) {
|
||||
((DisposableBean) this.taskScheduler).destroy();
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user