class LavinMQ::HTTP::Server

Defined in:

lavinmq/http/http_server.cr

Constant Summary

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

Constructors

Class Method Summary

Instance Method Summary

Constructor Detail

def self.new(amqp_server : LavinMQ::Server) #

[View source]

Class Method Detail

def self.follower_internal_socket_http_server #

Starts a HTTP server that binds to the internal UNIX socket used by lavinmqctl. The server returns 503 to signal that the node is a follower and can not handle the request.


[View source]

Instance Method Detail

def bind_internal_unix #

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

[View source]
def bind_tls(address, port, ctx) #

[View source]
def bind_unix(path) #

[View source]
def close #

[View source]
def listen #

[View source]