你当前正在访问 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>