fix(agent): requeue non-steering messages back to inbound instead of outbound
This commit is contained in:
parent
3500080abb
commit
ea60b743e5
1 changed files with 1 additions and 5 deletions
|
|
@ -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(
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue