class AMQP::Client
- AMQP::Client
- Reference
- Object
Defined in:
amqp-client.cramqp-client/channel.cr
amqp-client/connection.cr
amqp-client/errors.cr
amqp-client/exchange.cr
amqp-client/message.cr
amqp-client/queue.cr
amqp-client/sync.cr
amqp-client/version.cr
amqp-client/websocket_io.cr
Constant Summary
-
VERSION =
"1.2.7"
Constructors
- .new(url : String)
- .new(uri : URI)
- .new(host : String = AMQP_HOST, port : Int32 = AMQP_PORT, vhost : String = AMQP_VHOST, user : String = AMQP_USER, password : String = AMQP_PASS, tls : TLSContext = AMQP_TLS, websocket : Bool = AMQP_WS, channel_max : UInt16 = 1024_u16, frame_max : UInt32 = 131072_u32, heartbeat : UInt16 = 0_u16, verify_mode = OpenSSL::SSL::VerifyMode::PEER, name : String | Nil = File.basename(PROGRAM_NAME), connection_information : AMQP::Client::ConnectionInformation = ConnectionInformation.new("amqp-client.cr", AMQP::Client::VERSION, "Crystal", Crystal::VERSION, File.basename(PROGRAM_NAME)), tcp : AMQP::Client::TCPConfig = TCPConfig.new, buffer_size : Int32 = 16384)
Class Method Summary
- .start(url : String | URI, & : AMQP::Client::Connection -> _)
- .start(host = AMQP_HOST, port = AMQP_PORT, vhost = AMQP_VHOST, user = AMQP_USER, password = AMQP_PASS, tls : TLSContext = AMQP_TLS, websocket = AMQP_WS, channel_max = 1024_u16, frame_max = 131072_u32, heartbeat = 0_u16, verify_mode = OpenSSL::SSL::VerifyMode::PEER, name = nil, connection_information = ConnectionInformation.new, & : AMQP::Client::Connection -> _)
Instance Method Summary
- #buffer_size : Int32
- #buffer_size=(buffer_size : Int32)
-
#connect : Connection
Establish a connection
- #host : String
- #host=(host : String)
- #port : Int32
- #port=(port : Int32)
- #tcp : AMQP::Client::TCPConfig
- #tcp=(tcp : AMQP::Client::TCPConfig)
- #tls : OpenSSL::SSL::Context::Client | Nil
- #tls=(tls : OpenSSL::SSL::Context::Client | Nil)
- #user : String
- #user=(user : String)
- #vhost : String
- #vhost=(vhost : String)
- #websocket : Bool
- #websocket=(websocket : Bool)
Constructor Detail
def self.new(host : String = AMQP_HOST, port : Int32 = AMQP_PORT, vhost : String = AMQP_VHOST, user : String = AMQP_USER, password : String = AMQP_PASS, tls : TLSContext = AMQP_TLS, websocket : Bool = AMQP_WS, channel_max : UInt16 = 1024_u16, frame_max : UInt32 = 131072_u32, heartbeat : UInt16 = 0_u16, verify_mode = OpenSSL::SSL::VerifyMode::PEER, name : String | Nil = File.basename(PROGRAM_NAME), connection_information : AMQP::Client::ConnectionInformation = ConnectionInformation.new("amqp-client.cr", AMQP::Client::VERSION, "Crystal", Crystal::VERSION, File.basename(PROGRAM_NAME)), tcp : AMQP::Client::TCPConfig = TCPConfig.new, buffer_size : Int32 = 16384)
#
Class Method Detail
def self.start(host = AMQP_HOST, port = AMQP_PORT, vhost = AMQP_VHOST, user = AMQP_USER, password = AMQP_PASS, tls : TLSContext = AMQP_TLS, websocket = AMQP_WS, channel_max = 1024_u16, frame_max = 131072_u32, heartbeat = 0_u16, verify_mode = OpenSSL::SSL::VerifyMode::PEER, name = nil, connection_information = ConnectionInformation.new, & : AMQP::Client::Connection -> _)
#