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.crConstructors
- .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
def self.new(timestamp : Int64, exchange_name : String, routing_key : String, properties : AMQ::Protocol::Properties, bodysize : UInt64, body_io : IO)
#
def self.new(exchange_name : String, routing_key : String, body : String, properties : AMQ::Protocol::Properties = AMQ::Protocol::Properties.new)
#