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