rabbitmq-dump-queue

Dump messages from a RabbitMQ queue to files, without affecting the queue.

This work is derivated from https://github.com/dubek/rabbitmq-dump-queue

Installation

Compile from source

If you have Go installed, you can install rabbitmq-dump-queue from source by running:

go get github.com/luneo7/rabbitmq-dump-queue

The rabbitmq-dump-queue executable will be created in the $GOPATH/bin directory.

Usage

To dump the first 50 messages of queue incoming_1 to /tmp:

rabbitmq-dump-queue -uri="amqp://user:[email protected]:5672/" -queue=incoming_1 -max-messages=50 -output-dir=/tmp

This will create the files /tmp/msg-0000.json, /tmp/msg-0001.json, and so on.

The output filenames are printed one per line to the standard output; this allows piping the output of rabbitmq-dump-queue to xargs or similar utilities in order to perform further processing on each message (e.g. decompressing, decoding, etc.).

By default, it will not acknowledge messages, so they will be requeued. Acknowledging messages using the -ack=true switch will remove them from the queue, allowing the user to process new messages (see implementation details).

rabbitmq-dump-queue -uri="amqp://user:[email protected]:5672/" -queue=incoming_1 -max-messages=50 -output-dir=/tmp -ack=true

If you want to acknowledge a list of specific messages you can create a JSON file with the following structure

{
    "messages": [
        {
            "routingKey" : "testEvent",
            "containsString" : "[email protected]",
            "contains" : [
                {
                    "key": "fieldKeyInContent1",
                    "value": "fieldValueInContent"
                },
                {
                    "key": "fieldKeyInContent2",
                    "value": 12345
                },
                {
                    "key": "fieldKeyInContent3",
                    "value": true
                }
            ]
        }
    ]
}

In the above JSON routingKey is mandatory, containsString and contains are optional. So you can have only containsString or contains with the proper values. To use the acknowledge json file you should use the -messages-to-ack parameter:

rabbitmq-dump-queue -uri="amqp://user:[email protected]:5672/" -queue=incoming_1 -max-messages=50 -output-dir=/tmp -messages-to-ack=/tmp/ackmessages.json

rabbitmq-dump-queue is expecting a JSON response in the content of the message if it's not the case you can disable it with json-content paramater

rabbitmq-dump-queue -uri="amqp://user:[email protected]:5672/" -queue=incoming_1 -max-messages=50 -output-dir=/tmp -json-content=false

If you want to post a directory with dumped rabbit messages you can run the following command (it will use the exchange in properties section of the json files):

rabbitmq-dump-queue -uri="amqp://user:[email protected]:5672/" -messages-to-post-dir=/tmp 

If you want to post a directory with dumped rabbit messages and you want to tell to which exchange it should post you can run the following command (it will ignore exchange in the json files):

rabbitmq-dump-queue -uri="amqp://user:[email protected]:5672/" -messages-to-post-dir=/tmp -new-exchange=new_exchange 

If you want to move the messages from one queue to some exchange you can do:

rabbitmq-dump-queue -uri="amqp://user:[email protected]:5672/" -queue=incoming_1 -max-messages=5000 -output-dir=/tmp -new-exchange=new_exchange -ack=true

If you want to move the messages from one queue to some exchange in another server you can do:

rabbitmq-dump-queue -uri="amqp://user:[email protected]:5672/" -queue=incoming_1 -max-messages=5000 -output-dir=/tmp -new-exchange=new_exchange -new-uri="amqp://user:[email protected]:5672/" -ack=true

Running rabbitmq-dump-queue -help will list the available command-line options.

Message requeuing implementation details

In order to fetch messages from the queue and later return them in the original order, rabbitmq-dump-queue uses a standard AMQP basic.get API call without automatic acknowledgements, and it doesn't manually acknowledge the received messages. Thus, when the AMQP connection is closed (after all the messages were received and written to files), RabbitMQ returns all the un-acked messages (all the messages) back to the queue in their original order.

This means that during the time rabbitmq-dump-queue receives and saves the messages, the messages are not visible to other consumers of the queue. This duration is usually very short (unless you're downloading a lot of messages), but make sure your system can handle such a situation (or shut down other consumers of the queue during the time you use this tool).

Note that the same approach is used by RabbitMQ's management HTTP API (the /api/queues/{vhost}/{queue}/get endpoint with requeue=true).

Testing

To run the automated tests, have a RabbitMQ server listen on 127.0.0.1:5672 with user guest and password guest. Then run:

go build .
go test -v .

Contributing

Github pull requests and issues are welcome.

License

rabbitmq-dump-queue is under the MIT License. See the LICENSE file for details.