MessageHandlers interface
Ogólny interfejs obsługi komunikatów (używany dla funkcji streamMessages).
Metody
| process |
Procedura obsługi, która przetwarza błędy występujące podczas odbierania. Ta procedura obsługi zostanie wywołana dla dowolnego błędu występującego w odbiorniku, gdy
Należy pamiętać, że w przypadku odbierania komunikatów w strumieniu przy użyciu |
| process |
Procedura obsługi, która przetwarza komunikaty z usługi Service Bus. |
Szczegóły metody
processError(ProcessErrorArgs)
Procedura obsługi, która przetwarza błędy występujące podczas odbierania.
Ta procedura obsługi zostanie wywołana dla dowolnego błędu występującego w odbiorniku, gdy
- odbieranie komunikatu lub
- wykonywanie wywołania zwrotnego
processMessagelub - odbiornik kończy komunikat w Twoim imieniu po pomyślnym uruchomieniu wywołania zwrotnego
processMessageiautoCompleteMessagesjest włączony - odbiornik porzuca komunikat w Twoim imieniu, jeśli uruchomienie wywołania zwrotnego
processMessagezakończy się niepowodzeniem, aautoCompleteMessagesjest włączona - odbiornik odnawia blokadę w Twoim imieniu z powodu włączenia funkcji automatycznego odnawiania blokady
Należy pamiętać, że w przypadku odbierania komunikatów w strumieniu przy użyciu subscribe()odbiornik automatycznie ponowi próbę odbierania komunikatów we wszystkich błędach, chyba że close() zostanie wywołana w ramach subskrypcji. Całkowicie zależy to od użytkowników, aby zdecydować, jakie błędy są uznawane za niemożliwe do odzyskania 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 tematem 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)
Procedura obsługi, która 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>