Files

Spring Operator 6068a20f29 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://maven.apache.org/xsd/maven-4.0.0.xsd with 19 occurrences migrated to:
  https://maven.apache.org/xsd/maven-4.0.0.xsd ([https](https://maven.apache.org/xsd/maven-4.0.0.xsd) result 200).
* http://www.apache.org/licenses/LICENSE-2.0 with 6 occurrences migrated to:
  https://www.apache.org/licenses/LICENSE-2.0 ([https](https://www.apache.org/licenses/LICENSE-2.0) result 200).
* http://www.spring.io with 1 occurrences migrated to:
  https://www.spring.io ([https](https://www.spring.io) result 301).
* http://repo.spring.io/libs-milestone-local with 5 occurrences migrated to:
  https://repo.spring.io/libs-milestone-local ([https](https://repo.spring.io/libs-milestone-local) result 302).
* http://repo.spring.io/libs-release-local with 1 occurrences migrated to:
  https://repo.spring.io/libs-release-local ([https](https://repo.spring.io/libs-release-local) result 302).
* http://repo.spring.io/libs-snapshot-local with 2 occurrences migrated to:
  https://repo.spring.io/libs-snapshot-local ([https](https://repo.spring.io/libs-snapshot-local) result 302).
* http://repo.spring.io/release with 1 occurrences migrated to:
  https://repo.spring.io/release ([https](https://repo.spring.io/release) result 302).

# Ignored
These URLs were intentionally ignored.

* http://maven.apache.org/POM/4.0.0 with 38 occurrences
* http://www.w3.org/2001/XMLSchema-instance with 19 occurrences

2019-03-21 15:20:21 -04:00

src

URL Cleanup

2019-03-21 15:17:39 -04:00

pom.xml

URL Cleanup

2019-03-21 15:20:21 -04:00

README.md

Add StreamListener Usage Sample

2016-03-30 11:46:52 -04:00

README.md

Spring Cloud Stream Stream Listener Sample

In this Spring Cloud Stream sample, the application shows how to use StreamListener support to enable message mapping and automatic type conversion.

Requirements

To run this sample, you will need to have installed:

Java 8 or Above

This example requires Redis to be running on localhost.

Code Tour

This sample is a Spring Boot application that bundles multiple application together to showcase how to use StreamListener to enable message mapping and automatic type conversion.

TypeConversionApplication - the Spring Boot Main Application
Converters - the class that holds the required custom message converter that converts POJO of type Foo to Bar
SampleSource - the app that generates a message of type Foo that has the value hi
SampleTransformer - the app that has the message handler method annotated with @StreamListener to map the process input channel to a type Bar. This will make sure to apply FooToBarConverter automatically without having a need to specify content-type for the channel explicitly. The annotation @SendTo on the message handler method will make sure to send the output to the provided output channel.
SampleSink - the app that receives the converted message from the transformer output.

Please note that the applications (SampleSource, SampleTransformer and SampleSink) are bundled inside the single application for the demo purpose only. In practice, these applications run on their own. If at all they need to be bundled together, the best practice is to use AggregateApplicationBuilder. Refer the sample double for more info on aggregate application.

Building with Maven

Build the sample by executing:

>$ mvn clean package

Running the Sample

To start the source module execute the following:

>$ java -jar target/spring-cloud-stream-sample-stream-listener-1.0.0.BUILD-SNAPSHOT-exec.jar