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>