当前位置：文江博客话题详情

在处理 NServiceBus 消息时，是否可以查看输入队列？

发布于 2024-12-06 03:27:30 字数 92 浏览 0 评论 0原文

我有一个使用 NServiceBus 来处理传入消息的 Windows 服务。在处理消息时，我想检查队列中是否还有其他剩余消息需要处理。解决这个问题的最佳方法是什么？

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

柳絮泡泡 2024-12-13 03:27:30

对于这个特定场景，我想说传奇可能是合适的，它是由收到的第一条消息创建的，打开一个超时（假设一分钟），收集该时间段内的所有消息，然后 Bus.SendLocal 是一条消息包含另一个处理程序为其创建电子表格并上传的所有行。

回复收藏 0 原文

遗心遗梦遗幸福 2024-12-13 03:27:30

由于 NServiceBus 使用 MSMQ，因此您可以使用 System.Messaging 中的方法。
其中包括我目前正在研究的一种修改方法，用于进行一种批处理。

using System.Messaging;

public int PeekAtQueue()
{
    const string QUEUE_NAME = "private$\\you_precious_queuname";

    if (!MessageQueue.Exists(".\\" + QUEUE_NAME))
        return 0;

    var messageQueues = MessageQueue.GetPrivateQueuesByMachine(Environment.MachineName);
    var queue = messageQueues.Single(x => x.QueueName == QUEUE_NAME);
    return queue.GetAllMessages().Count();
}

在编辑器中自行修改。希望它仍然可以编译:)
顺便说一句，在这里找到了类似的讨论：

http://jopinblog.wordpress.com/2008/03/12/counting-messages-in-an-msmq-messagequeue-from-c/

Since, NServiceBus is using MSMQ, you can use the methods from System.Messaging.
Included is a modified method, I'm currently working on, to do a kind of batch processing.

using System.Messaging;

public int PeekAtQueue()
{
    const string QUEUE_NAME = "private$\\you_precious_queuname";

    if (!MessageQueue.Exists(".\\" + QUEUE_NAME))
        return 0;

    var messageQueues = MessageQueue.GetPrivateQueuesByMachine(Environment.MachineName);
    var queue = messageQueues.Single(x => x.QueueName == QUEUE_NAME);
    return queue.GetAllMessages().Count();
}

Modified here itself in the editor. Hope it still compiles :)
Found a similar discussion here, by the way:

http://jopinblog.wordpress.com/2008/03/12/counting-messages-in-an-msmq-messagequeue-from-c/

回复收藏 0 原文

~没有更多了~