Method: MQTT::Packet::Connect#initialize

Defined in:
lib/mqtt/packet.rb

#initialize(args = {}) ⇒ Connect

Create a new Client Connect packet



445
446
447
448
449
450
451
452
453
454
455
456
457
 
# File 'lib/mqtt/packet.rb', line 445

def initialize(args = {})
  super(ATTR_DEFAULTS.merge(args))

  if ['3.1.0', '3.1'].include?(version)
    self.protocol_name ||= 'MQIsdp'
    self.protocol_level ||= 0x03
  elsif version == '3.1.1'
    self.protocol_name ||= 'MQTT'
    self.protocol_level ||= 0x04
  else
    raise ArgumentError, "Unsupported protocol version: #{version}"
  end
end