Add README files with the instructions

Author: cescoffier

.gitignore

@@ -40,6 +40,8 @@ javadoc/
 build/
 lib/
 
+*.idea/
+*.iml
 
 *.pbxuser
 !default.pbxuser

README.md

@@ -0,0 +1,16 @@
+# Reactive Microservices in Java
+
+This repository contains the source code from the _Reactive Microsevices in Java - Asynchronous, Elastic, Resilience Applications_ book. It contains the source code shown in the book as well as other examples.
+
+
+The repository is structured as follows:
+
+
+* [Hello Vert.x - the Vert.x Hello World](hello-vertx)
+* [Packaging Examples - build Vert.x application using any tool](packaging-examples)
+* [Reactive Programming (RX Java 1) examples](reactive-programming)
+* [Microservices - the different microservices built in the book](microservices)
+* [OpenShift - the microservices built in the book running on top of OpenShift](openshift)
+
+
+Each directory contains the instructions to build and run the _module_. 

microservices/README.md

@@ -0,0 +1,27 @@
+# Microservices
+
+This directory contains the different microservices developed in the book. In order of appearance:
+
+* [Hello Microservice - HTTP](hello-microservice-http)
+* [Hello Consumer Microservice - HTTP](hello-consumer-microservice-http)
+* [Hello Microservice - Event Bus](hello-microservice-message)
+* [Hello Consumer Microservice - Event Bus](hello-consumer-microservice-message)
+* [Hello Microservice with faults](hello-microservice-faulty)
+* [Hello Consumer Microservice with timeout and reply](hello-consumer-microservice-timeout)
+
+The _-consumer_ projects invoke the corresponding services:
+
+* The [Hello Consumer Microservice - HTTP](hello-consumer-microservice-http) invokes the [Hello Microservice - HTTP](hello-microservice-http).
+* The [Hello Consumer Microservice - Event Bus](hello-consumer-microservice-message) invokes the [Hello Microservice - Event Bus](hello-microservice-message).
+* The [Hello Consumer Microservice with timeout and reply](hello-consumer-microservice-timeout) invokes the [Hello Microservice with faults](hello-microservice-faulty).
+   
+Be aware to run both at the same time.  
+ 
+Each project is built with Apache Maven:
+ 
+```
+cd $DIRECTORY
+mvn clean package
+```
+ 
+Each project contains a `README` with running instructions. 

microservices/hello-consumer-microservice-http/README.md

@@ -0,0 +1,26 @@
+# Hello Consumer Microservice - HTTP
+
+This directory contains the source code of the _Hello_ microservice consumer using HTTP interactions. It invokes the [Hello microservice - HTTP](../hello-microservice-http).
+
+## Running in development mode
+ 
+ 
+```
+mvn compile vertx:run
+```
+
+Hit `CTRL+C` to stop the execution and reloading.
+
+
+## Packaging
+      
+```
+mvn clean package
+```
+ 
+## Execution using the application package
+ 
+```
+java -jar target/hello-consumer-microservice-http-1.0-SNAPSHOT.jar 
+``` 
+ 

microservices/hello-consumer-microservice-message/README.md

@@ -0,0 +1,25 @@
+# Hello Consumer Microservice - Event Bus
+
+This directory contains the source code of the _Hello_ microservice consumer using event bus (message) interactions. It invokes the [Hello microservice - Event Bus](../hello-microservice-message).
+
+## Running in development mode
+  
+```
+mvn compile vertx:run -Dvertx.runArgs="-cluster -Djava.net.preferIPv4Stack=true"
+```
+
+Hit `CTRL+C` to stop the execution and reloading. 
+
+
+## Packaging
+      
+```
+mvn clean package
+```
+ 
+## Execution using the application package
+ 
+```
+java -jar target/hello-consumer-microservice-message-1.0-SNAPSHOT.jar -cluster -Djava.net.preferIPv4Stack=true
+``` 
+ 

microservices/hello-consumer-microservice-timeout/README.md

