eventstore: refacto

dethi · Dec 9, 2017 · 939b7b0 · 939b7b0
1 parent 07540fa
commit 939b7b0
Showing 1 changed file with 16 additions and 24 deletions.
diff --git a/src/main/java/com/epita/guereza/EventStoreApp.java b/src/main/java/com/epita/guereza/EventStoreApp.java
@@ -34,29 +34,21 @@ private void extractThen(final EventBusClient.Message msg, final Consumer<Object
 
     @Override
     public void run() {
-        eventBus.subscribe("/request/crawler/url", msg -> {
-            extractThen(msg, o -> {
-                Event<String> ev = new Event<>("CRAWLER_REQUEST_URL", String.class, (String) o);
-                eventStore.dispatch(ev);
-            });
-        });
-        eventBus.subscribe("/request/indexer/url", msg -> {
-            extractThen(msg, o -> {
-                Event<String> ev = new Event<>("INDEXER_REQUEST_URL", String.class, (String) o);
-                eventStore.dispatch(ev);
-            });
-        });
-        eventBus.subscribe("/store/crawler", msg -> {
-            extractThen(msg, o -> {
-                Event<String[]> ev = new Event<>("ADD_URLS", String[].class, (String[]) o);
-                eventStore.dispatch(ev);
-            });
-        });
-        eventBus.subscribe("/store/indexer", msg -> {
-            extractThen(msg, o -> {
-                Event<Document> ev = new Event<>("ADD_DOCUMENT", Document.class, (Document) o);
-                eventStore.dispatch(ev);
-            });
-        });
+        eventBus.subscribe("/request/crawler/url", msg -> extractThen(msg, o -> {
+            Event<String> ev = new Event<>("CRAWLER_REQUEST_URL", String.class, (String) o);
+            eventStore.dispatch(ev);
+        }));
+        eventBus.subscribe("/request/indexer/url", msg -> extractThen(msg, o -> {
+            Event<String> ev = new Event<>("INDEXER_REQUEST_URL", String.class, (String) o);
+            eventStore.dispatch(ev);
+        }));
+        eventBus.subscribe("/store/crawler", msg -> extractThen(msg, o -> {
+            Event<String[]> ev = new Event<>("ADD_URLS", String[].class, (String[]) o);
+            eventStore.dispatch(ev);
+        }));
+        eventBus.subscribe("/store/indexer", msg -> extractThen(msg, o -> {
+            Event<Document> ev = new Event<>("ADD_DOCUMENT", Document.class, (Document) o);
+            eventStore.dispatch(ev);
+        }));
     }
 }