Azure WebJobs SDK的ServiceBusTrigger
的有害消息处理如何工作?我希望将已出队超过“x”次的服务总线队列消息推送到其他ServiceBus(或)存储队列
在线文档here和here以及here的SDK示例没有关于ServiceBusTrigger的毒害消息处理方式的示例。这项工作正在进行吗?
我尝试使用dequeueCount
参数实现自定义有毒消息处理,但是由于我正在获取运行时异常{"Cannot bind parameter 'dequeueCount' when using this trigger."}
,因此它似乎不受ServiceBusTriggers支持
public static void ProcessMessage([ServiceBusTrigger(topicName: "abc", subscriptionName: "abc.gdp")] NotificationMessage message,
[Blob("rox/{PayloadId}", FileAccess.Read)] Stream blobInput, Int32 dequeueCount)
{
throw new ArgumentNullException();
}
最佳答案
虽然您无法获取ServiceBus消息的dequeueCount
属性,但始终可以绑定(bind)到BrokeredMessage
而不是NotificationMessage
并从中获取属性。
关于c# - Azure WebJobs和ServiceBusTrigger,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/28288058/