class

Mqhole::MemoryBroker

Inherits Mqhole::Broker < Reference < Object

Constructors

Instance methods

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