diff --git a/src/main/java/com/epita/guereza/Main.java b/src/main/java/com/epita/guereza/Main.java
index 8a7c287..8c023d3 100644
--- a/src/main/java/com/epita/guereza/Main.java
+++ b/src/main/java/com/epita/guereza/Main.java
@@ -8,23 +8,21 @@
 import com.epita.guereza.service.CrawlerService;
 import com.epita.guereza.service.indexer.IndexerService;
 import com.epita.winter.Scope;
+import com.epita.winter.provider.LazySingleton;
 import com.epita.winter.provider.Prototype;
 import com.epita.winter.provider.Singleton;
 import com.fasterxml.jackson.core.JsonProcessingException;
 
-import java.lang.reflect.Method;
 import java.util.Map;
 import java.util.function.Function;
 
-import static com.epita.winter.Scope.getMethod;
-
 public class Main {
     private static final String NETTY_HOST = "localhost";
     private static final int NETTY_PORT = 8000;
 
     public static void main(String[] args) {
 //        final Index index = new Index();
-//        final Repo repo = new RepoStore();
+//        final Repo repo = new UrlStore();
 //
 //        //repo.store(new String[]{"https://www.bbc.co.uk/food/recipes/saladenicoise_6572"});
 //
@@ -44,17 +42,17 @@ public static void main(String[] args) {
     private static void testApp() {
         final Crawler crawler = new CrawlerService();
         final Indexer indexer = new IndexerService();
-        final Repo repo = new RepoStore();
 
         final Function<Scope, EventBusClient> newEventBus = (s) -> new NettyEventBusClient();
         final Function<Scope, CrawlerApp> newCrawlerApp = (s) -> new CrawlerApp(s.instanceOf(EventBusClient.class), s.instanceOf(Crawler.class));
         final Function<Scope, IndexerApp> newIndexerApp = (s) -> new IndexerApp(s.instanceOf(EventBusClient.class), s.instanceOf(Indexer.class),
                 s.instanceOf(Crawler.class));
+        final Function<Scope, Repo> newRepo = (s) -> new UrlStore(s.instanceOf(EventBusClient.class));
 
         new Scope()
                 .register(new Singleton<>(Crawler.class, crawler))
                 .register(new Singleton<>(Indexer.class, indexer))
-                .register(new Singleton<>(Repo.class, repo))
+                .register(new LazySingleton<>(Repo.class, newRepo))
                 .register(new Prototype<>(EventBusClient.class, newEventBus))
                 .register(new Prototype<>(CrawlerApp.class, newCrawlerApp))
                 .register(new Prototype<>(IndexerApp.class, newIndexerApp))
diff --git a/src/main/java/com/epita/guereza/RepoStore.java b/src/main/java/com/epita/guereza/RepoStore.java
deleted file mode 100644
index a11a659..0000000
--- a/src/main/java/com/epita/guereza/RepoStore.java
+++ /dev/null
@@ -1,45 +0,0 @@
-package com.epita.guereza;
-
-import com.epita.guereza.service.CrawlerService;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.util.LinkedHashSet;
-import java.util.Set;
-
-public class RepoStore implements Repo {
-    private static final Logger LOGGER = LoggerFactory.getLogger(CrawlerService.class);
-
-    private Set<String> urlDone;
-    private Set<String> urlTodo;
-
-    public RepoStore() {
-        urlDone = new LinkedHashSet<>();
-        urlTodo = new LinkedHashSet<>();
-    }
-
-    @Override
-    public void store(String[] urls) {
-        for (String url : urls) {
-            if (url == null || url.isEmpty())
-                continue;
-
-            if (!urlDone.contains(url))
-                urlTodo.add(url);
-        }
-    }
-
-    @Override
-    public String nextUrl() {
-        if (!urlTodo.isEmpty()) {
-            // There is still
-            String url = urlTodo.iterator().next();
-            urlTodo.remove(url);
-            urlDone.add(url);
-            LOGGER.info("Repo still contains {} links", urlTodo.size());
-            return url;
-        }
-        LOGGER.warn("No more url to analyse.");
-        return null;
-    }
-}
diff --git a/src/main/java/com/epita/guereza/UrlStore.java b/src/main/java/com/epita/guereza/UrlStore.java
new file mode 100644
index 0000000..7a1fb27
--- /dev/null
+++ b/src/main/java/com/epita/guereza/UrlStore.java
@@ -0,0 +1,88 @@
+package com.epita.guereza;
+
+import com.epita.eventbus.EventBusClient;
+import com.epita.eventbus.EventMessage;
+import com.epita.guereza.eventsourcing.Event;
+import com.epita.guereza.eventsourcing.Reducer;
+import com.epita.guereza.service.CrawlerService;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.LinkedHashSet;
+import java.util.Set;
+
+public class UrlStore implements Repo, Reducer {
+    private static final Logger LOGGER = LoggerFactory.getLogger(CrawlerService.class);
+
+    private final EventBusClient eventBus;
+
+    private Set<String> urlDone = new LinkedHashSet<>();
+    private Set<String> urlTodo = new LinkedHashSet<>();
+
+    public UrlStore(final EventBusClient eventBus) {
+        this.eventBus = eventBus;
+    }
+
+    @Override
+    public void store(String[] urls) {
+        for (String url : urls) {
+            if (url == null || url.isEmpty())
+                continue;
+
+            if (!urlDone.contains(url))
+                urlTodo.add(url);
+        }
+    }
+
+    @Override
+    public String nextUrl() {
+        if (!urlTodo.isEmpty()) {
+            // There is still
+            String url = urlTodo.iterator().next();
+            urlTodo.remove(url);
+            urlDone.add(url);
+            LOGGER.info("Repo still contains {} links", urlTodo.size());
+            return url;
+        }
+        LOGGER.warn("No more url to analyse.");
+        return null;
+    }
+
+    @SuppressWarnings("unchecked")
+    @Override
+    public void reduce(final Event<?> event) {
+        switch (event.type) {
+            case "ADD_URLS":
+                addUrls((Event<String[]>) event);
+                break;
+            case "CRAWLER_REQUEST_URL":
+                crawlerRequestUrl((Event<String>) event);
+                break;
+            case "INDEXER_REQUEST_URL":
+                indexerRequestUrl((Event<String>) event);
+                break;
+        }
+    }
+
+    private void addUrls(Event<String[]> event) {
+        store(event.obj);
+        LOGGER.info("added URLs to the repo");
+    }
+
+    private void crawlerRequestUrl(Event<String> event) {
+        try {
+            eventBus.publish(new EventMessage(event.obj, nextUrl()));
+        } catch (JsonProcessingException e) {
+            LOGGER.error("cannot serialize: {}", e.getMessage());
+        }
+    }
+
+    private void indexerRequestUrl(Event<String> event) {
+        try {
+            eventBus.publish(new EventMessage(event.obj, nextUrl()));
+        } catch (JsonProcessingException e) {
+            LOGGER.error("cannot serialize: {}", e.getMessage());
+        }
+    }
+}