class

AMQProxy::ChannelPool

Inherits Reference < Object

Constants

Log = ::Log.for(self)

Constructors

new(host : String, port : Int32, tls_ctx : OpenSSL::SSL::Context::Client | Nil, credentials : Credentials, idle_connection_timeout : Int32, max_upstream_channels : UInt16)
Source

Instance methods

close
Source
connections
Source
get(downstream_channel : DownstreamChannel) : UpstreamChannel
Source