class

AMQProxy::Server

Inherits Reference < Object

Constants

Log = ::Log.for(self)

Constructors

new(upstream_host, upstream_port, upstream_tls, idle_connection_timeout = 5, max_upstream_channels = UInt16::MAX, client_close_timeout : Time::Span = Client::CLOSE_TIMEOUT)
Source
new(url : URI)
Source

Instance methods

client_connections
Source
close_sockets
Source
disconnect_clients
Source
listen(address, port)
Source
listen(server : TCPServer)
Source
stop_accepting_clients
Source
upstream_connections
Source