class

LavinMQ::AMQP::Queue::Settings

Inherits Reference < Object

Settings derived from the queue's arguments and its policies. A new instance is built off to the side every time they are (re)applied and published with a single reference store, so readers never see a policy half-applied, limits missing while a policy is re-applied, or a torn value. A published instance is never mutated.

Constructors

new(consumer_timeout : UInt64 | Nil = nil)

Instance methods

consumer_timeout

consumer_timeout=(consumer_timeout : UInt64 | Nil)

counts_deliveries?

Deliveries are counted for x-delivery-limit and x-delayed-retry-min

delayed_retry_max

delayed_retry_max=(delayed_retry_max : Int64 | Nil)

delayed_retry_min

delayed_retry_min=(delayed_retry_min : Int64 | Nil)

delayed_retry_multiplier

delayed_retry_multiplier=(delayed_retry_multiplier : Int32 | Nil)

delivery_limit

delivery_limit=(delivery_limit : Int64 | Nil)

dlrk

dlrk=(dlrk : String | Nil)

dlx

dlx=(dlx : String | Nil)

effective_args

enforce_limits=(enforce_limits : Bool)

Set when the policy tightened limits that existing messages must be checked against

enforce_limits?

Set when the policy tightened limits that existing messages must be checked against

expires

expires=(expires : Int64 | Nil)

federation_upstream

Only set by policies; federation has no queue argument

federation_upstream=(federation_upstream : String | Nil)

Only set by policies; federation has no queue argument

federation_upstream_set

federation_upstream_set=(federation_upstream_set : String | Nil)

max_age

max_age=(max_age : Time::Span | Time::MonthSpan | Nil)

max_length

max_length=(max_length : Int64 | Nil)

max_length_bytes

max_length_bytes=(max_length_bytes : Int64 | Nil)

message_ttl

message_ttl=(message_ttl : Int64 | Nil)

reject_on_overflow=(reject_on_overflow : Bool)

reject_on_overflow?