From 939b7b012bd4c3585d2005620a3bb5451aa021fc Mon Sep 17 00:00:00 2001
From: Florent Youinou <youino_f@epita.fr>
Date: Sat, 9 Dec 2017 16:53:50 +0100
Subject: [PATCH] eventstore: refacto

---
 .../java/com/epita/guereza/EventStoreApp.java | 40 ++++++++-----------
 1 file changed, 16 insertions(+), 24 deletions(-)

diff --git a/src/main/java/com/epita/guereza/EventStoreApp.java b/src/main/java/com/epita/guereza/EventStoreApp.java
index 7d49bd6..aef6a4c 100644
--- 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);
+        }));
     }
 }