class Crabbit::RawMessage

Overview

Already encoded AMQP 1.0 message bytes.

Publishing a RawMessage bypasses AMQP encoding. The bytes must contain a valid complete AMQP message, not merely an application payload.

Defined in:

crabbit/message.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(bytes : Bytes, copy : Bool = true) #

Creates a raw message and copies bytes by default.

With copy set to false, the caller owns the buffer lifetime and must not mutate it until publishing has completed.


[View source]

Instance Method Detail

def bytes : Bytes #

Returns the encoded AMQP message bytes.


[View source]