你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn。
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>