CDI event observer methods cannot be generic due to type erasure

src/main/java/org/test/AbstractBroadcaster.java

@@ -11,9 +11,6 @@
 import javax.annotation.Resource;
 import javax.enterprise.concurrent.ManagedExecutorService;
 import javax.enterprise.event.Event;
-import javax.enterprise.event.Observes;
-import javax.enterprise.event.ObservesAsync;
-import javax.enterprise.event.TransactionPhase;
 import javax.inject.Inject;
 import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.function.Consumer;
@@ -45,11 +42,7 @@ public void broadcastAsync(M message) {
         messageEvent.fireAsync(message);
     }
 
-    private void onMessageAsync(@ObservesAsync M message) {
-        onMessage(message);
-    }
-
-    private void onMessage(@Observes(during = TransactionPhase.AFTER_SUCCESS) M message) {
+    protected void onMessageImpl(M message) {
         log.info("{} got message {}, listeners are: {}", this, message, listeners);
         for (final Consumer<M> listener : listeners) {
             executorService.execute(() -> {

src/main/java/org/test/Broadcaster.java

@@ -6,7 +6,20 @@
 package org.test;
 
 import javax.enterprise.context.ApplicationScoped;
+import javax.enterprise.event.Observes;
+import javax.enterprise.event.ObservesAsync;
+import javax.enterprise.event.TransactionPhase;
 
 @ApplicationScoped
 public class Broadcaster extends AbstractBroadcaster<Message> {
+
+    // CDI event observer methods cannot be generic due to type erasure.
+    private void onMessageAsync(@ObservesAsync Message message) {
+        onMessageImpl(message);
+    }
+
+    private void onMessage(@Observes(during = TransactionPhase.AFTER_SUCCESS) Message message) {
+        onMessageImpl(message);
+    }
+
 }