您好, 欢迎来到 !    登录 | 注册 | | 设为首页 | 收藏本站

Spring Integration通过控制总线手动启动/停止通道适配器

Spring Integration通过控制总线手动启动/停止通道适配器

设置autoStartup="false"和直接start()/ stop()它们,或使用<control-bus/>(发送@myAdapter.start())。

获取直接参考(自动装配等)取决于端点类型。如果是轮询的端点,请插入SourcePollingChannelAdapter;。消息驱动的适配器有所不同,但通常为MessageProducerSupportMessagingGatewaySupport

编辑:

在此处了解有关控制总线的信息。

给入站适配器一个id属性

<control-bus input-channel="control"/>

<int:gateway service-interface="foo.Controller" default-request-channel="control"/>

创建一个网关接口

public interface Controller {

    void control(String command);

}

@Autowire网关(或使用context.getBean(Controller.class))。

然后,当你准备启动适配器时,请调用gateway.control(“@mqttOut.start()”)。

你不需要auto-startup="false"出站适配器。

但是,对于像这样的简单用例,你可能想研究使用Spring配置文件(将适配器放入配置文件中并在运行时启用配置文件

Java 2022/1/1 18:18:11 有505人围观

撰写回答


你尚未登录,登录后可以

和开发者交流问题的细节

关注并接收问题和回答的更新提醒

参与内容的编辑和改进,让解决方法与时俱进

请先登录

推荐问题


联系我
置顶