gpt4 book ai didi

c# - 如何在队列级别设置 MaxDequeueCount

转载 作者:太空宇宙 更新时间:2023-11-03 21:02:10 24 4
gpt4 key购买 nike

我有一个 Azure WebJob 正在监听多个队列...

我可以在作业级别指定 MaxDequeueCount...

    config.UseTimers();
config.Queues.BatchSize = 32;
config.Queues.MaxDequeueCount = 6;

在队列级别设置 MaxDequeueCounts 的最佳方法是什么?我知道我可以获取实际的出列计数并将其“手动”发送到有毒队列,但我想知道是否可以通过更好的方式来完成...

最佳答案

如果你想为不同的队列触发函数设置不同的配置,你可以实现自己的QueueProcessorFactory,并根据队列名称重置上下文的一些配置。

public class MyQueueProcessorFactory : IQueueProcessorFactory
{
public QueueProcessor Create(QueueProcessorFactoryContext context)
{
if (context == null)
{
throw new ArgumentNullException("context");
}
if (context.Queue.Name == "queue1")
{
context.MaxDequeueCount = 2;
}
else if (context.Queue.Name == "queue2")
{
context.MaxDequeueCount = 4;
}
return new QueueProcessor(context);
}
}

要使用自定义QueueProcessorFactory,我们需要如下设置QueueProcessorFactory属性。

JobHostConfiguration config = new JobHostConfiguration();
config.Queues.QueueProcessorFactory = new MyQueueProcessorFactory();
JobHost host = new JobHost(config);

关于c# - 如何在队列级别设置 MaxDequeueCount,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/44378885/

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com