class AMQPCat

• AMQPCat
• Reference
• Object

Defined in:

amqpcat.cr
version.cr

Constant Summary

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

Constructors

• .new(uri)

Instance Method Summary

• #consume(exchange_name : String, routing_key : String | Nil, queue_name : String | Nil, queue_type : String, format : String, offset = 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)

Constructor Detail

Instance Method Detail