AMQPCat

VERSION = {{ (`git describe 2>/dev/null || shards version`).stringify.gsub(/(^v|\n)/, "") }}

new(uri)

consume(exchange_name : String, routing_key : String | Nil, queue_name : String | Nil, queue_type : String, format : String, offset = nil, output_dir : String | Nil = nil)

produce(exchange : String, routing_key : String, exchange_type : String, publish_confirm : Bool, props : AMQP::Client::Properties)

rpc(exchange : String, routing_key : String, exchange_type : String, format : String)