MessageBus interface no longer extends DisposableBean. Now, the DefaultMessageBus implementation implements DisposableBean directly.
This commit is contained in:
@@ -61,7 +61,7 @@ import org.springframework.util.Assert;
|
||||
* @author Mark Fisher
|
||||
* @author Marius Bogoevici
|
||||
*/
|
||||
public class DefaultMessageBus implements MessageBus, ApplicationContextAware, ApplicationListener {
|
||||
public class DefaultMessageBus implements MessageBus, ApplicationContextAware, ApplicationListener, DisposableBean {
|
||||
|
||||
private static final int DEFAULT_DISPATCHER_POOL_SIZE = 10;
|
||||
|
||||
|
||||
@@ -16,7 +16,6 @@
|
||||
|
||||
package org.springframework.integration.bus;
|
||||
|
||||
import org.springframework.beans.factory.DisposableBean;
|
||||
import org.springframework.context.Lifecycle;
|
||||
import org.springframework.integration.channel.ChannelRegistry;
|
||||
import org.springframework.integration.channel.MessageChannel;
|
||||
@@ -27,7 +26,7 @@ import org.springframework.integration.endpoint.EndpointRegistry;
|
||||
*
|
||||
* @author Mark Fisher
|
||||
*/
|
||||
public interface MessageBus extends ChannelRegistry, EndpointRegistry, Lifecycle, DisposableBean {
|
||||
public interface MessageBus extends ChannelRegistry, EndpointRegistry, Lifecycle {
|
||||
|
||||
MessageChannel getErrorChannel();
|
||||
|
||||
|
||||
Reference in New Issue
Block a user