class

AMQP::Client

Inherits Reference < Object

Compatibility facade for migration paths that currently require amqp-client. The implementation delegates to amqp-ng and keeps the narrower old-client shapes used by LavinMQ's shovel/perf code.

Constructors

new(uri : URI | String)
Source

Class methods

coerce_arguments(arguments : Arguments) : Amqp::Arguments
Source
coerce_arguments(arguments : Amqp::Arguments) : Amqp::Arguments
Source
coerce_arguments(arguments) : Amqp::Arguments
Source
coerce_field(value : JSON::Any) : Amqp::FieldValue
Source
coerce_field(value : Hash) : Amqp::FieldValue
Source
coerce_field(value : Array) : Amqp::FieldValue
Source
coerce_field(value) : Amqp::FieldValue
Source
coerce_properties(properties : Amqp::Properties) : Amqp::Properties
Source
coerce_properties(properties) : Amqp::Properties
Source
start(uri : URI | String, & : Connection -> _)
Source

Instance methods

connect
Source
host=(host : String) : String
Source

Nested types