Uses of Class
cloud.opencode.base.event.Event

Packages that use Event

Package	Description
cloud.opencode.base.event
cloud.opencode.base.event.dispatcher
cloud.opencode.base.event.exception
cloud.opencode.base.event.handler
cloud.opencode.base.event.interceptor
cloud.opencode.base.event.security
cloud.opencode.base.event.serialization
cloud.opencode.base.event.store
cloud.opencode.base.event.testing

Uses of Event in cloud.opencode.base.event

Classes in cloud.opencode.base.event with type parameters of type Event

Modifier and Type	Interface	Description
interface	EventListener<E extends Event>	Event Listener Interface 事件监听器接口

Subclasses of Event in cloud.opencode.base.event

Modifier and Type	Class	Description
class	DataEvent<T>	Generic Data Event 泛型数据事件
final class	DeadEvent	Dead Event - Wraps events that have no subscribers 死事件 - 包装没有订阅者的事件
class	WaitableEvent	Waitable Event Wrapper 可等待事件包装器

Methods in cloud.opencode.base.event with type parameters of type Event

Modifier and Type	Method	Description
<E extends Event> E	OpenEvent.getStickyEvent(Class<E> eventType)	Get the last sticky event of the given type 获取指定类型的最后一个粘性事件
<E extends Event> void	OpenEvent.on(Class<E> eventType, EventListener<E> listener)	Register a lambda listener for an event type (legacy void return) 为事件类型注册Lambda监听器（兼容旧接口，无返回值）
<E extends Event> void	OpenEvent.on(Class<E> eventType, EventListener<E> listener, boolean async)	Register a lambda listener with async option (legacy void return) 使用异步选项注册Lambda监听器（兼容旧接口，无返回值）
<E extends Event> void	OpenEvent.on(Class<E> eventType, EventListener<E> listener, boolean async, int priority)	Register a lambda listener with async and priority options (legacy void return) 使用异步和优先级选项注册Lambda监听器（兼容旧接口，无返回值）
<E extends Event> E	OpenEvent.removeStickyEvent(Class<E> eventType)	Remove and return the sticky event of the given type 移除并返回指定类型的粘性事件
<E extends Event> Subscription	OpenEvent.subscribe(Class<E> eventType, EventListener<E> listener)	Subscribe a listener and return a Subscription handle 订阅监听器并返回订阅句柄
<E extends Event> Subscription	OpenEvent.subscribe(Class<E> eventType, EventListener<E> listener, Predicate<E> filter)	Subscribe a listener with a filter predicate 使用过滤谓词订阅监听器
<E extends Event> Subscription	OpenEvent.subscribe(Class<E> eventType, EventListener<E> listener, Predicate<E> filter, boolean async, int priority)	Subscribe a listener with full configuration 使用完整配置订阅监听器

Methods in cloud.opencode.base.event that return Event

Modifier and Type	Method	Description
Event	DeadEvent.getOriginalEvent()	Get the original event that had no subscribers 获取没有订阅者的原始事件
Event	WaitableEvent.getWrappedEvent()	Get the wrapped event 获取被包装的事件

Methods in cloud.opencode.base.event that return types with arguments of type Event

Modifier and Type	Method	Description
Class<? extends Event>	Subscription.getEventType()	Get the event type this subscription is for 获取此订阅的事件类型

Methods in cloud.opencode.base.event with parameters of type Event

Modifier and Type	Method	Description
void	OpenEvent.publish(Event event)	Publish an event synchronously 同步发布事件
boolean	OpenEvent.publishAndWait(Event event, Duration timeout)	Publish and wait for processing to complete 发布并等待处理完成
CompletableFuture<Void>	OpenEvent.publishAsync(Event event)	Publish an event asynchronously 异步发布事件
void	OpenEvent.publishSticky(Event event)	Publish a sticky event (stored and replayed to future subscribers) 发布粘性事件（存储并重放给未来的订阅者）

Constructors in cloud.opencode.base.event with parameters of type Event

Modifier	Constructor	Description
	DeadEvent(Event originalEvent)	Create a dead event wrapping the original unhandled event 创建包装原始未处理事件的死事件
	WaitableEvent(Event event)	Create waitable event with new latch 创建带新锁存器的可等待事件
	WaitableEvent(Event event, CountDownLatch latch)	Create waitable event wrapper 创建可等待事件包装器

