class

LavinMQ::ProtocolServer

Inherits Reference < Object

Constants

Log = LavinMQ::Log.for("server")

Constructors

new(server : LavinMQ::Server, config : Config, protocol : Protocol)
Source

Instance methods

bind_tcp(bind : String, port : Int)
Source
bind_tcp(s : TCPServer)
Source
bind_tls(bind : String, port : Int, context : OpenSSL::SSL::Context::Server)
Source
bind_tls(s : TCPServer, context : OpenSSL::SSL::Context::Server)
Source
bind_unix(path : String)
Source
close
Source
closed?
Source
handle_connection(socket, connection_info)
Source
listen
Source
listeners
Source
listening?
Source