设置
autoStartup="false"和直接
start()/ stop()它们,或使用
<control-bus/>(发送
@myAdapter.start())。
获取直接参考(自动装配等)取决于端点类型。如果是轮询的端点,请插入
SourcePollingChannelAdapter;。消息驱动的适配器有所不同,但通常为
MessageProducerSupport或
MessagingGatewaySupport。
编辑:
在此处了解有关控制总线的信息。
给入站适配器一个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配置文件(将适配器放入配置文件中并在运行时启用配置文件。



