From ea60b743e5ec3a3a8e362f8e626cccd3239e02dc Mon Sep 17 00:00:00 2001 From: colvin Date: Mon, 23 Mar 2026 17:06:23 +0800 Subject: [PATCH] fix(agent): requeue non-steering messages back to inbound instead of outbound --- pkg/agent/loop.go | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/pkg/agent/loop.go b/pkg/agent/loop.go index 840aa8fa1..15b4db517 100644 --- a/pkg/agent/loop.go +++ b/pkg/agent/loop.go @@ -1361,11 +1361,7 @@ func (al *AgentLoop) requeueInboundMessage(msg bus.InboundMessage) error { } pubCtx, cancel := context.WithTimeout(context.Background(), time.Second) defer cancel() - return al.bus.PublishOutbound(pubCtx, bus.OutboundMessage{ - Channel: msg.Channel, - ChatID: msg.ChatID, - Content: msg.Content, - }) + return al.bus.PublishInbound(pubCtx, msg) } func (al *AgentLoop) processSystemMessage(