Skip to content
AMQP-tool - Import & export data from/to an AMQP/RabbitMQ broker
JavaScript
Find file
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Failed to load latest commit information.
bin
.gitignore
.npmignore
README.md
package.json

README.md

Node AMQP Tool Version

AMQP-tool is a cli for importing and/or exporting message from/to an AMQP/RabbitMQ broker.

Installation

$ npm install amqp-tool -g

Usage overview

Usage: node ./bin/amqp-tool [options] [-import | -export]

Options:
  --host          host                                                                         [default: "localhost"]
  --user, -u      username                                                                     [default: "guest"]
  --password, -p  password                                                                     [default: "guest"]
  --port          port                                                                         [default: 5672]
  --vhost         vhost                                                                        [default: "/"]
  --queue, -q     queue's name to work with                                                    [required]
  --passive       set it to true if the queue already exist                                    [boolean]  [default: true]
  --durable       if specified the queue will survive a broker restart                         [boolean]
  --autoDelete    if specified the queue will be deleted when there are no more subscriptions  [boolean]
  --export        export [filename], export queue's content to filename
  --import        import [filename], export file content into the queue
  --count         limit the number of message to export/import
  -v, --verbose   verbose mode                                                                 [default: false]
  -h, --help      produce this help message

Export the first 5000 messages of a queue

into a file ...

amqp-tool --host rabbitmq.local -u user -p azerty -q queuetest --count 5000 --export dump.json

... or to stdout

amqp-tool --host rabbitmq.local -u user -p azerty -q queuetest --count 5000 --export > dump.json

Continuously export a queue into a file

amqp-tool --host rabbitmq.local -u user -p azerty -q queuetest --export > dump.json

Import all messages to a queue

from a file...

amqp-tool --host rabbitmq.local -u user -p azerty -q queuetest --import dump.json

...or from stdin

cat dump.json | amqp-tool --host rabbitmq.local -u user -p azerty -q queuetest --import

Import the first 10 messages of a file into a queue

head -n10 500messages.json | amqp-tool --host rabbitmq.local -u user -p azerty -q queuetest --import

Continuously transfer message between two RabbitMQ Server (just for fun)

amqp-tool --host rabbitmq1.local -u user -p azerty -q queue1 --export | amqp-tool --host rabbitmq2.local -u user -p azerty -q queue2 --import

Donate

Donate Bitcoins

Something went wrong with that request. Please try again.