MessageHandlers interface
Obecné rozhraní obslužné rutiny zpráv (používá se pro streamMessages).
Metody
process |
Obslužná rutina, která zpracovává chyby, ke kterým dochází během příjmu. Tato obslužná rutina bude volána pro všechny chyby, ke kterým dojde v přijímači
Všimněte si, že při přijímání zpráv ve streamu pomocí |
process |
Obslužná rutina, která zpracovává zprávy ze služby Service Bus. |
Podrobnosti metody
processError(ProcessErrorArgs)
Obslužná rutina, která zpracovává chyby, ke kterým dochází během příjmu.
Tato obslužná rutina bude volána pro všechny chyby, ke kterým dojde v přijímači
- příjem zprávy nebo
- provádění zpětného
processMessage
volání nebo - příjemce dokončí zprávu vaším jménem po úspěšném spuštění
processMessage
zpětného volání aautoCompleteMessages
je povolená - pokud se spuštění zpětného volání nezdaří a je povolené, příjemce zprávu opouští vaším jménem
processMessage
.autoCompleteMessages
- příjemce prodlužuje zámek vaším jménem kvůli povolení funkce automatického obnovení zámku
Všimněte si, že při přijímání zpráv ve streamu pomocí subscribe()
se příjemce automaticky pokusí znovu přijmout zprávy u všech chyb, pokud close()
není v odběru volána. Je zcela na uživatelích, aby se rozhodli, které chyby se považují za neobnovitelné, a aby je v tomto zpětném volání odpovídajícím způsobem zpracovávali.
Seznam chyb, ke kterému dochází ve službě Service Bus, najdete v tématu https://docs.microsoft.com/javascript/api/@azure/service-bus/servicebuserror?view=azure-node-latest
function processError(args: ProcessErrorArgs): Promise<void>
Parametry
- args
- ProcessErrorArgs
Chyba a další kontext označující původ chyby.
Návraty
Promise<void>
processMessage(ServiceBusReceivedMessage)
Obslužná rutina, která zpracovává zprávy ze služby Service Bus.
function processMessage(message: ServiceBusReceivedMessage): Promise<void>
Parametry
- message
- ServiceBusReceivedMessage
Zpráva přijatá ze služby Service Bus
Návraty
Promise<void>