class AMQPCat

Defined in:

amqpcat.cr
version.cr

Constant Summary

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

Constructors

Instance Method Summary

Constructor Detail

def self.new(uri) #

[View source]

Instance Method Detail

def consume(exchange_name : String | Nil, routing_key : String | Nil, queue_name : String | Nil, format : String) #

[View source]
def produce(exchange : String, routing_key : String, exchange_type : String, publish_confirm = false) #

[View source]