Add a simple implementation of an event bus using reactor

Author: rgomezcasas

build.gradle

@@ -8,6 +8,10 @@ repositories {
 }
 
 dependencies {
+    // Prod
+    implementation('io.projectreactor:reactor-bus:2.0.8.RELEASE')
+
+    // Test
     testCompile('org.junit.jupiter:junit-jupiter-api:5.3.2')
     testRuntime('org.junit.jupiter:junit-jupiter-engine:5.3.2')
 }
@@ -22,4 +26,4 @@ test {
     reports {
         html.enabled = true
     }
-}
+}

src/main/java/tv/codely/Starter.java

@@ -0,0 +1,17 @@
+package tv.codely;
+
+import tv.codely.context.notification.module.push.application.create.SendPushToSubscribersOnVideoCreated;
+import tv.codely.context.video.module.video.domain.VideoCreated;
+import tv.codely.shared.infrastructure.bus.ReactorEventBus;
+
+import java.util.Arrays;
+
+public class Starter {
+    public static void main(String[] args) {
+        var sendPushToSubscribersOnVideoCreated = new SendPushToSubscribersOnVideoCreated();
+
+        var eventBus = new ReactorEventBus(Arrays.asList(sendPushToSubscribersOnVideoCreated));
+
+        eventBus.notify(new VideoCreated("Llegamos a 1M de subscribers!", "CodelyTV es una gran plataforma, CREMITA!"));
+    }
+}

src/main/java/tv/codely/context/notification/module/push/application/create/SendPushToSubscribersOnVideoCreated.java

@@ -0,0 +1,22 @@
+package tv.codely.context.notification.module.push.application.create;
+
+import tv.codely.context.video.module.video.domain.VideoCreated;
+import tv.codely.shared.application.DomainEventSubscriber;
+
+public class SendPushToSubscribersOnVideoCreated implements DomainEventSubscriber<VideoCreated> {
+    @Override
+    public String subscribedTo() {
+        return VideoCreated.NAME;
+    }
+
+    @Override
+    public void react(VideoCreated event) {
+        System.out.println(
+            String.format(
+                "Hey! There is a new video with title <%s> and description <%s>",
+                event.name(),
+                event.description()
+            )
+        );
+    }
+}

src/main/java/tv/codely/context/notification/module/push/application/find/.gitkeep

@@ -0,0 +1,5 @@
+package tv.codely.context.video.module.video.application.create;
+
+public class VideoCreator {
+
+}

src/main/java/tv/codely/context/notification/module/push/domain/.gitkeep

@@ -0,0 +1,27 @@
+package tv.codely.context.video.module.video.domain;
+
+import tv.codely.shared.domain.DomainEvent;
+
+public class VideoCreated implements DomainEvent {
+    public static final String NAME = "video.created";
+
+    private final String name;
+    private final String description;
+
+    public VideoCreated(String name, String description) {
+        this.name        = name;
+        this.description = description;
+    }
+
+    public String domainEventName() {
+        return NAME;
+    }
+
+    public String name() {
+        return name;
+    }
+
+    public String description() {
+        return description;
+    }
+}