diff --git a/queue/chat_inbound.go b/queue/chat_inbound.go index 89cb04ef..2a67ceb7 100644 --- a/queue/chat_inbound.go +++ b/queue/chat_inbound.go @@ -103,8 +103,13 @@ func (queue *InboundChatQueue) process(attempt *Attempt, inviterId, invUserId st conv, err = queue.ChatManager().NewConversation(queue.domainId, *attempt.MemberCallId(), inviterId, invUserId, model.UnionStringMaps(attempt.ExportVariables(), queue.variables)) if err != nil { - //FIXME attempt.Log(err.Error()) + queue.queueManager.Abandoned(attempt) + go func() { + attempt.Emit(AttemptHookLeaving) + attempt.Off("*") + }() + return } loop := conv.Active()