reactive-streams: need to fix sb component scan and rest example

Author: smongiar

reactive-streams/readme.adoc

@@ -2,14 +2,16 @@
 
 This example shows some possible usages of the Camel reactive streams component.
 
+=== Introduction
+
 The following sample routes are started together in a spring-boot application (all routes use `reactor-core` as external reactive framework):
 
 - **examples.basic.camel-to-reactor**: shows how data generated by Camel route can be consumed by a reactive application.
 - **examples.basic.camel-to-reactor-in-out**: shows how Camel data can be processed by a reactive library and return back to Camel to complete the flow.
 - **examples.basic.reactor-to-camel**: shows how data generated by a reactive application can be consumed by a Camel route.
 - **examples.basic.reactor-to-camel-in-out**: shows how data generated by a reactive application can can be processed by Camel and return back to the library to complete the flow.
 - **examples.client-api.rest**: shows how a rest service can be defined using the reactive streams client API only.
-- **examples.client-api.workflow**: shows how multiple Camel endpoints can be used into a reactive streams processing flow.
+- **examples.client-api.workflow**: shows how multiple Camel endpoints can be used into a reactive streams processing flow. It reads from an "input" named directory, filtering files containing "camel" as text as criteria before sending to an external system
 - **examples.others.rest**: shows how `Publisher` classes can be used as parameters or return types in beans.
 
 All routes are enabled by default, but they can be switched off by changing the `src/main/resources/application.yml` file.
@@ -21,6 +23,29 @@ You can run this example using
 
     mvn spring-boot:run
 
+In some cases the camel reactor streams routes can be verified during execution of application, but we can also verify the functionality of reactor subscriptions through some defined Rest APIs.
+
+Rest API to retrieve informations about orders:
+
+http://localhost:8080/camel/orders/1
+http://localhost:8080/camel/orders/2
+
+If we call:
+
+----
+curl http://localhost:8080/camel/orders/3
+----
+
+We should receive a message "Not Found" as result of Flux Reactor coded behaviour
+
+Rest API for reactor managed calculator:
+
+----
+curl http://localhost:8080/camel/sum/23/31
+----
+
+Let verify "54" as result
+
 === Help and contributions
 
 If you hit any problem using Camel or have some feedback, then please

reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/ClientAPIWorkflowExample.java

@@ -80,7 +80,7 @@ public void configure() throws Exception {
                     .log("Content marshalled to string: ${body}");
 
             from("direct:send")
-                    .log("Sending the file to an external system (simulation)");
+                    .log("Sending the file to an external system (simulation) with text: ${body}");
 
         }
 

reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/RestExample.java

@@ -70,8 +70,8 @@ public void configure() throws Exception {
                     .to("direct:sum");
 
             from("direct:sum")
-                    .setHeader("num1").simple("${headerAs(num1,Long)}")
-                    .setHeader("num2").simple("${headerAs(num2,Long)}")
+                    .setHeader("num1").simple("${header.num1}",Long.class)
+                    .setHeader("num2").simple("${header.num2}",Long.class)
                     .bean("calculator", "sum")
                     .process(new UnwrapStreamProcessor())
                     .setBody().simple("The result is: ${body}");

reactive-streams/src/main/java/org/apache/camel/example/reactive/streams/app/ReactiveStreamsSpringBootApp.java

@@ -17,10 +17,12 @@
 package org.apache.camel.example.reactive.streams.app;
 
 import org.springframework.boot.SpringApplication;
+import org.springframework.context.annotation.ComponentScan;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 
 //CHECKSTYLE:OFF
 @SpringBootApplication
+@ComponentScan(basePackages = "org.apache.camel.example.reactive.streams")
 public class ReactiveStreamsSpringBootApp {
 
     public static void main(String[] args) {