This sample demonstrates basic functionality of bridging Spring Integration TCP Adapters with Spring Integration AMQP Adapters.
Once the application is started, you enter some text in a telnet session and the data is written to an AMQP queue, which is then consumed and the result echoed to a netcat session.
telnet->tcp-inbound-adapter->rabbit->tcp-outbound-adapter->netcat
telnet: http://en.wikipedia.org/wiki/Telnet netcat: http://en.wikipedia.org/wiki/Netcat
In order to run the example you will need a running instance of RabbitMQ. A local installation with just the basic defaults will be sufficient. Please visit: http://www.rabbitmq.com/install.html for detailed installation procedures.
In a terminal window start netcat, listening on port 11112:
netcat -l -p 11112
If you imported the example into your IDE, you can just run class org.springframework.integration.samples.tcpamqp.Main. For example in SpringSource Tool Suite (STS) do:
- Right-click on Main class --> Run As --> Java Application
Alternatively, you can start the sample from the command line (Gradle Application Plugin):
$ gradlew :tcp-amqp:run
In another terminal window, telnet to localhost:11111
telnet localhost 11111
Data typed into the telnet terminal will be echoed to the netcat terminal, via the rabbit queue.
- spring-integration-core
- spring-integration-amqp
- spring-integration-tcp
For further help please take a look at the Spring Integration documentation:
Some further resources:
- RabbitMQ - http://www.rabbitmq.com/
- Spring AMQP - http://www.springsource.org/spring-amqp