class LavinMQ::MQTT::ConnectionFactory

Defined in:

lavinmq/mqtt/connection_factory.cr

Constant Summary

Log = LavinMQ::Log.for("mqtt.connection_factory")

Constructors

Instance Method Summary

Constructor Detail

def self.new(authenticator : Auth::Authenticator, brokers : Brokers, config : Config) #

[View source]

Instance Method Detail

def assign_client_id(packet) #

[View source]
def authenticate(io, packet) #

[View source]
def start(socket : ::IO, connection_info : ConnectionInfo) #

[View source]