InboxMiddleware
public class InboxMiddleware implements HarnessRuntimeMiddlewareio/agentscope/harness/agent/middleware/InboxMiddleware.java:53–223收件箱中间件，在智能体执行流程中提供横切扩展。位于 io.agentscope.harness.agent.middleware 包，实现 HarnessRuntimeMiddleware。核心成员包括 onReasoning、InboxMiddleware。
Middleware that drains the message bus inbox before each reasoning step and injects the messages
as HintBlocks into the agent's context.
Producers (e.g. AsyncToolMiddleware, team tools, schedulers) push HintBlock
payloads into the per-session inbox via MessageBus#inboxPush. This middleware drains
them at the start of each reasoning step, appends them to the agent's context, and emits a
HintBlockEvent for each so the front-end event stream can render them in real time.
构造器摘要Constructor Summary
方法摘要Method Summary
构造器详情Constructor Detail
InboxMiddleware
public InboxMiddleware(MessageBus messageBus)初始化 InboxMiddleware 实例。
Creates a new instance.
| 名称Name | 类型Type | 说明Description |
|---|---|---|
messageBus | MessageBus | 消息总线（类型 `MessageBus`）。The message bus. |
io/agentscope/harness/agent/middleware/InboxMiddleware.java:63–65InboxMiddleware
public InboxMiddleware(MessageBus messageBus, int maxDrainCount)初始化 InboxMiddleware 实例。
Creates a new instance.
| 名称Name | 类型Type | 说明Description |
|---|---|---|
messageBus | MessageBus | 消息总线（类型 `MessageBus`）。The message bus. |
maxDrainCount | int | 最大 Drain 数量（类型 `int`）。The max drain count. |
io/agentscope/harness/agent/middleware/InboxMiddleware.java:67–69InboxMiddleware
public InboxMiddleware(MessageBus messageBus, int maxDrainCount, AsyncToolRegistry asyncToolRegistry, Duration staleTtl)初始化 InboxMiddleware 实例。
Creates a new instance.
| 名称Name | 类型Type | 说明Description |
|---|---|---|
messageBus | MessageBus | 消息总线（类型 `MessageBus`）。The message bus. |
maxDrainCount | int | 最大 Drain 数量（类型 `int`）。The max drain count. |
asyncToolRegistry | AsyncToolRegistry | 异步工具注册表（类型 `AsyncToolRegistry`）。The async tool registry. |
staleTtl | Duration | 过期存活时间（类型 `Duration`）。The stale ttl. |
io/agentscope/harness/agent/middleware/InboxMiddleware.java:71–80方法详情Method Detail
onReasoning
public Flux<AgentEvent> onReasoning(Agent agent, RuntimeContext ctx, ReasoningInput input, Function<ReasoningInput, Flux<AgentEvent>> next)处理推理事件。
Performs the on reasoning operation.
| 名称Name | 类型Type | 说明Description |
|---|---|---|
agent | Agent | 智能体（类型 `Agent`）。The agent. |
ctx | RuntimeContext | 运行时上下文（类型 `RuntimeContext`）。The ctx. |
input | ReasoningInput | 输入消息（类型 `ReasoningInput`）。The input. |
next | Function<ReasoningInput, Flux<AgentEvent>> | 下一个（类型 `Function >`）。The next. |
Flux<AgentEvent>io/agentscope/harness/agent/middleware/InboxMiddleware.java:82–180