Verschieben von Nachrichten zwischen Warteschlangen rabbitMQ

Ich bin auf der Suche, um in der Lage sein, um Nachrichten zwischen Warteschlangen (manuell), Kaninchen.

Beispiel:

first-queue has messages ['a','b','c','d','e','f']
second-queue has messages ['x','y']

Ich möchte in der Lage sein, sich zu bewegen zum Beispiel Meldung 'eine' second-queue aus der ersten Warteschlange. Dies kann eine manuelle Bedienung. Beide Warteschlangen auf den gleichen broker, und ich will nicht, um Sie zu senden, durch jeden Austausch. Gibt es trotzdem, dies zu tun? Ich Spiele mit rabbitmqctl aber kann nicht scheinen, um es zu arbeiten. Ich bin offen für andere tools, die mir erlauben würde, dies zu erreichen. Schließlich bin ich in der Hoffnung, irgendeine Art von message-selector (zum Beispiel verschieben Sie alle Nachrichten, die mit ein paar header-Feld = X aus der ersten Warteschlange zu der zweiten Warteschlange).

Ich bin noch neu auf rabbitmq und amqp, aber wurden nicht in der Lage zu finden, eine Dokumentation, wie dies zu tun (wenn es überhaupt möglich ist).

Dank.

InformationsquelleAutor Dax Durax | 2014-03-25

  1. 8

    @Dax, ich beantwortete die gleiche Frage hier: Ist es möglich, zu verschieben /Zusammenführen von Nachrichten zwischen dem RabbitMQ-Warteschlangen?

    Habe ich eine lange Beschreibung gibt. Zur Vermeidung von duplicate content, die ich nicht kopieren/einfügen möchte.

    Es klingt wie das, was Sie suchen, ist das rabbitmq-Schaufel-plugin.

    Es ist gebaut in den Kern, einfach aktivieren:

    rabbitmq-plugins enable rabbitmq_shovel
rabbitmq-plugins enable rabbitmq_shovel_management

    Aus dem Admin-Bereich in der GUI finden Sie eine einfache Schnittstelle zum erstellen Schaufeln.

    Siehe andere post für mich Details!

    InformationsquelleAutor rocksfrow

  2. 5

    Die Tatsache, dass es nicht dokumentiert ist, weil es weit Weg von messaging-Modell.

    Es ist leicht zu senden Sie eine Nachricht an eine bestimmte queue - siehe tutorial #1 zum Beispiel - aber der einzige Weg, Nachrichten zu Lesen ist verbrauchen Sie, in der Reihenfolge der Makler verschicken an die Kunden.

    Es ist nicht erlaubt wählen Sie Nachrichten aus einer Warteschlange, wie können Sie mit SQL.

    Was Sie tun können ist, lassen Sie einen client - (oder irgendwann, ein plugin, aber das ist ein Thema für fortgeschrittene) verbrauchen Nachrichten aus einer Warteschlange, und basierend auf einige Regel, die Sie re-veröffentlichen Sie zu einem späteren Warteschlange oder zu einem anderen.

    InformationsquelleAutor Sigismondo

  3. 2

    Hier ist eine einfache java-code zu bewegen, alles aus einer Warteschlange zu einem anderen:

    public void moveMessages(
            final String sourceQueueName,
            final String targetQueueName,
            final String rabbitmqHost,
            final String rabbitmqUsername,
            final String rabbitmqPassword,
            final String rabbitmqVirtualHost
) throws IOException {

        //Initialize the consuming and publishing channel
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost(rabbitmqHost);
        factory.setUsername(rabbitmqUsername);
        factory.setPassword(rabbitmqPassword);
        factory.setVirtualHost(rabbitmqVirtualHost);
        Connection connection = factory.newConnection();

        Channel consumingChannel = connection.createChannel();
        Channel publishingChannel = connection.createChannel();


        while (true) {
            //Get the first message in the queue (auto ack = false)
            GetResponse response = consumingChannel.basicGet(sourceQueueName, false);

            if (response == null) {
                return;
            }

            BasicProperties properties = response.getProps();

            //Publish the message to the origin queue
            publishingChannel.txSelect();
            publishingChannel.basicPublish("", targetQueueName, (AMQP.BasicProperties) properties, response.getBody());
            publishingChannel.txCommit();

            //Acknowledge the message in the dead letter queue
            consumingChannel.basicAck(response.getEnvelope().getDeliveryTag(), false);
        }
    }

    InformationsquelleAutor Nicolas De Nayer

Schreibe einen Kommentar