Class FlowEventBusBridge

java.lang.Object

cloud.opencode.base.flow.internal.FlowEventBusBridge

public final class FlowEventBusBridge
extends Object

Cross-package bridge into the package-private FlowEventBus so the operation/ package can publish domain events without exposing the underlying bus type. 跨包桥接到包私有 FlowEventBus，让 operation/ 包能发布领域事件。

Since:

JDK 25, opencode-base-flow V1.0.5

Author:

Leon Soo

Method Summary

Modifier and Type	Method	Description
static void	publishCirculated(String instanceId, String taskId, String fromUserId, List<String> toUserIds)	Publish a task-circulated event (best-effort).
static void	publishCompleted(String instanceId, String flowKey, InstanceStatus status)	Publish a flow-completed event (best-effort).
static void	publishStarted(String instanceId, String flowKey, String initiatorId)	Publish a flow-started event (best-effort).

Methods inherited from class Object

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

Method Details

publishStarted

public static void publishStarted(String instanceId,
 String flowKey,
 String initiatorId)

Publish a flow-started event (best-effort). 发布 flow-started 事件（best-effort）。

Parameters:

instanceId - instance id — 实例 ID

flowKey - business key — 业务 key

initiatorId - initiator user id — 发起人

Since:

JDK 25, opencode-base-flow V1.0.5

publishCompleted

public static void publishCompleted(String instanceId,
 String flowKey,
 InstanceStatus status)

Publish a flow-completed event (best-effort). 发布 flow-completed 事件（best-effort）。

Parameters:

instanceId - instance id — 实例 ID

flowKey - business key — 业务 key

status - terminal status — 终态

Since:

JDK 25, opencode-base-flow V1.0.5

publishCirculated

public static void publishCirculated(String instanceId,
 String taskId,
 String fromUserId,
 List<String> toUserIds)

Publish a task-circulated event (best-effort). 发布 task-circulated 事件（best-effort）。

Parameters:

instanceId - instance id — 实例 ID

taskId - related task id — 关联任务

fromUserId - caller user id — 调用者

toUserIds - notify list — 被抄送 userId 列表

Since:

JDK 25, opencode-base-flow V1.0.5