2424public class EventBus implements IEventExceptionHandler , IEventBus {
2525 private static final Logger LOGGER = LogManager .getLogger ();
2626 private static final boolean checkTypesOnDispatchProperty = Boolean .parseBoolean (System .getProperty ("eventbus.checkTypesOnDispatch" , "false" ));
27- private static AtomicInteger maxID = new AtomicInteger (0 );
27+ private static final AtomicInteger maxID = new AtomicInteger (0 );
2828 private final boolean trackPhases ;
2929
30- private ConcurrentHashMap <Object , List <IEventListener >> listeners = new ConcurrentHashMap <>();
30+ private final ConcurrentHashMap <Object , List <IEventListener >> listeners = new ConcurrentHashMap <>();
3131 private final int busID = maxID .getAndIncrement ();
3232 private final IEventExceptionHandler exceptionHandler ;
3333 private volatile boolean shutdown = false ;
@@ -161,34 +161,32 @@ private void registerListener(final Object target, final Method method, final Me
161161
162162 private static final Predicate <Event > checkCancelled = e -> !e .isCanceled ();
163163 @ SuppressWarnings ("unchecked" )
164- private <T extends Event > Predicate <T > passCancelled (boolean ignored ) {
164+ private static <T extends Event > Predicate <T > passCancelled (boolean ignored ) {
165165 return ignored ? null : (Predicate <T >)checkCancelled ;
166166 }
167167
168- private <T extends GenericEvent <? extends F >, F > Predicate <T > passGenericFilter (Class <F > type , boolean ignored ) {
168+ private static <T extends GenericEvent <? extends F >, F > Predicate <T > passGenericFilter (Class <F > type , boolean ignored ) {
169169 if (ignored )
170170 return e -> e .getGenericType () == type ;
171171 return e -> e .getGenericType () == type && !e .isCanceled ();
172172 }
173173
174- private void checkNotGeneric (final Consumer <? extends Event > consumer ) {
174+ private static void checkNotGeneric (final Consumer <? extends Event > consumer ) {
175175 checkNotGeneric (getEventClass (consumer ));
176176 }
177177
178- private void checkNotGeneric (final Class <? extends Event > eventType ) {
178+ private static void checkNotGeneric (final Class <? extends Event > eventType ) {
179179 if (GenericEvent .class .isAssignableFrom (eventType ))
180180 throw new IllegalArgumentException ("Cannot register a generic event listener with addListener, use addGenericListener" );
181181 }
182182
183183 @ Override
184184 public <T extends Event > void addListener (final Consumer <T > consumer ) {
185- checkNotGeneric (consumer );
186185 addListener (EventPriority .NORMAL , consumer );
187186 }
188187
189188 @ Override
190189 public <T extends Event > void addListener (final EventPriority priority , final Consumer <T > consumer ) {
191- checkNotGeneric (consumer );
192190 addListener (priority , false , consumer );
193191 }
194192
@@ -225,7 +223,7 @@ public <T extends GenericEvent<? extends F>, F> void addGenericListener(final Cl
225223 }
226224
227225 @ SuppressWarnings ("unchecked" )
228- private <T extends Event > Class <T > getEventClass (Consumer <T > consumer ) {
226+ private static <T extends Event > Class <T > getEventClass (Consumer <T > consumer ) {
229227 final Class <T > eventClass = (Class <T >) TypeResolver .resolveRawArgument (Consumer .class , consumer .getClass ());
230228 if ((Class <?>)eventClass == TypeResolver .Unknown .class ) {
231229 LOGGER .error (EVENTBUS , "Failed to resolve handler for \" {}\" " , consumer .toString ());
@@ -252,7 +250,7 @@ private <T extends Event> void addListener(final EventPriority priority, final P
252250 }
253251
254252 @ SuppressWarnings ("unchecked" )
255- private <T extends Event > void doCastFilter (final Predicate <? super T > filter , final Class <T > eventClass , final Consumer <T > consumer , final Event e ) {
253+ private static <T extends Event > void doCastFilter (final Predicate <? super T > filter , final Class <T > eventClass , final Consumer <T > consumer , final Event e ) {
256254 T cast = (T )e ;
257255 if (filter == null || filter .test (cast ))
258256 consumer .accept (cast );
0 commit comments