Files
spring-integration-samples/basic/tcp-amqp
Spring Operator f160a1c766 URL Cleanup
This commit updates URLs to prefer the https protocol. Redirects are not followed to avoid accidentally expanding intentionally shortened URLs (i.e. if using a URL shortener).

# Fixed URLs

## Fixed Success
These URLs were switched to an https URL with a 2xx status. While the status was successful, your review is still recommended.

* [ ] http://www.apache.org/licenses/LICENSE-2.0 with 292 occurrences migrated to:
  https://www.apache.org/licenses/LICENSE-2.0 ([https](https://www.apache.org/licenses/LICENSE-2.0) result 200).
2019-03-22 14:54:39 -04:00
..
2019-03-22 14:54:39 -04:00
2019-03-16 12:52:58 -04:00

Spring Integration - TCP-AMQP Sample

Overview

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.

How to Run the Sample

Start netcat

In a terminal window start netcat, listening on port 11112:

netcat -l -p 11112

Start the Application

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

Run Telnet

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.

Used Spring Integration components

Spring Integration Modules (Maven dependencies)

  • spring-integration-core
  • spring-integration-amqp
  • spring-integration-tcp

Resources

For further help please take a look at the Spring Integration documentation:

Some further resources: