README
¶
acker
Acker is a cli application to consume/produce messages from/to AMQP servers, e.g. RabbitMQ. It can be used to ack unacked messages on the queue, for the messages not to build up on the queue.
Compile from Source
You can compile Acker from source with the following commands:
$ go get github.com/mostafa/acker
$ go $GOPATH/github.com/mostafa/acker
$ go get
$ go build
$ go install
Alternatively you can cross-compile it using these commands:
$ go get github.com/mostafa/acker
$ cd $GOPATH/github.com/mostafa/acker
$ ./build.sh
Running Acker Consumer
For recovering a queue from unacked messages piling up and slowing the processing, which is usually due to a non-responding consumer, run the following command. It also acts as a consumer that runs forever, until killed by CTRL+C.
$ acker consume --server=<AMQP-URL> --queue=<QUEUE> --autoack=true --recover=true --current-consumer=true
The --server and --queue flags set server and queue configuration to connect to. The --autoack flag causes each message consumed by Acker consumer to be automatically acknowledged. Setting --autoack to false causes unacked consumed messages to pile up the queue, which is only used for testing purposes. The --recover flag will recover unacknowledged messages on the queue and mark them as ready, so that they can be processed again. If the --current-consumer is set to true, the messages will be processed by the Acker consumer, otherwise it will be eventually processed by the original consumer.
Running Acker Producer
For producing messages on the queue, run the following command:
$ acker produce --server=<AMQP-URL> --queue=<QUEUE> --body="<BODY>" --count=10
Just like the Acker consumer, the --server and --queue flags set server and queue configuration to connect to. The --body specifies the body of the message to be published on the queue. The --count specifies the number of messages to be produced.
Documentation
¶
There is no documentation for this package.
Source Files