Skip to content

Commit

Permalink
DEV-4420
Browse files Browse the repository at this point in the history
  • Loading branch information
i.navrotskyj committed Aug 20, 2024
1 parent 931b082 commit dfa3ba7
Showing 1 changed file with 11 additions and 3 deletions.
14 changes: 11 additions & 3 deletions queue/schema.go
Original file line number Diff line number Diff line change
Expand Up @@ -40,10 +40,18 @@ func (qm *QueueManager) StartProcessingForm(schemaId int, att *Attempt) {
return
}
att.processingForm = pf
e := NewNextFormEvent(att, att.agent.UserId())
appErr := qm.mq.AgentChannelEvent(att.channel, att.domainId, att.QueueId(), att.agent.UserId(), e)

// TODO DEV-4420, implement mx
agent := att.Agent()
if agent == nil {
att.Log("set form error: not found agent")
return
}

e := NewNextFormEvent(att, agent.UserId())
appErr := qm.mq.AgentChannelEvent(att.channel, att.domainId, att.QueueId(), agent.UserId(), e)
if appErr != nil {
wlog.Error(err.Error())
wlog.Error(appErr.Error())
}
}

Expand Down

0 comments on commit dfa3ba7

Please sign in to comment.