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(