Skip to content
This repository

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP

Spring Integration Controlbus controlling JMS inbound channel adaptor

branch: master

Fetching latest commit…

Octocat-spinner-32-eaf2f5

Cannot retrieve the latest commit at this time

Octocat-spinner-32 src
Octocat-spinner-32 README.md
Octocat-spinner-32 pom.xml
README.md

Spring Integration Controlbus controlling JMS inbound channel adapter

In this project, I will demo Control Bus capability of Spring Integration, where in we can stop or start JMS inbound channel adapters runtime as an alternative to MBean.

To quickly see how it works,

Just test the subscriber architecture In this project, I will demo the use of Control Bus-Enterprise Integration Pattern using Spring Integration. To quickly see how it works,

  • Download activemq
  • Start the activemq by executing /bin/activemq.bat
  • Create Queues called "MyQueue" and "ControlBusQueue"
  • Get the latest code
  • Import the maven project into STS IDE, and "Run at Server"
  • Now put a message on to "MyQueue", you see the debug message on both the service activators where the messages are published
  • If you want to stop the "inbound channel adapter" to listen to the Queue, put a message "@inboundAdapter.stop()" on "ControlBusQueue". To test it, put a message on to "MyQueue" the message is not published
  • To start the adapter, again put a message "@inboundAdapter.start()", the earlier message is consumed.

  • to JUnit test this, run "mvn test"

Refer this blog for more details on the above flow.

Feel free to modify this code and use it for your need.

Something went wrong with that request. Please try again.