使用 HornetQ 在 JBOSS 7 中清空 jms 队列

Question

我正在使用 jboss 7.1.1 final 和 HornetQ 2.2.13 final。

我配置了几个队列，其中一个是“满”消息，几千条。我无法删除这些消息。

我尝试使用 jboss cli 和命令删除它们 /subsystem=messaging/hornetq-server=default/jms-queue=Queue:remove-messages

它响应成功，但消息仍然存在......

我尝试使用带有 jmx 命令的 JConsole 删除它们。它以数字零响应，并且计数消息仍然相同。

我尝试在 Jboss 控制台中删除队列并重新启动 AS。再次配置队列后，消息仍然存在，导致其持久化。

唯一可行的方法是配置 hornetq 服务器以禁用standalone.xml 中的持久性。

有人知道如何使用 jconsole 或 jboss cli 吗？

Answer 1

你所要做的就是调用方法：

来自 jboss-cli：

/subsystem=messaging/hornetq-server=default/jms-queue=testQueue:remove-messages

我刚刚通过添加大量消息（包括分页）尝试了您尝试过的确切版本。并且一切正常。

我将系统配置为分页，并使用它创建了几千条消息：

  HornetQConnectionFactory cf = HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.CF, new TransportConfiguration(NETTY_CONNECTOR_FACTORY));
  Connection conn = cf.createConnection("guest", "hello");
  Session sess = conn.createSession(true, Session.SESSION_TRANSACTED);
  javax.jms.Queue queue = sess.createQueue("testQueue");
  MessageProducer prod = sess.createProducer(queue);

  for (int i = 0 ; i < 50000; i++)
  {
     TextMessage msg = sess.createTextMessage("hello " + i);
     prod.send(msg);
     if (i % 500 == 0)
     {
        System.out.println("Sent " + i);
        System.out.println("commit");
        sess.commit();
     }
  }
  sess.commit();
  conn.close();

然后我尝试了 remove 方法，它成功了：

/subsystem=messaging/hornetq-server=default/jms-queue=testQueue:remove-messages

如果这不起作用，有两种可能性：

• 我们更改了在传递过程中锁定队列的方式。也许您遇到了一个已修复的错误，您将不得不迁移到更新的版本。

• 您在消费者的交付中有队列。如果消息处于传递状态的消费者缓冲区中，我们无法删除消息。您必须删除消费者才能删除所有消息。

我在这里添加了这个答案，因为我做了很多研究试图复制你的问题，而且一切都像一个魅力。我需要更多关于发生了什么的信息。

我认为最好的是用户论坛，我们可以在其中进一步讨论。 SOF 将进行简单的问题/答案。这不是调查错误或类似问题的地方。

https://community.jboss.org/en/hornetq?view=discussions