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

MessageHandlers interface

常规消息处理程序接口(用于 streamMessages)。

方法

processError(ProcessErrorArgs)

处理接收过程中发生的错误的处理程序。

对于在接收方中发生的任何错误,将调用此处理程序

  • 接收消息,或
  • 执行 processMessage 回调,或
  • 成功运行 processMessage 回调并启用 autoCompleteMessages 后,接收方将代表你完成消息
  • 如果运行 processMessage 回调失败并启用 autoCompleteMessages,接收方将代表你放弃该消息
  • 接收方代表你续订锁,因为已启用自动锁定续订功能

请注意,在使用 subscribe()在流中接收消息时,除非订阅上调用了 close(),否则接收方会自动重试接收所有错误的消息。 完全由用户决定哪些错误被视为不可恢复,并在此回调中相应地处理这些错误。 有关服务总线中发生的错误列表,请参阅 https://docs.microsoft.com/javascript/api/@azure/service-bus/servicebuserror?view=azure-node-latest

processMessage(ServiceBusReceivedMessage)

处理来自服务总线的消息的处理程序。

方法详细信息

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>