class

Mqhole::AMQPBroker

Inherits Mqhole::Broker < Reference < Object

Constructors

new(queue : AMQP::Client::Queue)
Source

Class methods

open(url : String, queue_name : String, & : AMQPBroker -> _)
Source

Instance methods

get(timeout : Time::Span) : BrokerMessage | Nil
Source
publish(type : String, correlation_id : String, message_id : String, body : Bytes) : Nil
Source