struct LavinMQ::BytesMessage

• LavinMQ::BytesMessage
• Struct
• Value
• Object

Overview

Messages read from message store (mmap filed) and being delivered to consumers

Defined in:

lavinmq/message.cr

Constant Summary

MIN_BYTESIZE = ((((8 + 1) + 1) + 2) + 8) + 1

Constructors

• .from_bytes(bytes, format = IO::ByteFormat::SystemEndian) : self
• .new(timestamp : Int64, exchange_name : String, routing_key : String, properties : AMQ::Protocol::Properties, bodysize : UInt64, body : Bytes)

Class Method Summary

• .skip(io, format = IO::ByteFormat::SystemEndian) : UInt64

Instance Method Summary

• #body : Slice(UInt8)
• #bodysize : UInt64
• #bytesize
• #delay : UInt32 | Nil
• #dlrk : String | Nil
• #dlx : String | Nil
• #exchange_name : String
• #properties : AMQ::Protocol::Properties
• #routing_key : String
• #timestamp : Int64
• #ttl

Constructor Detail

Class Method Detail

Instance Method Detail