我想确定如果队列中已经存在相同的消息,那么在webjob
处理第一条消息时应该忽略第二条消息(不插入队列)。
我尝试了以下代码:
var namespaceManager =
NamespaceManager.CreateFromConnectionString(connectionString);
if (!namespaceManager.QueueExists(queueName))
{
namespaceManager.CreateQueue(new QueueDescription(queueName) { RequiresDuplicateDetection = true });
}
属性RequiresDuplicateDetection
应确保重复消息。
// Get messageFactory for runtime operation
MessagingFactory messagingFactory = MessagingFactory.CreateFromConnectionString(connectionString);
QueueClient queueClient = messagingFactory.CreateQueueClient("TestQueue");
BrokeredMessage message = new BrokeredMessage();
message.MessageId = "Localization";
queueClient.Send(message);
但是webjob
会为每个 messageId 触发。我给了睡眠时间 150000 毫秒,但在此之前我尝试将相同的消息插入到同一个队列中,由于重复的消息,不应插入该队列。
我尝试了MSDN,但它在 Azure Webjob 中不起作用。
网络作业代码:
public static void ProcessQueueMessage([ServiceBusTrigger("TestQueue")] BrokeredMessage message, TextWriter log)
{
log.WriteLine("Webjob Start" + message.MessageId + DateTime.Now);
Thread.Sleep(150000);
log.WriteLine("Webjob End" + message.MessageId + DateTime.Now);
}