class LavinMQ::AMQP::Argument::DeadLettering::DeadLetterer

Defined in:

lavinmq/amqp/argument/dead_lettering.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(vhost : VHost, queue_name : String, log : Logger) #

[View source]

Instance Method Detail

def dlrk : String | Nil #

[View source]
def dlrk=(dlrk : String | Nil) #

[View source]
def dlx : String | Nil #

[View source]
def dlx=(dlx : String | Nil) #

[View source]
def route(msg : BytesMessage, reason) #

This method will publish direct to queues instead of to the DLX. It's done like this to be able to dead letter to all destinations except to the queue itself if a cycle is detected. This is also how it's done in rabbitmq


[View source]