@@ -0,0 +1,25 @@
+# Hello Consumer Microservice - Event Bus with timeout and reply
+
+This directory contains the source code of the _Hello_ microservice consumer using event bus (message) interactions. It implements a simple fault-tolerance strategy using timeouts and retries. It invokes the [Hello microservice - Event Bus - Faulty](../hello-microservice-faulty).
+
+## Running in development mode
+  
+```
+mvn compile vertx:run -Dvertx.runArgs="-cluster -Djava.net.preferIPv4Stack=true"
+```
+
+Hit `CTRL+C` to stop the execution and reloading. 
+
+
+## Packaging
+      
+```
+mvn clean package
+```
+ 
+## Execution using the application package
+ 
+```
+java -jar target/hello-consumer-microservice-message-1.0-SNAPSHOT.jar -cluster -Djava.net.preferIPv4Stack=true
+``` 
+ 

microservices/hello-consumer-microservice-timeout/src/main/java/io/vertx/book/message/HelloConsumerMicroservice.java

@@ -19,13 +19,19 @@ public void start() {
                         <JsonObject>rxSend("hello", "Luke")
                         .subscribeOn(RxHelper.scheduler(vertx))
                         .timeout(3, TimeUnit.SECONDS)
-                        .retry()
+                        .retry((i, t) -> {
+                            System.out.println("Retrying... because of " + t.getMessage());
+                            return true;
+                        })
                         .map(Message::body);
                     Single<JsonObject> obs2 = vertx.eventBus().
                         <JsonObject>rxSend("hello", "Leia")
                         .subscribeOn(RxHelper.scheduler(vertx))
                         .timeout(3, TimeUnit.SECONDS)
-                        .retry()
+                        .retry((i, t) -> {
+                            System.out.println("Retrying... because of " + t.getMessage());
+                            return true;
+                        })
                         .map(Message::body);
 
                     Single

microservices/hello-microservice-faulty/README.md

@@ -0,0 +1,25 @@
+# Hello Microservice - Event Bus with faults
+
+This directory contains the source code of the _Hello_ microservice using event bus (message) interactions with with injected fault (on purpose).
+
+## Running in development mode
+  
+```
+mvn compile vertx:run -Dvertx.runArgs="-cluster -Djava.net.preferIPv4Stack=true"
+```
+
+Hit `CTRL+C` to stop the execution and reloading. 
+
+
+## Packaging
+      
+```
+mvn clean package
+```
+ 
+## Execution using the application package
+ 
+```
+java -jar target/hello-microservice-message-1.0-SNAPSHOT.jar -cluster -Djava.net.preferIPv4Stack=true         
+``` 
+ 

microservices/hello-microservice-http/README.md

@@ -0,0 +1,26 @@
+# Hello Microservice - HTTP
+
+This directory contains the source code of the _Hello_ microservice using HTTP interactions.
+
+## Running in development mode
+ 
+ 
+```
+mvn compile vertx:run
+```
+
+Hit `CTRL+C` to stop the execution and reloading.
+
+
+## Packaging
+      
+```
+mvn clean package
+```
+ 
+## Execution using the application package
+ 
+```
+java -jar target/hello-microservice-http-1.0-SNAPSHOT.jar 
+``` 
+ 

microservices/hello-microservice-message/README.md

@@ -0,0 +1,25 @@
+# Hello Microservice - Event Bus
+
+This directory contains the source code of the _Hello_ microservice using event bus (message) interactions.
+
+## Running in development mode
+  
+```
+mvn compile vertx:run -Dvertx.runArgs="-cluster -Djava.net.preferIPv4Stack=true"
+```
+
+Hit `CTRL+C` to stop the execution and reloading. 
+
+
+## Packaging
+      
+```
+mvn clean package
+```
+ 
+## Execution using the application package
+ 
+```
+java -jar target/hello-microservice-message-1.0-SNAPSHOT.jar -cluster -Djava.net.preferIPv4Stack=true
+``` 
+