Partilhar via

MessageHandlers interface

  • Referência
Pacote:
@azure/service-bus

A interface geral do processador de mensagens (utilizada para streamMessages).

Métodos

processError(ProcessErrorArgs)

Processador que processa erros que ocorrem durante a receção.

Este processador será chamado para qualquer erro que ocorra no recetor quando

  • a receber a mensagem ou
  • executar a chamada processMessage de retorno ou
  • o recetor está a concluir a mensagem em seu nome depois de executar com êxito a chamada processMessage de retorno e autoCompleteMessages está ativada
  • o recetor está a abandonar a mensagem em seu nome se a execução processMessage da chamada de retorno falhar e autoCompleteMessages estiver ativada
  • o recetor está a renovar o bloqueio em seu nome devido à funcionalidade de renovação do bloqueio automático estar ativada

Tenha em atenção que, ao receber mensagens num fluxo com subscribe()o , o recetor repetirá automaticamente a receção de mensagens em todos os erros, a menos que seja close() chamada na subscrição. Cabe aos utilizadores decidir que erros são considerados não recuperáveis e processá-los em conformidade nesta chamada de retorno. Para obter uma lista de erros no Service Bus, veja https://docs.microsoft.com/javascript/api/@azure/service-bus/servicebuserror?view=azure-node-latest
processMessage(ServiceBusReceivedMessage)

Processador que processa mensagens do service bus.

Detalhes de Método

processError(ProcessErrorArgs)

Processador que processa erros que ocorrem durante a receção.

Este processador será chamado para qualquer erro que ocorra no recetor quando

  • a receber a mensagem ou
  • executar a chamada processMessage de retorno ou
  • o recetor está a concluir a mensagem em seu nome depois de executar com êxito a chamada processMessage de retorno e autoCompleteMessages está ativada
  • o recetor está a abandonar a mensagem em seu nome se a execução processMessage da chamada de retorno falhar e autoCompleteMessages estiver ativada
  • o recetor está a renovar o bloqueio em seu nome devido à funcionalidade de renovação do bloqueio automático estar ativada

Tenha em atenção que, ao receber mensagens num fluxo com subscribe()o , o recetor repetirá automaticamente a receção de mensagens em todos os erros, a menos que seja close() chamada na subscrição. Cabe aos utilizadores decidir que erros são considerados não recuperáveis e processá-los em conformidade nesta chamada de retorno. Para obter uma lista de erros no Service Bus, veja https://docs.microsoft.com/javascript/api/@azure/service-bus/servicebuserror?view=azure-node-latest

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

Parâmetros

args
ProcessErrorArgs

O erro e o contexto adicional para indicar a origem do erro.

Devoluções

Promise<void>

processMessage(ServiceBusReceivedMessage)

Processador que processa mensagens do service bus.

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

Parâmetros

message
ServiceBusReceivedMessage

Uma mensagem recebida do Service Bus.

Devoluções

Promise<void>