fix(agent): restore topic helper for exec context
This commit is contained in:
parent
0f7c1b1a78
commit
d981a2d68b
1 changed files with 7 additions and 0 deletions
|
|
@ -227,6 +227,13 @@ func (al *AgentLoop) allocateRouteSession(route routing.ResolvedRoute, msg bus.I
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func originTopicID(origin *bus.InboundContext) string {
|
||||||
|
if origin == nil {
|
||||||
|
return ""
|
||||||
|
}
|
||||||
|
return strings.TrimSpace(origin.TopicID)
|
||||||
|
}
|
||||||
|
|
||||||
func (al *AgentLoop) processSystemMessage(
|
func (al *AgentLoop) processSystemMessage(
|
||||||
ctx context.Context,
|
ctx context.Context,
|
||||||
msg bus.InboundMessage,
|
msg bus.InboundMessage,
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue