我正在尝试使用ScheduledEnqueueTimeUtc来调度消息以供将来处理,但Peek只返回活动和延迟消息。
这是我用来偷看消息的代码:
public static async Task<IEnumerable<BrokeredMessage>> GetMessagesAsync(string connectionString, string queueName, int take)
{
var queue = QueueClient.CreateFromConnectionString(connectionString, que
我有一个MSMQ应用程序设置,其中数据被推入一个队列。最初,我只有一个读取和处理它的进程。由于卷增加了,我启动了多个进程来读取它,这基本上是我的原始进程的一个新实例。我没有看到任何错误,但性能确实下降了。我的理解是,每个进程将从队列中读取并接收尚未处理的新消息,然后继续该消息。这是正确的还是有可能多个进程最终处理相同的消息?
Dim q As MessageQueue
If MessageQueue.Exists(".\private$\MsgsIQueue") Then
q = New MessageQueue(".\private$\