MessageHandlers interface
A interface geral do manipulador de mensagens (usada para streamMessages).
Métodos
process |
Manipulador que processa erros que ocorrem durante o recebimento. Esse manipulador será chamado para qualquer erro que ocorra no receptor quando
Observe que, ao receber mensagens em um fluxo usando |
process |
Manipulador que processa mensagens do barramento de serviço. |
Detalhes do método
processError(ProcessErrorArgs)
Manipulador que processa erros que ocorrem durante o recebimento.
Esse manipulador será chamado para qualquer erro que ocorra no receptor quando
- recebendo a mensagem ou
- executando o
processMessage
retorno de chamada ou - o receptor está concluindo a mensagem em seu nome depois de executar com êxito o
processMessage
retorno de chamada eautoCompleteMessages
está habilitado - O receptor está abandonando a mensagem em seu nome se a execução
processMessage
do retorno de chamada falhar eautoCompleteMessages
estiver habilitada - receiver está renovando o bloqueio em seu nome devido ao recurso de renovação de bloqueio automático que está sendo habilitado
Observe que, ao receber mensagens em um fluxo usando subscribe()
, o receptor tentará automaticamente receber mensagens em todos os erros, a menos que close()
seja chamado na assinatura. Cabe aos usuários decidir quais erros são considerados não recuperáveis e tratá-los adequadamente neste retorno de chamada.
Para obter uma lista de erros no Barramento de Serviço, consulte 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.
Retornos
Promise<void>
processMessage(ServiceBusReceivedMessage)
Manipulador que processa mensagens do barramento de serviço.
function processMessage(message: ServiceBusReceivedMessage): Promise<void>
Parâmetros
- message
- ServiceBusReceivedMessage
Uma mensagem recebida do Barramento de Serviço.
Retornos
Promise<void>