class AMQProxy::Upstream

• AMQProxy::Upstream
• Reference
• Object

Defined in:

amqproxy/upstream.cr

Constant Summary

SAFE_BASIC_METHODS = {40, 10}

Constructors

• .new(host : String, port : Int32, tls_ctx : OpenSSL::SSL::Context::Client | Nil, log : Logger)

Instance Method Summary

• #client_disconnected
• #close(reason = "")
• #closed?
• #connect(user : String, password : String, vhost : String)
• #current_client=(current_client : Client | Nil)
• #last_used : Time::Span
• #last_used=(last_used : Time::Span)
• #read_loop

  Frames from upstream (to client)

• #write(frame : AMQ::Protocol::Frame)

  Send frames to upstream (often from the client)

Constructor Detail

Instance Method Detail