Uses of Event in cloud.opencode.base.event.dispatcher

Methods in cloud.opencode.base.event.dispatcher with parameters of type Event

Modifier and Type	Method	Description
void	AsyncDispatcher.dispatch(Event event, List<Consumer<Event>> listeners)	Dispatch event to listeners asynchronously 异步将事件分发到监听器
void	EventDispatcher.dispatch(Event event, List<Consumer<Event>> listeners)	Dispatch event to listeners 将事件分发到监听器
void	SyncDispatcher.dispatch(Event event, List<Consumer<Event>> listeners)	Dispatch event to listeners synchronously 同步将事件分发到监听器
CompletableFuture<Void>	AsyncDispatcher.dispatchAsync(Event event, List<Consumer<Event>> listeners)	Dispatch event and return a future for completion 分发事件并返回完成的Future

Method parameters in cloud.opencode.base.event.dispatcher with type arguments of type Event

Modifier and Type	Method	Description
void	AsyncDispatcher.dispatch(Event event, List<Consumer<Event>> listeners)	Dispatch event to listeners asynchronously 异步将事件分发到监听器
void	EventDispatcher.dispatch(Event event, List<Consumer<Event>> listeners)	Dispatch event to listeners 将事件分发到监听器
void	SyncDispatcher.dispatch(Event event, List<Consumer<Event>> listeners)	Dispatch event to listeners synchronously 同步将事件分发到监听器
CompletableFuture<Void>	AsyncDispatcher.dispatchAsync(Event event, List<Consumer<Event>> listeners)	Dispatch event and return a future for completion 分发事件并返回完成的Future

Uses of Event in cloud.opencode.base.event.exception

Methods in cloud.opencode.base.event.exception that return Event

Modifier and Type	Method	Description
Event	EventException.getEvent()	Get the related event (if available) 获取相关事件（如果可用）

Constructors in cloud.opencode.base.event.exception with parameters of type Event

Modifier	Constructor	Description
	EventException(String message, Throwable cause, Event event, EventErrorCode errorCode)	Create exception with all parameters 使用所有参数创建异常
	EventListenerException(String message, Throwable cause, Event event, EventErrorCode errorCode)	Create listener exception with all parameters 使用所有参数创建监听器异常
	EventPublishException(String message, Throwable cause, Event event, EventErrorCode errorCode)	Create publish exception with all parameters 使用所有参数创建发布异常
	EventSecurityException(String message, Throwable cause, Event event, EventErrorCode errorCode)	Create security exception with all parameters 使用所有参数创建安全异常
	EventStoreException(String message, Throwable cause, Event event, EventErrorCode errorCode)	Create store exception with all parameters 使用所有参数创建存储异常

Uses of Event in cloud.opencode.base.event.handler

Methods in cloud.opencode.base.event.handler that return Event

Modifier and Type	Method	Description
Event	RetryExceptionHandler.FailedEvent.event()	Returns the value of the event record component.

Methods in cloud.opencode.base.event.handler with parameters of type Event

Modifier and Type	Method	Description
void	EventExceptionHandler.handleException(Event event, Throwable exception, String listenerName)	Handle an exception that occurred during event processing 处理事件处理过程中发生的异常
void	LoggingExceptionHandler.handleException(Event event, Throwable exception, String listenerName)	Handle exception by logging it 通过记录日志处理异常
void	RetryExceptionHandler.handleException(Event event, Throwable exception, String listenerName)	Handle exception with retry logic 使用重试逻辑处理异常

Method parameters in cloud.opencode.base.event.handler with type arguments of type Event

Modifier and Type	Method	Description
void	RetryExceptionHandler.setRetryAction(Consumer<Event> retryAction)	Set the retry action 设置重试动作

Constructors in cloud.opencode.base.event.handler with parameters of type Event

Modifier	Constructor	Description
	FailedEvent(Event event, Throwable exception, String listenerName, int attempts)	Creates an instance of a FailedEvent record class.

Uses of Event in cloud.opencode.base.event.interceptor

Methods in cloud.opencode.base.event.interceptor with parameters of type Event

Modifier and Type	Method	Description
default void	EventInterceptor.afterPublish(Event event, boolean dispatched)	Called after an event has been dispatched to listeners 在事件分发给监听器之后调用
boolean	EventInterceptor.beforePublish(Event event)	Called before an event is dispatched to listeners 在事件分发给监听器之前调用

