ChannelWorkBridge
@Component @EnableScheduling public class ChannelWorkBridge源码Source
io/agentscope/builder/web/managed/ChannelWorkBridge.java:41–186渠道 Work Bridge，承载智能体的部署、调度与服务化运行。位于 io.agentscope.builder.web.managed 包。核心成员包括 receive、deliverPending、ChannelWorkBridge。
Authenticated, durable work intake. The control plane resolves the human identity and target.
构造器摘要Constructor Summary
| 构造器Constructor | 说明Description |
|---|---|
public ChannelWorkBridge(WebClient control, ManagedSessionChannelBridge chat, ChannelManager channels) | 初始化 `ChannelWorkBridge` 实例。 Creates a new instance. |
方法摘要Method Summary
| 方法Method | 说明Description |
|---|---|
public Mono<Msg> receive(InboundMessage in) | 设置接收。 Performs the receive operation. |
public void deliverPending() | 执行 `deliverPending` 方法。 A claimed delivery is never reported as accepted until the provider returns a message ID. |
构造器详情Constructor Detail
ChannelWorkBridge
public ChannelWorkBridge(WebClient control, ManagedSessionChannelBridge chat, ChannelManager channels)初始化 ChannelWorkBridge 实例。
Creates a new instance.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
control | WebClient | control（类型 `WebClient`）。The control. |
chat | ManagedSessionChannelBridge | 聊天（类型 `ManagedSessionChannelBridge`）。The chat. |
channels | ChannelManager | 渠道（类型 `ChannelManager`）。The channels. |
源码Source
io/agentscope/builder/web/managed/ChannelWorkBridge.java:49–56方法详情Method Detail
receive
public Mono<Msg> receive(InboundMessage in)设置接收。
Performs the receive operation.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
in | InboundMessage | in（类型 `InboundMessage`）。The in. |
Mono<Msg>返回Mono。Returns mono.
源码Source
io/agentscope/builder/web/managed/ChannelWorkBridge.java:58–100deliverPending
public void deliverPending()执行 deliverPending 方法。
A claimed delivery is never reported as accepted until the provider returns a message ID.
源码Source
io/agentscope/builder/web/managed/ChannelWorkBridge.java:103–150