Вызов IQueueClient.CompleteAsyn c () из ServiceBus из другого потока всегда дает сбой

Question

Я получаю из очереди, используя IQueueClient.RegisterMessageHandler(), и в методе получения я запускаю задачу Hangfire. Но в задаче Hangfire все вызовы IQueueClient.CompleteAsync(), чтобы пометить сообщение как использованное (потому что я использую режим ReceiveMode.PeekLock), терпят неудачу.

Я подозреваю, что это из-за того, что задача Hangfire воссоздает IQueueClient, может быть потому, что вызов CompleteAsync() происходит из другого экземпляра IQueueClient? Или что-то еще может пойти не так? Я передаю Message.SystemProperties.LockToken в задачу Hangfire, которая затем используется CompleteAsync.

Answer 1

Я подозреваю, что это потому, что задача Hangfire заново создает IQueueClient, возможно, потому что вызов CompleteAsyn c () происходит из другого экземпляра IQueueClient?

Это правильно. LockToken недостаточно для завершения сообщения. Вы должны использовать тот же клиент, который использовался для получения сообщения, чтобы завершить его.