Uses of Event in cloud.opencode.base.event.security

Subclasses of Event in cloud.opencode.base.event.security

Modifier and Type	Class	Description
class	SignedEvent	Signed Event Base Class 签名事件基类

Methods in cloud.opencode.base.event.security with type parameters of type Event

Modifier and Type	Method	Description
<E extends Event> void	SecureEventBus.on(Class<E> eventType, EventListener<E> listener)	Register a lambda listener with security checks 使用安全检查注册Lambda监听器

Methods in cloud.opencode.base.event.security with parameters of type Event

Modifier and Type	Method	Description
boolean	EventRateLimiter.allowPublish(Event event)	Check if publishing is allowed 检查是否允许发布
void	SecureEventBus.publish(Event event)	Publish an event with security checks 使用安全检查发布事件

Method parameters in cloud.opencode.base.event.security with type arguments of type Event

Modifier and Type	Method	Description
int	EventRateLimiter.getCurrentCount(Class<? extends Event> eventType)	Get current count for an event type 获取事件类型的当前计数
void	EventRateLimiter.reset(Class<? extends Event> eventType)	Reset rate limit for a specific event type 重置特定事件类型的频率限制
void	EventRateLimiter.setLimit(Class<? extends Event> eventType, int maxPerSecond)	Set rate limit for a specific event type 为特定事件类型设置频率限制

Uses of Event in cloud.opencode.base.event.serialization

Methods in cloud.opencode.base.event.serialization with type parameters of type Event

Modifier and Type	Method	Description
static <T extends Event> T	EventSerializer.deserialize(byte[] data, Class<T> eventType)	Deserializes bytes to an event.
static <T extends Event> T	EventSerializer.deserializeFromString(String base64, Class<T> eventType)	Deserializes a Base64 string to an event.
static <T extends Event> byte[]	EventSerializer.serialize(T event)	Serializes an event to bytes.
static <T extends Event> String	EventSerializer.serializeToString(T event)	Serializes an event to a Base64 string.

Uses of Event in cloud.opencode.base.event.store

Methods in cloud.opencode.base.event.store that return Event

Modifier and Type	Method	Description
Event	EventRecord.event()	Returns the value of the event record component.

Methods in cloud.opencode.base.event.store with parameters of type Event

Modifier and Type	Method	Description
static EventRecord	EventRecord.of(Event event, long sequenceNumber)	Create event record from an event 从事件创建事件记录
EventRecord	EventStore.save(Event event)	Save an event to the store 将事件保存到存储
EventRecord	InMemoryEventStore.save(Event event)

Method parameters in cloud.opencode.base.event.store with type arguments of type Event

Modifier and Type	Method	Description
List<EventRecord>	EventStore.findByType(Class<? extends Event> eventType)	Find all event records by event type 根据事件类型查找所有事件记录
List<EventRecord>	InMemoryEventStore.findByType(Class<? extends Event> eventType)
boolean	EventRecord.isType(Class<? extends Event> type)	Check if the event is of a specific type 检查事件是否为特定类型
void	EventStore.replay(Class<? extends Event> eventType, Consumer<Event> handler)	Replay events of a specific type 重放特定类型的事件
void	EventStore.replay(Class<? extends Event> eventType, Consumer<Event> handler)	Replay events of a specific type 重放特定类型的事件
void	InMemoryEventStore.replay(Class<? extends Event> eventType, Consumer<Event> handler)
void	InMemoryEventStore.replay(Class<? extends Event> eventType, Consumer<Event> handler)
void	EventStore.replayByTimeRange(Instant from, Instant to, Consumer<Event> handler)	Replay events within a time range 在时间范围内重放事件
void	InMemoryEventStore.replayByTimeRange(Instant from, Instant to, Consumer<Event> handler)

Constructors in cloud.opencode.base.event.store with parameters of type Event

Modifier	Constructor	Description
	EventRecord(String id, Event event, String eventType, Instant timestamp, String source, Instant storedAt, long sequenceNumber)	Creates an instance of a EventRecord record class.

Uses of Event in cloud.opencode.base.event.testing

Classes in cloud.opencode.base.event.testing with type parameters of type Event

Modifier and Type	Class	Description
class	EventCaptor<E extends Event>	Event Captor - Test utility for capturing and asserting events 事件捕获器 - 用于捕获和断言事件的测试工具