MessageHandlers interface
用於 streamMessages) 的一般訊息處理常式介面 (。
方法
process |
處理常式,處理在接收期間發生的錯誤。 當接收者發生任何錯誤時,將會呼叫此處理程式
請注意,使用 |
process |
處理來自服務匯流排之訊息的處理常式。 |
方法詳細資料
processError(ProcessErrorArgs)
處理常式,處理在接收期間發生的錯誤。
當接收者發生任何錯誤時,將會呼叫此處理程式
- 接收訊息,或
- 執行您的
processMessage
回呼,或 - 成功執行回
processMessage
autoCompleteMessages
呼並啟用之後,接收者會代表您完成訊息 - 如果執行回
processMessage
呼失敗且autoCompleteMessages
已啟用,接收者會代表您放棄訊息 - 接收者正在代表您更新鎖定,因為已啟用自動鎖定更新功能
請注意,使用 subscribe()
在資料流程中接收訊息時,除非在訂用帳戶上呼叫 ,否則 close()
接收者會自動重試接收所有錯誤的訊息。 完全由使用者決定哪些錯誤被視為不可復原,並據以在此回呼中處理錯誤。
如需服務匯流排內發生的錯誤清單,請參閱 https://docs.microsoft.com/javascript/api/@azure/service-bus/servicebuserror?view=azure-node-latest
function processError(args: ProcessErrorArgs): Promise<void>
參數
- args
- ProcessErrorArgs
錯誤和其他內容,用來指出錯誤的來源。
傳回
Promise<void>
processMessage(ServiceBusReceivedMessage)
處理來自服務匯流排之訊息的處理常式。
function processMessage(message: ServiceBusReceivedMessage): Promise<void>
參數
- message
- ServiceBusReceivedMessage
從服務匯流排接收的訊息。
傳回
Promise<void>