Поделиться через

MessageHandlers interface

  • Ссылка
Пакет:
@azure/service-bus

Общий интерфейс обработчика сообщений (используется для streamMessages).

Методы

processError(ProcessErrorArgs)

Обработчик, обрабатывающий ошибки, возникающие во время получения.

Этот обработчик будет вызываться для всех ошибок, возникающих в приемнике, когда

  • получение сообщения, или
  • выполнение обратного processMessage вызова, или
  • получатель завершает сообщение от вашего имени после успешного выполнения processMessage обратного вызова и autoCompleteMessages включен
  • получатель отказывается от сообщения от вашего имени, если обратный processMessage вызов завершается сбоем и autoCompleteMessages включен
  • получатель продлевает блокировку от вашего имени из-за включения функции автоматического продления блокировки

Обратите внимание, что при получении сообщений в потоке с помощью subscribe()получатель будет автоматически повторять получение сообщений для всех ошибок, если close() только не вызывается в подписке. Пользователи полностью решают, какие ошибки считаются невосстановимыми, и обрабатывать их соответствующим образом в этом обратном вызове. Список ошибок, возникающих в служебной шине, см. в статье https://docs.microsoft.com/javascript/api/@azure/service-bus/servicebuserror?view=azure-node-latest
processMessage(ServiceBusReceivedMessage)

Обработчик, обрабатывающий сообщения из служебной шины.

Сведения о методе

processError(ProcessErrorArgs)

Обработчик, обрабатывающий ошибки, возникающие во время получения.

Этот обработчик будет вызываться для всех ошибок, возникающих в приемнике, когда

  • получение сообщения, или
  • выполнение обратного processMessage вызова, или
  • получатель завершает сообщение от вашего имени после успешного выполнения processMessage обратного вызова и autoCompleteMessages включен
  • получатель отказывается от сообщения от вашего имени, если обратный processMessage вызов завершается сбоем и autoCompleteMessages включен
  • получатель продлевает блокировку от вашего имени из-за включения функции автоматического продления блокировки

Обратите внимание, что при получении сообщений в потоке с помощью subscribe()получатель будет автоматически повторять получение сообщений для всех ошибок, если close() только не вызывается в подписке. Пользователи полностью решают, какие ошибки считаются невосстановимыми, и обрабатывать их соответствующим образом в этом обратном вызове. Список ошибок, возникающих в служебной шине, см. в статье https://docs.microsoft.com/javascript/api/@azure/service-bus/servicebuserror?view=azure-node-latest

function processError(args: ProcessErrorArgs): Promise<void>

Параметры

args
ProcessErrorArgs

Ошибка и дополнительный контекст для указания места возникновения ошибки.

Возвращаемое значение

Promise<void>

processMessage(ServiceBusReceivedMessage)

Обработчик, обрабатывающий сообщения из служебной шины.

function processMessage(message: ServiceBusReceivedMessage): Promise<void>

Параметры

message
ServiceBusReceivedMessage

Сообщение, полученное из служебной шины.

Возвращаемое значение

Promise<void>