[Event] (Add) try handle generic event

quarkus/src/main/java/com/miti99/test/event/GenericEvent.java

@@ -0,0 +1,3 @@
+package com.miti99.test.event;
+
+public record GenericEvent<T>(T data) {}

quarkus/src/main/java/com/miti99/test/event/SimpleEvent.java

@@ -0,0 +1,3 @@
+package com.miti99.test.event;
+
+public record SimpleEvent() {}

quarkus/src/main/java/com/miti99/test/listener/AListener.java

@@ -0,0 +1,14 @@
+package com.miti99.test.listener;
+
+import com.miti99.test.event.GenericEvent;
+import com.miti99.test.type.A;
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.enterprise.event.Observes;
+
+@ApplicationScoped
+public class AListener {
+
+  public void onGenericEvent(@Observes GenericEvent<A> event) {
+    System.out.println("AListener.onGenericEvent: " + event.data().getClass());
+  }
+}

quarkus/src/main/java/com/miti99/test/listener/BListener.java

@@ -0,0 +1,15 @@
+package com.miti99.test.listener;
+
+import com.miti99.test.event.GenericEvent;
+import com.miti99.test.type.A;
+import com.miti99.test.type.B;
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.enterprise.event.Observes;
+
+@ApplicationScoped
+public class BListener {
+
+  public void onGenericEvent(@Observes GenericEvent<B> event) {
+    System.out.println("BListener.onGenericEvent: " + event.data().getClass());
+  }
+}

quarkus/src/main/java/com/miti99/test/listener/SimpleListener.java

@@ -0,0 +1,13 @@
+package com.miti99.test.listener;
+
+import com.miti99.test.event.SimpleEvent;
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.enterprise.event.Observes;
+
+@ApplicationScoped
+public class SimpleListener {
+
+  public void onEvent(@Observes SimpleEvent event) {
+    System.out.println("SimpleListener.onEvent");
+  }
+}

quarkus/src/main/java/com/miti99/test/publisher/APublisher.java

@@ -0,0 +1,24 @@
+package com.miti99.test.publisher;
+
+import com.miti99.test.event.GenericEvent;
+import com.miti99.test.type.A;
+import jakarta.enterprise.event.Event;
+import jakarta.inject.Inject;
+import jakarta.ws.rs.GET;
+import jakarta.ws.rs.Path;
+import jakarta.ws.rs.Produces;
+import jakarta.ws.rs.core.MediaType;
+
+@Path("/A")
+public class APublisher {
+
+  @Inject Event<GenericEvent<A>> eventPublisher;
+
+  @GET
+  @Produces(MediaType.TEXT_PLAIN)
+  public String hello() {
+    GenericEvent<A> event = new GenericEvent<>(new A());
+    eventPublisher.fire(event);
+    return "fired A event";
+  }
+}

quarkus/src/main/java/com/miti99/test/publisher/BPublisher.java

@@ -0,0 +1,24 @@
+package com.miti99.test.publisher;
+
+import com.miti99.test.event.GenericEvent;
+import com.miti99.test.type.B;
+import jakarta.enterprise.event.Event;
+import jakarta.inject.Inject;
+import jakarta.ws.rs.GET;
+import jakarta.ws.rs.Path;
+import jakarta.ws.rs.Produces;
+import jakarta.ws.rs.core.MediaType;
+
+@Path("/B")
+public class BPublisher {
+
+  @Inject Event<GenericEvent<B>> eventPublisher;
+
+  @GET
+  @Produces(MediaType.TEXT_PLAIN)
+  public String hello() {
+    GenericEvent<B> event = new GenericEvent<>(new B());
+    eventPublisher.fire(event);
+    return "fired B event";
+  }
+}

quarkus/src/main/java/com/miti99/test/publisher/SimplePublisher.java

@@ -0,0 +1,23 @@
+package com.miti99.test.publisher;
+
+import com.miti99.test.event.SimpleEvent;
+import jakarta.enterprise.event.Event;
+import jakarta.inject.Inject;
+import jakarta.ws.rs.GET;
+import jakarta.ws.rs.Path;
+import jakarta.ws.rs.Produces;
+import jakarta.ws.rs.core.MediaType;
+
+@Path("/Simple")
+public class SimplePublisher {
+
+  @Inject Event<SimpleEvent> eventPublisher;
+
+  @GET
+  @Produces(MediaType.TEXT_PLAIN)
+  public String hello() {
+    SimpleEvent event = new SimpleEvent();
+    eventPublisher.fire(event);
+    return "fired simple event";
+  }
+}

quarkus/src/main/java/com/miti99/test/type/A.java

@@ -0,0 +1,3 @@
+package com.miti99.test.type;
+
+public class A {}

quarkus/src/main/java/com/miti99/test/type/B.java

@@ -0,0 +1,3 @@
+package com.miti99.test.type;
+
+public class B {}