ActiveMQ - löschen/purge all-queue über die Kommandozeile

Gibt es eine Möglichkeit zu löschen /purge alle Warteschlangen in ActiveMQ über die Kommandozeile (win/linux)?
Ich konnte nur die Befehle für eine bestimmte queue.
Oder vielleicht gibt es eine Möglichkeit, dies zu tun über die activeMQ-admin? Wieder habe ich nur gefunden, wie man löschen/leeren der Warteschlangen eins nach dem anderen, die sehr mühsam sein kann.

Dank!

InformationsquelleAutor Ayelet | 2014-12-03

  1. 14

    Können Sie tun, verändern Sie Ihre activemq.xml ein bisschen:

    <broker deleteAllMessagesOnStartup="true"  ...>

    Dieser arbeitet mit KahaDB message-stores (es hat Probleme mit JDBC message Store), werden alle Nachrichten gelöscht und anschließend Warteschlangen gelöscht werden.

    Wie Sie möchten, dass alle Warteschlangen gelöscht werden, ein Neustart der broker nicht eine kostspielige option, alles zu reinigen.

    Vielen Dank, es funktioniert!
    Es hat mein Leben gerettet, danke!
    willkommen ,froh zu helfen!

    InformationsquelleAutor Vihar

  2. 4

    Entwickelte ich meine eigene ActiveMQ-Befehlszeilen-Dienstprogramm (activemq-cli), um dies zu tun. Sie können es hier finden: https://github.com/antonwierenga/activemq-cli (Befehl 'purge-alle-Warteschlangen "oder" remove-all-queues').

    InformationsquelleAutor Anton

  3. 3

    Ab version 5.0 es sieht aus wie diese kann mithilfe der CLI mit ActiveMQ selbst:

    $ ActiveMQ/bin/activemq purge
    dequeueCount wird nicht aktualisiert, 0. Neustart nach der Säuberung funktioniert.

    InformationsquelleAutor starkos

  4. 0

    Andere Möglichkeit ist das bereitstellen einer kleinen Kamel-route, die in einem container (z.B. Apache ServiceMix) oder einfach durch ausführen eines java-Programms enthalten die route.

    Zum Beispiel hier ist die route, die ich derzeit auf meinem Entwicklungs-Rechner, wo ich auch den ServiceMix installiert:

    <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>

    InformationsquelleAutor рüффп

  5. 0

    1 - gehen Sie zu amq bin-Ordner, in meinem Fall:

    cd /opt/amq/bin

    2 - run-amq-client:

    ./client

    3 - run purge auf die gewünschte Warteschlange

    activemq:purge <QUEUE NAME HERE>

    InformationsquelleAutor Shell_Leko

Schreibe einen Kommentar