Azure WebJobs SDK的ServiceBusTrigger的有害消息处理如何工作?我希望将已出队超过“x”次的服务总线队列消息推送到其他ServiceBus(或)存储队列

在线文档herehere以及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/

10-11 04:14