class Crabbit::Header

Overview

AMQP 1.0 header section.

All fields are optional. Values left as nil are omitted from the trailing portion of the encoded composite where possible.

Defined in:

crabbit/message.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(durable : Bool | Nil = nil, priority : UInt8 | Nil = nil, ttl : UInt32 | Nil = nil, first_acquirer : Bool | Nil = nil, delivery_count : UInt32 | Nil = nil) #

Creates an AMQP header section.


[View source]

Instance Method Detail

def delivery_count : UInt32 | Nil #

Counts prior unsuccessful delivery attempts.


[View source]
def delivery_count=(delivery_count : UInt32 | Nil) #

Counts prior unsuccessful delivery attempts.


[View source]
def durable : Bool | Nil #

Controls whether the message should survive node failure.


[View source]
def durable=(durable : Bool | Nil) #

Controls whether the message should survive node failure.


[View source]
def first_acquirer : Bool | Nil #

Indicates whether the message was acquired by its first consumer.


[View source]
def first_acquirer=(first_acquirer : Bool | Nil) #

Indicates whether the message was acquired by its first consumer.


[View source]
def priority : UInt8 | Nil #

Indicates relative message priority.


[View source]
def priority=(priority : UInt8 | Nil) #

Indicates relative message priority.


[View source]
def ttl : UInt32 | Nil #

Specifies time-to-live in milliseconds.


[View source]
def ttl=(ttl : UInt32 | Nil) #

Specifies time-to-live in milliseconds.


[View source]