class

PubSubClient

Inherits Reference < Object

Constructors

new(url : String)
Source

Instance methods

close
Source
publish(message : IO)
Source
publish_health(queue_name : String, message : IO)
Source
subscribe
Source
subscribe_health(queue_name : String, &block : AMQP::Client::DeliverMessage -> Nil)
Source