class MQTT::V3::Publish

• MQTT::V3::Publish
• MQTT::Header
• BinData
• Reference
• Object

Defined in:

Constant Summary

AFTER_DESERIALIZE = [] of Nil

BEFORE_SERIALIZE = [] of Nil

ENDIAN = ["big"]

KLASS_NAME = [MQTT::V3::Publish]

PARTS = [{type: "basic", name: topic_size, cls: UInt16, onlyif: nil, verify: nil, value: -> do topic.bytesize end, endian: nil}, {type: "string", name: topic, cls: String, onlyif: nil, verify: nil, length: -> do topic_size end, value: nil, encoding: nil}, {type: "basic", name: message_id, cls: UInt16, onlyif: -> do qos? end, verify: nil, value: nil, endian: nil}, {type: "bytes", name: payload, cls: Slice(UInt8), onlyif: nil, verify: nil, length: -> do overhead = topic.bytesize + 2 if qos? overhead = overhead + 2 end len = packet_length.to_i64 - overhead if len < 0 raise(MQTT::ProtocolError.new("publish packet length #{packet_length} is too small for a #{topic.bytesize} byte topic")) end len end, value: nil}] of Nil

REMAINING = [] of Nil

Class Method Summary

• .bit_fields

Instance Method Summary

• #__format__ : IO::ByteFormat

  A group or bit_field captures the endianness at its declaration point, so declaring endian after one would silently leave it system-endian.

• #calculate_length : UInt32
• #message_id : UInt16
• #message_id=(message_id : UInt16)
• #payload : Bytes

  The data to be published

• #payload=(payload : Bytes)

  The data to be published

• #payload=(message)
• #topic : String
• #topic=(topic : String)
• #topic_size : UInt16
• #topic_size=(topic_size : UInt16)

Class Method Detail

Instance Method Detail