class

Mqhole::Broker

Inherits Reference < Object

Instance methods

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