ActiveMQ - 通过命令行删除/清除所有队列

Question

有没有办法通过命令行（win/linux）删除/清除ActiveMQ中的所有队列？ 我只能找到特定队列的命令。 或者也许有办法通过activeMQ管理员来做到这一点？再次，我只发现如何删除/清除队列中的一个接一个，这可能非常乏味。

谢谢！

Answer 1

你可以做调整你的activemq.xml一点：

<broker deleteAllMessagesOnStartup="true" ...> 

这适用于KahaDB邮件存储（它与JDBC消息存储问题），所有的邮件被删除，随后队列被清除。

由于您希望删除所有队列，因此重新启动代理并不是成本高昂的选项，无法清理所有内容。

Answer 2

我开发了我自己的ActiveMQ命令行实用程序（activemq-cli）来执行此操作。你可以在这里找到它：https://github.com/antonwierenga/activemq-cli（命令'清除所有队列'或'删除所有队列'）。

Answer 3

另一种可能性是在一个容器（例如Apache ServiceMix）中部署一个小型骆驼路由，或者只是通过执行一个包含该路由的java程序。

例如，下面是我目前我的开发计算机上使用的路线，我也已经安装了ServiceMix的：

<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xmlns:ext="http://aries.apache.org/blueprint/xmlns/blueprint-ext/v1.0.0" 
    xmlns:cm="http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.1.0" 
    xsi:schemaLocation=" 
     http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd 
     http://camel.apache.org/schema/blueprint http://camel.apache.org/schema/blueprint/camel-blueprint.xsd 
     http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.1.0 http://aries.apache.org/schemas/blueprint-cm/blueprint-cm-1.1.0.xsd"> 

    <cm:property-placeholder persistent-id="amq.cleanup" update-strategy="reload"> 
     <cm:default-properties> 
      <cm:property name="amq.local.url" value="tcp://localhost:61616" /> 
     </cm:default-properties> 
    </cm:property-placeholder> 

    <camelContext xmlns="http://camel.apache.org/schema/blueprint"> 
     <onException useOriginalMessage="true"> 
      <exception>java.lang.Exception</exception> 
      <handled> 
       <constant>true</constant> 
      </handled> 
      <to uri="activemq:queue:CLEANUP_DLQ" /> 
     </onException> 

     <route id="drop-all-queues" autoStartup="true"> 
      <from uri="activemq:queue:*.>" /> 
      <stop/> 
     </route> 
    </camelContext> 

    <bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent"> 
     <property name="brokerURL" value="${amq.local.url}" /> 
    </bean> 
</blueprint> 

Answer 4

截至5.0，它看起来像这个版本可以done using the CLI provided with ActiveMQ本身：

$ ActiveMQ/bin/activemq purge