Command line AMQP clients

amqpspawn and amqpsend allow the simple sending and receiving of AMQP messages from the command line or shell scripts. You will require an existing AMQP broker such as RabbitMQ to be running somewhere on an accessible network.

They use rabbitmq-c (http://hg.rabbitmq.com/rabbitmq-c/), and the rabbitmq library can be statically compiled-in so as to only leave standard libc dependencies. The resident memory footprint is under one megabyte, making them perfect for low resource environments.

amqpspawn

amqpspawn binds to an exchange and queue using a binding key, and can spawn a program on message retrieval, or send the same information to stdout.

There's a hardcoded maximum message size of 10MB. If you need to send larger messages, consider splitting them into smaller blocks.

$ ./amqpspawn --help::

Usage: ./amqpspawn [options] exchange bindingkey Options: --host/-h host specify the host (default: "amqpbroker") --port/-P port specify AMQP port (default: 5672) --vhost/-v vhost specify vhost (default: "/") --queue/-q queue specify queue name (default: auto-generated) --execute/-e program program to execute --user/-u username specify username (default: "guest") --password/-p password specify password (default: "guest") --foreground/-f do not daemonise (default: daemonise with -e) --passive do not create the queue if it doesn't exist --exclusive declare the queue as exclusive --durable declare the queue should survive broker restart

The following environment variables may also be set: AMQP_HOST, AMQP_PORT, AMQP_VHOST, AMQP_USER, AMQP_PASSWORD, AMQP_QUEUE AMQP_QUEUE_PASSIVE, AMQP_QUEUE_EXCLUSIVE, AMQP_QUEUE_DURABLE

Program will be called with the following arguments: routing_key, tempfile tempfile contains the raw bytestream of the message

If program is not supplied, the above format will be printed to stdout

Example: $ amqpspawn -h amqp.example.com -P 5672 -u guest -p guest
amq.fanout mykey --foreground -e ./onmessage.sh

amqpsend

amqpsend sends a message to an exchange using the specified routing key. You may also pass a filename as input.

$ ./amqpsend --help::

Usage: ./amqpsend [options] exchange routingkey [message] Options: --host/-h host specify the host (default: "amqpbroker") --port/-P port specify AMQP port (default: 5672) --vhost/-v vhost specify vhost (default: "/") --file/-f filename send contents of file as message --user/-u username specify username (default: "guest") --password/-p password specify password (default: "guest") --persistent mark message as persistent --no-persistent mark message as NOT persistent

The following environment variables may also be set: AMQP_HOST, AMQP_PORT, AMQP_VHOST, AMQP_USER, AMQP_PASSWORD, AMQP_PERSISENT Acceptable values for AMQP_PERSISENT are '1' (No Persist) and '2' (Persist)

With no -f option and no message, message contents will be read from standard input.

Example: $ amqpsend -h amqp.example.com -P 5672 amq.fanout mykey "HELLO AMQP" $ amqpsend -h amqp.example.com -P 5672 amq.fanout mykey -f /etc/hosts $ echo "HELLO AMQP" | amqpsend -h amqp.example.com -P 5672 amq.fanout mykey