struct

LavinMQ::Message

Inherits Struct < Value < Object

Messages from publishers, read from socket and then written to mmap files

Constructors

moved_copy(msg : BytesMessage, *, timestamp = msg.timestamp, exchange_name = msg.exchange_name, routing_key = msg.routing_key, properties = msg.properties) : self

A copy of a stored message that the broker moves to another queue (dead-lettered, delayed, retried). Build every such copy with this, so it's marked moved.

new(timestamp : Int64, exchange_name : String, routing_key : String, properties : AMQ::Protocol::Properties, bodysize : UInt64, body_io : IO)

new(exchange_name : String, routing_key : String, body : String, properties : AMQ::Protocol::Properties = AMQ::Protocol::Properties.new)

Instance methods

body_io

bodysize

bytesize

exchange_name

moved=(moved : Bool)

Set for the copies the broker makes of another queue's messages, see .moved_copy, so the segments they're written to are synced before the segment they were moved out of is unlinked, see Persister#unlink_after_sync

moved?

Set for the copies the broker makes of another queue's messages, see .moved_copy, so the segments they're written to are synced before the segment they were moved out of is unlinked, see Persister#unlink_after_sync

needs_sync=(needs_sync : Bool)

Set for publishes that are confirmed (AMQP confirm mode, MQTT QoS 1), so the segments they're written to are synced before the confirm

needs_sync?

Set for publishes that are confirmed (AMQP confirm mode, MQTT QoS 1), so the segments they're written to are synced before the confirm

properties

routing_key

synced_by_commit=(synced_by_commit : Bool)

Set for transactional publishes, the commit syncs the data dir

synced_by_commit?

Set for transactional publishes, the commit syncs the data dir

timestamp

timestamp=(timestamp : Int64)

to_io(io : IO, format = IO::ByteFormat::SystemEndian)