struct AvalancheMQ::BytesMessage

Defined in:

avalanchemq/message.cr

Constructors

Class Method Summary

Instance Method Summary

Constructor Detail

def self.from_io(io, format = IO::ByteFormat::SystemEndian) : self #

[View source]
def self.new(timestamp : Int64, exchange_name : String, routing_key : String, properties : AMQP::Properties, size : UInt64, body : Bytes) #

[View source]

Class Method Detail

def self.skip(io, format) : UInt64 #

[View source]

Instance Method Detail

def body : Slice(UInt8) #

[View source]
def bytesize #

[View source]
def exchange_name : String #

[View source]
def exchange_name=(exchange_name : String) #

[View source]
def persistent? #

[View source]
def properties : AMQ::Protocol::Properties #

[View source]
def properties=(properties : AMQ::Protocol::Properties) #

[View source]
def routing_key : String #

[View source]
def routing_key=(routing_key : String) #

[View source]
def size : UInt64 #

[View source]
def timestamp : Int64 #

[View source]
def timestamp=(timestamp : Int64) #

[View source]