Package com.ultikits.ultitools.events

Class EventBus

java.lang.Object

com.ultikits.ultitools.events.EventBus

public class EventBus
extends Object

Central event bus for inter-module communication. Supports sync and async dispatch, annotation and programmatic subscriptions.

模块间通信的中央事件总线。 支持同步和异步分发、注解和编程式订阅。

Since:

6.2.2

Field Summary

Fields

Modifier and Type	Field	Description
private final ExecutorService	asyncPool
private final Map<Class<? extends ModuleEvent>,CopyOnWriteArrayList<HandlerEntry>>	handlers
private static final Logger	LOGGER

Constructor Summary

Constructors

Constructor	Description
EventBus()

Method Summary

Modifier and Type	Method	Description
private List<HandlerEntry>	collectHandlers(Class<? extends ModuleEvent> eventType)	Collect all handlers matching the event type (including superclass handlers), sorted by priority.
private void	invokeHandler(HandlerEntry entry, ModuleEvent event)
void	publish(ModuleEvent event)	Publish an event synchronously.
void	publishAsync(ModuleEvent event)	Publish an event asynchronously.
void	register(Class<? extends ModuleEvent> eventType, EventPriority priority, boolean ignoreCancelled, String ownerModule, Method method, Object instance)	Register an annotation-based handler.
void	shutdown()	Shutdown the async thread pool.
<T extends ModuleEvent> Subscription	subscribe(Class<T> eventType, EventPriority priority, boolean ignoreCancelled, String ownerModule, Consumer<T> consumer)	Register a programmatic handler with full options.
<T extends ModuleEvent> Subscription	subscribe(Class<T> eventType, Consumer<T> consumer)	Register a programmatic handler.
void	unregisterAll(String moduleName)	Unregister all handlers owned by a module.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOGGER

private static final Logger LOGGER

handlers

private final Map<Class<? extends ModuleEvent>,CopyOnWriteArrayList<HandlerEntry>> handlers

asyncPool

private final ExecutorService asyncPool

Constructor Details

EventBus

public EventBus()

Method Details

register

public void register(Class<? extends ModuleEvent> eventType,
 EventPriority priority,
 boolean ignoreCancelled,
 String ownerModule,
 Method method,
 Object instance)

Register an annotation-based handler.

subscribe

public <T extends ModuleEvent> Subscription subscribe(Class<T> eventType,
 Consumer<T> consumer)

Register a programmatic handler. Returns a Subscription for manual unsubscribe.

subscribe

public <T extends ModuleEvent> Subscription subscribe(Class<T> eventType,
 EventPriority priority,
 boolean ignoreCancelled,
 String ownerModule,
 Consumer<T> consumer)

Register a programmatic handler with full options.

unregisterAll

public void unregisterAll(String moduleName)

Unregister all handlers owned by a module.

publish

public void publish(ModuleEvent event)

Publish an event synchronously. Handlers run on the calling thread in priority order.

publishAsync

public void publishAsync(ModuleEvent event)

Publish an event asynchronously. Handlers run on a worker thread. Cancellable events are rejected — cancellation is only meaningful for sync dispatch.

shutdown

public void shutdown()

Shutdown the async thread pool. Called on plugin disable.

collectHandlers

private List<HandlerEntry> collectHandlers(Class<? extends ModuleEvent> eventType)

Collect all handlers matching the event type (including superclass handlers), sorted by priority.

invokeHandler

private void invokeHandler(HandlerEntry entry,
 ModuleEvent event)