public class EventDispatcher
extends java.lang.Object
限定符和类型 | 字段和说明 |
---|---|
static java.lang.Long |
asyncTimeLimit
异步同步任务超过[5]s需要关注,是否要设置为异步
|
static java.util.concurrent.atomic.AtomicLong |
eventCount
统计事件执行中的数量
|
static java.lang.Long |
syncTimeLimit
同步任务超过[200]ms需要关注,可以考虑设置为异步
|
构造器和说明 |
---|
EventDispatcher() |
限定符和类型 | 方法和说明 |
---|---|
static void |
continueDispatching() |
static void |
fireEvent(Event event)
触发事件,不抛出异常,只记录日志。
|
static void |
fireEventAfterCommit(Event event)
触发事件,不立即触发。
|
static void |
fireEventWithException(Event event)
触发事件,有异常则抛出。
|
java.util.Map<java.lang.String,java.util.List<Listener>> |
getAllListener() |
static void |
register(java.lang.Class<? extends Event> eventType,
Listener listener)
注册事件监听。
|
static void |
register(java.lang.Class<? extends Event> event,
java.lang.String beanName,
java.lang.String methodName,
boolean async) |
static void |
register(java.lang.Class<? extends Event> event,
java.lang.String beanName,
java.lang.String methodName,
boolean async,
EventTriggerMode mode) |
static void |
stopDispatching() |
public static final java.lang.Long syncTimeLimit
public static final java.lang.Long asyncTimeLimit
public static java.util.concurrent.atomic.AtomicLong eventCount
public static final void fireEvent(Event event)
event
- 事件对象。public static final void fireEventAfterCommit(Event event)
event
- 事件对象。public static final void fireEventWithException(Event event) throws java.lang.Throwable
event
- 事件对象。java.lang.Throwable
public java.util.Map<java.lang.String,java.util.List<Listener>> getAllListener()
public static final void register(java.lang.Class<? extends Event> eventType, Listener listener)
eventType
- 事件类型,Event的子类,如CollaborationStartEvent.classlistener
- 事件监听器。public static final void register(java.lang.Class<? extends Event> event, java.lang.String beanName, java.lang.String methodName, boolean async)
public static final void register(java.lang.Class<? extends Event> event, java.lang.String beanName, java.lang.String methodName, boolean async, EventTriggerMode mode)
public static void stopDispatching()
public static void continueDispatching()