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

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>