diff --git a/framework/src/main/java/org/toop/framework/eventbus/bus/DisruptorEventBus.java b/framework/src/main/java/org/toop/framework/eventbus/bus/DisruptorEventBus.java index fc296db..a7fc214 100644 --- a/framework/src/main/java/org/toop/framework/eventbus/bus/DisruptorEventBus.java +++ b/framework/src/main/java/org/toop/framework/eventbus/bus/DisruptorEventBus.java @@ -75,6 +75,7 @@ public class DisruptorEventBus implements EventBus { public void post(T event) { long seq = ringBuffer.next(); try { + @SuppressWarnings("unchecked") EventHolder holder = (EventHolder) ringBuffer.get(seq); holder.event = event; } finally { @@ -105,6 +106,7 @@ public class DisruptorEventBus implements EventBus { } } + // TODO, Still needed? CopyOnWriteArrayList> genericListeners = (CopyOnWriteArrayList>) eventsHolder.get(Object.class); if (genericListeners != null) { for (Subscriber listener : genericListeners) {