Add eventbus example.

basic-eventbus/pom.xml

@@ -0,0 +1,18 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+
+    <modelVersion>4.0.0</modelVersion>
+
+    <parent>
+        <artifactId>vertx3-examples</artifactId>
+        <groupId>nl.revolution</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>basic-eventbus</artifactId>
+
+    <name>Vert.x 3 examples : Basic event bus</name>
+
+</project>

basic-eventbus/src/main/java/nl/revolution/vertx3/eventbus/basic/EchoServiceVerticle.java

@@ -0,0 +1,27 @@
+package nl.revolution.vertx3.eventbus.basic;
+
+import io.vertx.core.AbstractVerticle;
+import io.vertx.core.json.JsonObject;
+import io.vertx.core.logging.Logger;
+import io.vertx.core.logging.LoggerFactory;
+
+public class EchoServiceVerticle extends AbstractVerticle {
+
+    public static final String ADDRESS = "echo-service";
+    private static final Logger LOG = LoggerFactory.getLogger(EchoServiceVerticle.class);
+
+    @Override
+    public void start() {
+        LOG.info("Starting echo-service");
+
+        vertx.eventBus().consumer(EchoServiceVerticle.ADDRESS, message -> {
+            JsonObject messageBody = (JsonObject)message.body();
+            LOG.info("Received message: " + messageBody);
+
+            messageBody.put("passedThrough", "echo-service");
+            LOG.info("Sending reply: " + messageBody);
+
+            message.reply(messageBody);
+        });
+    }
+}

basic-eventbus/src/main/java/nl/revolution/vertx3/eventbus/basic/VertxStarter.java

@@ -0,0 +1,22 @@
+package nl.revolution.vertx3.eventbus.basic;
+
+import io.vertx.core.*;
+import io.vertx.core.logging.LoggerFactory;
+import io.vertx.core.logging.SLF4JLogDelegateFactory;
+
+public class VertxStarter extends AbstractVerticle {
+
+    public static void main(String... args) {
+        System.setProperty(LoggerFactory.LOGGER_DELEGATE_FACTORY_CLASS_NAME, SLF4JLogDelegateFactory.class.getName());
+
+        VertxOptions options = new VertxOptions().setClustered(true).setClusterHost("localhost");
+
+        Vertx.clusteredVertx(options, resultHandler -> {
+            Vertx vertx = resultHandler.result();
+            vertx.deployVerticle(new EchoServiceVerticle());
+            vertx.deployVerticle(new WebVerticle());
+        });
+
+    }
+
+}

basic-eventbus/src/main/java/nl/revolution/vertx3/eventbus/basic/WebVerticle.java

@@ -0,0 +1,32 @@
+package nl.revolution.vertx3.eventbus.basic;
+
+import io.vertx.core.AbstractVerticle;
+import io.vertx.core.json.JsonObject;
+import io.vertx.core.logging.Logger;
+import io.vertx.core.logging.LoggerFactory;
+
+public class WebVerticle extends AbstractVerticle {
+
+    private static final Logger LOG = LoggerFactory.getLogger(WebVerticle.class);
+
+    @Override
+    public void start() {
+        LOG.info("Starting webVerticle");
+
+        vertx.createHttpServer().requestHandler(request -> {
+            JsonObject message = new JsonObject()
+                    .put("text", "Hello world!")
+                    .put("queryString", request.query());
+
+            LOG.info("Sending message: " + message);
+            vertx.eventBus().send(EchoServiceVerticle.ADDRESS, message, reply -> {
+
+                JsonObject replyBody = (JsonObject) reply.result().body();
+                LOG.info("Received reply: " + replyBody);
+
+                request.response().end(replyBody.encodePrettily());
+            });
+
+        }).listen(8080);
+    }
+}

logback.xml

@@ -0,0 +1,19 @@
+<configuration>
+    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender" level="INFO">
+        <encoder>
+            <pattern>[%-5level] %logger{15} - %msg%n</pattern>
+        </encoder>
+    </appender>
+
+    <logger name="io.vertx" level="INFO">
+        <appender-ref ref="STDOUT"/>
+    </logger>
+    <logger name="com.hazelcast" level="ERROR">
+        <appender-ref ref="STDOUT"/>
+    </logger>
+    <logger name="io.netty.util.internal.PlatformDependent" level="ERROR">
+        <appender-ref ref="STDOUT"/>
+    </logger>
+    <root level="INFO">
+    </root>
+</configuration>

pom.xml

@@ -41,6 +41,12 @@
             <artifactId>groovy-all</artifactId>
             <version>2.3.7</version>
         </dependency>
+        <dependency>
+            <groupId>ch.qos.logback</groupId>
+            <artifactId>logback-classic</artifactId>
+            <version>1.1.5</version>
+            <scope>runtime</scope>
+        </dependency>
     </dependencies>
 
     <build>
@@ -74,6 +80,7 @@
     <modules>
         <module>helloworld</module>
         <module>sockjs-eventbus</module>
+        <module>basic-eventbus</module>
     </modules>
 
 </project>

sockjs-eventbus/src/main/java/nl/revolution/vertx3/eventbus/SimpleVerticle.java → sockjs-eventbus/src/main/java/nl/revolution/vertx3/eventbus/sockjs/SimpleVerticle.java

@@ -1,4 +1,4 @@
-package nl.revolution.vertx3.eventbus;
+package nl.revolution.vertx3.eventbus.sockjs;
 
 import io.vertx.core.AbstractVerticle;
 

sockjs-eventbus/src/main/java/nl/revolution/vertx3/eventbus/SockJSEventBusBridge.java → sockjs-eventbus/src/main/java/nl/revolution/vertx3/eventbus/sockjs/SockJSEventBusBridge.java

@@ -1,4 +1,4 @@
-package nl.revolution.vertx3.eventbus;
+package nl.revolution.vertx3.eventbus.sockjs;
 
 import io.vertx.core.AbstractVerticle;
 import io.vertx.core.logging.Logger;

sockjs-eventbus/src/main/java/nl/revolution/vertx3/eventbus/VertxStarter.java → sockjs-eventbus/src/main/java/nl/revolution/vertx3/eventbus/sockjs/VertxStarter.java

@@ -1,10 +1,14 @@
-package nl.revolution.vertx3.eventbus;
+package nl.revolution.vertx3.eventbus.sockjs;
 
 import io.vertx.core.*;
+import io.vertx.core.logging.LoggerFactory;
+import io.vertx.core.logging.SLF4JLogDelegateFactory;
 
 public class VertxStarter extends AbstractVerticle {
 
     public static void main(String... args) {
+        System.setProperty(LoggerFactory.LOGGER_DELEGATE_FACTORY_CLASS_NAME, SLF4JLogDelegateFactory.class.getName());
+
         VertxOptions options = new VertxOptions().setClustered(true).setClusterHost("localhost");
 
         Vertx.clusteredVertx(options, resultHandler -> {