Spring Cloud Stream Past, Present, and Future.

This repository contains the projects that are demoed during the breakout discussion. These projects are meant to provide a quick start for experimenting with various features of Spring Cloud Function and Spring Cloud Stream All samples use RabbitMQ as the Messaging Framework.

Projects

Creek Functions

A collection of functions that can be used with the Producer, Function, and Consumer portions demonstration

Creek Producer

A boot application that will retrieve the creek data from the USGS for a selected set of creeks and send it to the specified destination (rabbit exchange).

Creek Transformer

A boot application transforms USGS Water Information System data to CreekMeasurements s.

Creek Consumer

A boot application that will consume the CreekMeasurement s from the stream and either log or send an sms message containing information on the creeks that are safe-ish to kayak from the provided data.

Note	Do not determine if it is safe to kayak a stream, river, or any body of water based soley on the this analysis. It is for demonstration purposes only.

Creek MeasurementRepository Consumer

A boot application that will consume the CreekMeasurement s from the stream and store them into a repository.

Stream POC

Single App POC that is used as a basic outline for the demo.

Figure 1. Process Flow

Running the full demo

Start the consumers

Send Creek Report via SMS

This will send the report to the specified phone number . You must also provide the sms key.

java -jar creekconsumer/target/creekconsumer-0.0.1-SNAPSHOT.jar  --spring.cloud.function.definition='generateReport|sms' --spring.cloud.stream.function.bindings.generateReportsms-in-0=input --spring.cloud.stream.bindings.input.group=sms --io.spring.smsKey=yourkey --io.spring.phoneNumber=+1XXXXXXXXXX

Write Creek Report to console

This will write the report to the console.

java -jar creekconsumer/target/creekconsumer-0.0.1-SNAPSHOT.jar

Start the transformer

java -jar creektransformer/target/creektransformer-0.0.1-SNAPSHOT.jar

Start the Producer

java -jar creekproducer/targecreekproducer-0.0.1-SNAPSHOT.jar

eydunn / scstdn2022 Goto Github PK

scstdn2022's Introduction