spring-cloud-stream-demo

spring-cloud-stream-demo copied to clipboard

@benwilcock : I build and executed with the profile `rabbit` but still, the `kafka` binder gets created by `DefaultBinderFactory`. **Application start up log:** ``` /home/raj/.jdks/openjdk-16.0.2/bin/java -XX:TieredStopAtLevel=1 -noverify -Dspring.profiles.active=rabbit -Dspring.output.ansi.enabled=always -javaagent:/home/raj/.local/share/JetBrains/Toolbox/apps/IDEA-U/ch-1/212.4746.92/lib/idea_rt.jar=38079:/home/raj/.local/share/JetBrains/Toolbox/apps/IDEA-U/ch-1/212.4746.92/bin...

RRSR

anguillanneuf

https://github.com/benwilcock/spring-cloud-stream-demo/blob/fbdadd1b8d30c5f3d42c18e03835474aaa052f29/loancheck/src/main/java/io/pivotal/loancheck/Loan.java#L34-L38 https://github.com/benwilcock/spring-cloud-stream-demo/blob/fbdadd1b8d30c5f3d42c18e03835474aaa052f29/loansource/src/main/java/io/pivotal/loansource/Loan.java#L37-L46 Instead of all checking against all of the `Statuses` enum values, we can easily check the existence of the status with the help of `Statuses.valueOf` which throws `IllegalArgumentException`...

fractalliter

Adding test cases to cover the business logic and also an example of testing stream applications would be a huge plus for this repository

fractalliter