class

LavinMQ::HTTP::Server

Inherits Reference < Object

Constants

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

Constructors

new(server : LavinMQ::Server, amqp_server : LavinMQ::AMQP::Server, mqtt_server : LavinMQ::MQTT::Server)

Source

Class methods

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. If another node on the same machine already serves the socket the server is skipped and nil is returned, it's only a convenience for lavinmqctl users.

Source

prepare_control_socket(path)

Verifies that the control socket path is safe to bind to. Deletes the file if it's a socket no one is listening on, raises if it's in use, not a socket, or can't be verified.

Source

Instance methods

bind_internal_unix

Source

bind_tcp(address, port)

Source

bind_tls(address, port, ctx)

Source

bind_unix(path)

Source

listen

Source