struct AMQProxy::Client

Defined in:

amqproxy/client.cr

Constructors

Class Method Summary

Instance Method Summary

Constructor Detail

def self.new(socket : TCPSocket | OpenSSL::SSL::Socket::Server) #

[View source]

Class Method Detail

def self.negotiate(socket) #

[View source]

Instance Method Detail

def close #

[View source]
def read_loop(upstream : Upstream) #

[View source]
def upstream_disconnected #

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

Send frame to client


[View source]