Блог

Я создаю прослушиватель, следуя руководству amqplite, в качестве сервера клиента servicebus

Я могу успешно отправить сообщение на свой сервер, но не могу получить сообщение с ошибкой:

Не удалось восстановить идентификатор сеанса от брокера. Пожалуйста, повторите попытку.
в Microsoft.Azure.ServiceBus.SessionClient.d__37.MoveNext()
в System.Runtime.Службы исключений.ExceptionDispatchInfo.Throw()
в Microsoft.Azure.ServiceBus.SessionReceivePump.d__21.MoveNext()

Код получателя выглядит следующим образом:

 using Microsoft.Azure.ServiceBus;

        public async Task TestAMQP()
        {
            var client = new QueueClient("Endpoint=sb://127.0.0.1/;SharedAccessKeyName=xxx;SharedAccessKey=xxx;TransportType=Amqp",
                 "q1");

            client.RegisterSessionHandler(
               this.NotificationHandler,
               new SessionHandlerOptions(this.ExceptionHandler)
               {
                   ...
               });
         ...
        }

        private Task ExceptionHandler(ExceptionReceivedEventArgs arg)
        {
            return Task.CompletedTask;
        }
 

И затем я получаю ошибку в этом обработчике исключений.

Поскольку клиентский SDK Microsoft.AzureWebjobs.Extensions.ServiceBus для меня является полностью черным ящиком, я не могу найти, что происходит с этим сообщением.

Я пропустил какую-то информацию, которую сервер должен отправить обратно клиенту?