struct AvalancheMQ::Message

• AvalancheMQ::Message
• Struct
• Value
• Object

Defined in:

avalanchemq/message.cr

Constructors

• .new(timestamp : Int64, exchange_name : String, routing_key : String, properties : AMQP::Properties, size : UInt64, body_io : IO)
• .new(exchange_name : String, routing_key : String, body : String, properties : AMQ::Protocol::Properties = AMQP::Properties.new)

Class Method Summary

• .skip(io, format) : UInt64

Instance Method Summary

• #body_io : IO
• #bytesize
• #exchange_name : String
• #exchange_name=(exchange_name : String)
• #persistent?
• #properties : AMQ::Protocol::Properties
• #properties=(properties : AMQ::Protocol::Properties)
• #routing_key : String
• #routing_key=(routing_key : String)
• #size : UInt64
• #timestamp : Int64
• #timestamp=(timestamp : Int64)

Constructor Detail

Class Method Detail

Instance Method Detail