commit c3625ea1531b54c9a77d777f9b55aee3756967c5
author Christian Schneider <chris@die-schneider.net> Mon Jun 26 18:07:33 2017 +0200
committer Christian Schneider <chris@die-schneider.net> Mon Jun 26 18:07:33 2017 +0200
tree 78e24d2aaecadbdc298d2c1506b59d4608a9e93a
parent 4d56f41f6a90634f0fa5eb7cb3f703c8f75c4a0a

Cleanup

reactortest/src/main/java/reactortest/ExampleEventAdmin.java

diff --git a/reactortest/src/main/java/reactortest/ExampleComponent2.java b/reactortest/src/main/java/reactortest/ExampleEventAdmin.java
similarity index 60%
rename from reactortest/src/main/java/reactortest/ExampleComponent2.java
rename to reactortest/src/main/java/reactortest/ExampleEventAdmin.java
index 6b2fb5b..3291758 100644
--- a/reactortest/src/main/java/reactortest/ExampleComponent2.java
+++ b/reactortest/src/main/java/reactortest/ExampleEventAdmin.java
@@ -14,21 +14,19 @@
 import reactor.core.publisher.Flux;
 
 @Component(immediate=true)
-public class ExampleComponent2 {
-    Logger LOG = LoggerFactory.getLogger(ExampleComponent2.class);
+public class ExampleEventAdmin {
+    Logger LOG = LoggerFactory.getLogger(ExampleEventAdmin.class);
     
     @Reference(target="(name=eventAdmin)")
-    MComponent<Map<String, ? >> mqtt;
+    MComponent<Map<String, ? >> eventAdmin;
 
     @Activate
     public void start() throws Exception {
-        LOG.info("Starting component2");
-        Publisher<Map<String, ?>> fromTopic = mqtt.from("input", Map2Map::convert);
-        Consumer<Map<String, ?>> toTopic = mqtt.to("output", Map2Map::convert);
+        Publisher<Map<String, ?>> fromTopic = eventAdmin.from("input", Map2Map::convert);
+        Consumer<Map<String, ?>> toTopic = eventAdmin.to("output", Map2Map::convert);
         Flux.from(fromTopic)
             .log()
-            .subscribe();
-        LOG.info("component2 started");
+            .subscribe(toTopic);
     }
 
 }