0

我遇到需要排空 JMS（特别是 Tibco EMS）队列的情况。用例是，如果我们要进行大规模中断，队列会建立起来，处理它会花费很长时间。因此，我们想要排空队列，并执行冷启动类型的例程来获取当前状态。

到目前为止，我要做的代码如下：

 int count = 0;
    Message msg = null;
    while ((msg = connection.receive(timeout)) != null) {
        count++;
    }
    System.out.println(count + " msgs removed from queue: " + queueName);

基本上它会循环接收消息，直到在收到消息之前timeout过期，这表明队列是空的。

我的问题涉及timeout. 假设我们在队列中有一个非常快的生产者，设置一个 500 毫秒的超时似乎有点武断。我们可能会无限循环（即生产者每 500 毫秒产生 >= 1 条消息）

另一种方法是使用 receiveNoWait()。据我了解，这会在消息可用时提取消息，或者返回 null，而不涉及超时。但是，根据这篇文章：

如果您调用 receiveNoWait() 并且代理上可能有消息，并非所有 JMS 提供程序都会立即返回一条消息，因此值得等待一秒钟左右，以确保队列确实已耗尽。

那么有没有更强大的方法可以从程序化方法中做到这一点？或者，Tibco EMS 管理员是否有排水功能？

4

2 回答 2

3

在 TIBCO EMS Admin 中，您只需发出命令

PURGE QUEUE <queue name>

从中删除所有消息。对于多个队列，您可以执行

PURGE ALL QUEUES <pattern using '>' and '*' as wildcards>

请注意，除了 EMS Admin 的命令行界面外，还有一个 Java-API 可以直接从 Java 程序内部发出此类 Admin 命令。

于 2014-02-14T18:40:52.550 回答
0

如果在特定时间段后不需要消息，您可以设置消息的过期时间。这将确保消息在过期后离开队列。除了到期之外，还可以使用带有超时的简单接收（）调用。如果队列中有消息，接收将起作用。如果消息处于未提交状态或被某个进程锁定，那么接收调用将无法获取该消息。

于 2014-02-15T00:27:52.963 回答