Spring Integration manually start/stop channel adapter via control bus

by

Set autoStartup="false" and either directly start()/stop() them, or use a <control-bus/> (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 <control-bus input-channel="control"/>

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

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.

More Related Contents:

  1. How to configure port for a Spring Boot application
  2. Deploying Spring 5.x on Tomcat 10.x
  3. How do I use annotations to define different types of relationships in Hibernate 4 and Spring?
  4. Spring MVC – How to get all request params in a map in Spring controller?
  5. Spring Data JPA – ZonedDateTime format for json serialization
  6. Why does my Spring Boot App always shutdown immediately after starting?
  7. How to set base url for rest in spring boot?
  8. @Valid annotation is not validating the list of child objects
  9. Can I combine a @Query definition with a Specification in a Spring Data JPA repository method?
  10. How to parameterize @Scheduled(fixedDelay) with Spring 3.0 expression language?
  11. Unable to complete the scan for annotations for web application [/app] due to a StackOverflowError
  12. Spring JpaRepository – Detach and Attach entity
  13. Run Spring-boot’s main using IDE
  14. How to enforce ACCEPT_SINGLE_VALUE_AS_ARRAY in jackson’s deserialization process using annotation
  15. spring mvc not returning json content – error 406
  16. Spring Boot Externalizing properties not working
  17. How do I properly do a background thread when using Spring Data and Hibernate?
  18. Which maven dependencies to include for spring 3.0?
  19. Securing Spring Boot API with API key and secret
  20. Getting a ‘No thread-bound request found’ error from spring in my web app
  21. How to store @Query sql in external file for CrudRepository?
  22. Differences between requires_new and nested propagation in Spring transactions
  23. Provide time zone to Spring @Scheduled?
  24. How to show localization messages with parameters in Spring 3 / Thymeleaf
  25. How to enable LockModeType.PESSIMISTIC_WRITE when looking up entities with Spring Data JPA?
  26. Spring 4.x/3.x (Web MVC) REST API and JSON2 Post requests, how to get it right once for all?
  27. How to use Spring Boot with MySQL database and JPA?
  28. How to instrument / advice a Spring Data (JPA) repository?
  29. How I create an error handler (404, 500…) in Spring Boot/MVC
  30. Can I replace a Spring bean definition at runtime?

Leave a Comment