Remove class from event

dethi · Dec 9, 2017 · e8563f6 · e8563f6
1 parent 98a6dbf
commit e8563f6
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 7 deletions.
diff --git a/src/main/java/com/epita/guereza/EventStoreApp.java b/src/main/java/com/epita/guereza/EventStoreApp.java
@@ -35,19 +35,19 @@ 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);
+            Event<String> ev = new Event<>("CRAWLER_REQUEST_URL", (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);
+            Event<String> ev = new Event<>("INDEXER_REQUEST_URL", (String) o);
             eventStore.dispatch(ev);
         }));
         eventBus.subscribe("/store/crawler", msg -> extractThen(msg, o -> {
-            Event<String[]> ev = new Event<>("ADD_URLS", String[].class, (String[]) o);
+            Event<String[]> ev = new Event<>("ADD_URLS", (String[]) o);
             eventStore.dispatch(ev);
         }));
         eventBus.subscribe("/store/indexer", msg -> extractThen(msg, o -> {
-            Event<Document> ev = new Event<>("ADD_DOCUMENT", Document.class, (Document) o);
+            Event<Document> ev = new Event<>("ADD_DOCUMENT", (Document) o);
             eventStore.dispatch(ev);
         }));
     }

diff --git a/src/main/java/com/epita/guereza/eventsourcing/Event.java b/src/main/java/com/epita/guereza/eventsourcing/Event.java
@@ -3,12 +3,10 @@
 @SuppressWarnings("WeakerAccess")
 public class Event<BEAN_TYPE> {
     public final String type;
-    public final Class<BEAN_TYPE> klass;
     public final BEAN_TYPE obj;
 
-    public Event(final String type, final Class<BEAN_TYPE> klass, final BEAN_TYPE obj) {
+    public Event(final String type, final BEAN_TYPE obj) {
         this.type = type;
-        this.klass = klass;
         this.obj = obj;
     }
 }