struct LavinMQ::Message

• LavinMQ::Message
• Struct
• Value
• Object

Overview

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

Defined in:

lavinmq/message.cr

Constructors

• .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 Method Summary

• #body_io : IO
• #bodysize : UInt64
• #bytesize
• #exchange_name : String
• #properties : AMQ::Protocol::Properties
• #routing_key : String
• #timestamp : Int64
• #timestamp=(timestamp : Int64)
• #to_io(io : IO, format = IO::ByteFormat::SystemEndian)

Constructor Detail

Instance Method Detail