module

Example

Class methods

connect

Connects to CLOUDAMQP_URL. TLS connections (amqps://) verify the server certificate. The client doesn't reconnect: restart the process or reconnect yourself if the connection is lost.

Source

consume(ch : AMQP::Client::Channel, queue : String, &handler : String -> ) : Nil

Consumes with a prefetch of 10, acking each message after the block returns

Source

publish(ch : AMQP::Client::Channel, queue : String, message : String) : Nil

Publishes a persistent message and blocks until the broker has confirmed it

Source