LavinMQ::HTTP::MainController
Inherits LavinMQ::HTTP::StatsHelpers < LavinMQ::HTTP::Controller < LavinMQ::HTTP::Router < HTTP::Handler < Reference < Object
Constants
CHURN_STATS = {"connection_created", "connection_closed", "channel_created", "channel_closed", "queue_declared", "queue_deleted"}
EXCHANGE_TYPES = { {name: "direct", human: "Direct"}, {name: "fanout", human: "Fanout"}, {name: "topic", human: "Topic"}, {name: "headers", human: "Headers"}, {name: "x-federation-upstream", human: "Federation Upstream"}, {name: "x-consistent-hash", human: "Consistent Hash"}, {name: "x-mqtt-topic", human: "MQTT Topic"} }
Log = LavinMQ::Log.for("http.main")
OVERVIEW_STATS = {"ack", "deliver", "get", "deliver_get", "publish", "confirm", "redeliver", "reject", "return_unroutable"}
Constructors
new(server : LavinMQ::Server, amqp_server : LavinMQ::AMQP::Server, mqtt_server : LavinMQ::MQTT::Server)
Source