Interface FlowCommunicationEventBus

All Superinterfaces:

CommonDecorator, FlowCommon

All Known Subinterfaces:

FlowContext

All Known Implementing Classes:

DefaultFlowContext

public interface FlowCommunicationEventBus
extends FlowCommon

FlowCommunicationEventBus

Since:

25.1

Author:

渔民小镇

date:

2025-10-09

Method Summary

Modifier and Type	Method	Description
default void	fire(Object eventSource)	[Async] Sends an event to all subscribers.
default void	fireAny(Object eventSource)	[Async] Sends an event message to subscribers in the current process and remote processes.
default void	fireAnySync(Object eventSource)	Sends an event message to subscribers in the current process and remote processes.
default void	fireLocal(Object eventSource)	[Async] Sends an event message to subscribers of all logic servers in the current process.
default void	fireLocalSync(Object eventSource)	[Sync] Sends an event message to subscribers of all logic servers in the current process.
default void	fireMe(Object eventSource)	[Async] Sends an event message only to subscribers of the current EventBus.
default void	fireMeSync(Object eventSource)	[Sync] Sends an event message only to subscribers of the current EventBus.
default void	fireSync(Object eventSource)	[Sync] Sends an event to all subscribers.
default EventBus	getEventBus()
default EventBusMessage	ofEventBusMessage(Object eventSource)

Methods inherited from interface CommonDecorator

getCommunicationAggregation

Methods inherited from interface FlowCommon

execute, executeUser, executeVirtual, getBarSkeleton, getCmdInfo, getCommunicationType, getCurrentExecutor, getCurrentThreadExecutor, getExecutorRegion, getRequest, getServer, getServerId, getThreadIndex, getTraceId, getUserId, getUserThreadExecutor, getVirtualThreadExecutor, setMethodResult, setUserId

Method Details

getEventBus

default EventBus getEventBus()

ofEventBusMessage

default EventBusMessage ofEventBusMessage(Object eventSource)

fire

default void fire(Object eventSource)

[Async] Sends an event to all subscribers.

Parameters:

eventSource - The event source

fireSync

default void fireSync(Object eventSource)

[Sync] Sends an event to all subscribers.

Parameters:

eventSource - The event source

fireAny

default void fireAny(Object eventSource)

[Async] Sends an event message to subscribers in the current process and remote processes. If multiple logic servers of the same type exist, the event will only be sent to one instance.

Parameters:

eventSource - The event source

fireAnySync

default void fireAnySync(Object eventSource)

Sends an event message to subscribers in the current process and remote processes. If multiple logic servers of the same type exist, the event will only be sent to one instance.

Parameters:

eventSource - The event source

fireLocal

default void fireLocal(Object eventSource)

[Async] Sends an event message to subscribers of all logic servers in the current process.

Parameters:

eventSource - The event source

fireLocalSync

default void fireLocalSync(Object eventSource)

[Sync] Sends an event message to subscribers of all logic servers in the current process.

Parameters:

eventSource - The event source

fireMe

default void fireMe(Object eventSource)

[Async] Sends an event message only to subscribers of the current EventBus.

Parameters:

eventSource - The event source

fireMeSync

default void fireMeSync(Object eventSource)

[Sync] Sends an event message only to subscribers of the current EventBus.

Parameters:

eventSource - The event source