class AMQProxy::Server

Defined in:

amqproxy/server.cr

Constant Summary

Log = ::Log.for(self)

Constructors

Instance Method Summary

Constructor Detail

def self.new(upstream_host, upstream_port, upstream_tls, idle_connection_timeout = 5, max_upstream_channels = UInt16::MAX) #

[View source]
def self.new(url : URI) #

[View source]

Instance Method Detail

def client_connections #

[View source]
def close_sockets #

[View source]
def disconnect_clients #

[View source]
def listen(address, port) #

[View source]
def listen(server : TCPServer) #

[View source]
def stop_accepting_clients #

[View source]
def upstream_connections #

[View source]