Исключение служебной шины Azure при попытке завершить сообщение ⇐ C#

[Anonymous]

Я использую пример GitHub для обработки сообщений темы:

Код: Выделить всё

private void RegisterSubscriptionClientMessageHandler()
{
_subscriptionClient.RegisterMessageHandler(
async (message, token) =>
{
var eventName = $"{message.Label}{INTEGRATION_EVENT_SUFIX}";
var messageData = Encoding.UTF8.GetString(message.Body);
await ProcessEvent(eventName, messageData);

// Complete the message so that it is not received again.
await _subscriptionClient.CompleteAsync(message.SystemProperties.LockToken);
},
new MessageHandlerOptions(ExceptionReceivedHandler) { MaxConcurrentCalls = 10, AutoComplete = false });
}

Все сообщения отправляются и принимаются всеми подписчиками успешно, однако в команде:

Код: Выделить всё

await _subscriptionClient.CompleteAsync(message.SystemProperties.LockToken);

Всегда возникает следующая ошибка:

Код: Выделить всё

 ERROR ON ExceptionReceivedHandler EXEPTION: The lock supplied is invalid. Either the lock expired, or the message has already been removed from the queue, or was received by a different receiver instance.
Bazinga.EventBus.Bus.EventBusSubscription:Error: ERROR ON ExceptionReceivedHandler EXEPTION: The lock supplied is invalid. Either the lock expired, or the message has already been removed from the queue, or was received by a different receiver instance.
- Executing Action: UserCallback

Есть какие-нибудь советы по решению? Спасибо!

Подробнее здесь: https://stackoverflow.com/questions/521 ... te-message