Spring Integration manually start/stop channel adapter via control bus

Question

Is there anyway to manually start/init a channel adapter? I have two pairs of inbound/outbound adapters in my context.xml and would like to decide at runtime which one of them I want to get started. EDIT: The concrete scenario: I have a client, that can be configured at runtime to be an mqtt publisher or subscriber. My context.xml looks like this: ```

Accepted Answer

Set `autoStartup="false"` and either directly `start()`/`stop()` them, or use a `` (send `@myAdapter.start()`). Getting a direct reference (autowire etc), depends on the endpoint type. If it's a polled endpoint, inject a `SourcePollingChannelAdapter`; message-driven adapters vary, but generally are a `MessageProducerSupport` or `MessagingGatewaySupport`. EDIT: Read about the control-bus here. Give the inbound adapter an `id` attribute. Add `` Add `` Create a gateway interface ``` public interface Controller { void control(String command); } ``` `@Autowire` the gateway (or use `context.getBean(Controller.class)`). Then, when you are ready to start the adapter, call, e.g. `gateway.control("@mqttOut.start()")`. You don't need `auto-startup="false"` on the outbound adapters. However, for a simple use case like this, you might want to investigate using Spring profiles instead (put the adapters in a profile and enable the profile at runtime.

Spring Integration manually start/stop channel adapter via control bus

Solution

Problem