gocardless/amqpc

Name: amqpc

Owner: GoCardless

Description: AMQP CLI tool

Created: 2013-04-25 11:58:14.0

Updated: 2018-01-19 03:07:06.0

Pushed: 2017-02-21 09:32:04.0

Homepage: null

Size: 99

Language: Go

GitHub Committers

UserMost Recent Commit# Commits

Other Committers

UserEmailMost Recent Commit# Commits

README

amqpc

amqpc is a tool to test your AMQP broker.
It has been developed and tested with RabbitMQ but any AMQP broker should work.
We put it together very quickly to benchmark and test our RabbitMQ HA Cluster, so it might be unstable.

Usage
qpc -h

c is CLI tool for testing AMQP brokers
e:
nsumer : amqpc [options] -c exchange routingkey queue
oducer : amqpc [options] -p exchange routingkey [message]

ons:
=true: Act as a consumer
t="amqpc-consumer": AMQP consumer tag (should not be blank)
=1: Concurrency
=500: (Producer only) Interval at which send messages (in ms)
=0: (Producer only) Number of messages to send
=false: Act as a producer
=true: Wait for the publisher confirmation before exiting
="direct": Exchange type - direct|fanout|topic|x-custom
="amqp://guest:guest@localhost:5672/": AMQP URI
Installation

Right now it's not available in any package manager. To build it your need to have a Go compiler.

 get
 build
Examples
Start one consumer
qpc -u amqp://guest:guest@localhost:5672/ -c your-exchange routing-key your-queue
Start one producer
qpc -u amqp://guest:guest@localhost:5672/ -p your-exchange routing-key your-message
Start 10 producers
qpc -u amqp://guest:guest@localhost:5672/ -g 10 -p your-exchange routing-key your-message
Start 10 producers, each one will be sending 100 at a rate of 1msg/s
qpc -u amqp://guest:guest@localhost:5672/ -g 10 -i 1000 -n 100 -p your-exchange routing-key your-message
TODO

This work is supported by the National Institutes of Health's National Center for Advancing Translational Sciences, Grant Number U24TR002306. This work is solely the responsibility of the creators and does not necessarily represent the official views of the National Institutes of Health.