class MQTT::Packet::Connect

def initialize(args = {})

Create a new Client Connect packet
def initialize(args = {})
  super(ATTR_DEFAULTS.merge(args))
  if version == '3.1.0' || version == '3.1'
    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