MessageHandlers interface
Ogólny interfejs obsługi komunikatów (używany do funkcji streamMessages).
Metody
process |
Program obsługi, który przetwarza błędy występujące podczas odbierania. Ta procedura obsługi zostanie wywołana dla każdego błędu, który występuje w odbiorniku, gdy
Należy pamiętać, że podczas odbierania komunikatów w strumieniu przy użyciu programu |
process |
Program obsługi, który przetwarza komunikaty z usługi Service Bus. |
Szczegóły metody
processError(ProcessErrorArgs)
Program obsługi, który przetwarza błędy występujące podczas odbierania.
Ta procedura obsługi zostanie wywołana dla każdego błędu, który występuje w odbiorniku, gdy
- odbieranie komunikatu lub
- wykonywanie
processMessage
wywołania zwrotnego lub - odbiornik kończy komunikat w Twoim imieniu po pomyślnym uruchomieniu
processMessage
wywołania zwrotnego iautoCompleteMessages
jest włączony - odbiornik porzuca komunikat w Twoim imieniu, jeśli uruchomienie
processMessage
wywołania zwrotnego nie powiedzie się iautoCompleteMessages
jest włączone - odbiornik odnawia blokadę w Twoim imieniu z powodu włączenia funkcji automatycznego odnawiania blokady
Należy pamiętać, że podczas odbierania komunikatów w strumieniu przy użyciu programu subscribe()
odbiornik automatycznie ponowi próbę odebrania komunikatów o wszystkich błędach, chyba że close()
zostanie wywołana w ramach subskrypcji. Do użytkowników należy całkowicie zdecydować, jakie błędy są uznawane za nieodzyszczalne i odpowiednio obsługiwać je w tym wywołaniu zwrotnym.
Aby uzyskać listę błędów występujących w usłudze Service Bus, zapoznaj się z artykułem https://docs.microsoft.com/javascript/api/@azure/service-bus/servicebuserror?view=azure-node-latest
function processError(args: ProcessErrorArgs): Promise<void>
Parametry
- args
- ProcessErrorArgs
Błąd i dodatkowy kontekst wskazujący, skąd pochodzi błąd.
Zwraca
Promise<void>
processMessage(ServiceBusReceivedMessage)
Program obsługi, który przetwarza komunikaty z usługi Service Bus.
function processMessage(message: ServiceBusReceivedMessage): Promise<void>
Parametry
- message
- ServiceBusReceivedMessage
Komunikat odebrany z usługi Service Bus.
Zwraca
Promise<void>