struct

LavinMQ::BytesMessage

Inherits Struct < Value < Object

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

Constants

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

Constructors

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

Class methods

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

Instance methods

body
Source
bodysize
Source
bytesize
Source
dlrk
Source
exchange_name
Source
moved?
Source
needs_sync?
Source
properties
Source
routing_key
Source
synced_by_commit?
Source
timestamp
Source
to_io(io : IO, format = IO::ByteFormat::SystemEndian)
Source