class AMQP::Client::Connection

Defined in:

amqp-client/connection.cr
amqp-client/errors.cr

Constant Summary

LOG = AMQP::Client::LOG.for(self)

Constructors

Class Method Summary

Instance Method Summary

Constructor Detail

def self.new(io : UNIXSocket | TCPSocket | OpenSSL::SSL::Socket::Client | WebSocketIO, channel_max : UInt16, frame_max : UInt32, heartbeat : UInt16) #

[View source]

Class Method Detail

def self.start(io : UNIXSocket | TCPSocket | OpenSSL::SSL::Socket::Client | WebSocketIO, user, password, vhost, channel_max, frame_max, heartbeat, name : String | Nil) #

[View source]

Instance Method Detail

def channel(id : Int | Nil = nil) #

[View source]
def channel(&blk : Channel -> _) #

[View source]
def channel_max : UInt16 #

[View source]
def close(msg = "", no_wait = false) #

[View source]
def closed? : Bool #

[View source]
def frame_max : UInt32 #

[View source]
def log #

[View source]
def on_close(&blk : UInt16, String -> ) #

[View source]
def unsafe_write(frame : Frame) #

[View source]
def with_lock(&blk : self -> _) #

[View source]
def write(frame : Frame) #

[View source]