class

TJLavin::Configuration

Inherits Reference < Object

Instance methods

amqp_url
Source
amqp_url=(amqp_url : String | Nil)
Source
default_exchange
Source
default_exchange=(default_exchange : String)
Source
delayed_exchange
Source
delayed_exchange=(delayed_exchange : String)
Source
heartbeat

Seconds between AMQP heartbeats. The server pings the client at this interval; if two intervals pass with no traffic, the underlying TCP socket is closed. This is what catches half-open connections after a broker upgrade or network drop. Set to 0 to disable.

Source
heartbeat=(heartbeat : Int32)

Seconds between AMQP heartbeats. The server pings the client at this interval; if two intervals pass with no traffic, the underlying TCP socket is closed. This is what catches half-open connections after a broker upgrade or network drop. Set to 0 to disable.

Source
propagate_log_context

Log.context keys carried from the enqueuing fiber to the job. Each value present at enqueue travels as an AMQP header, and the runner restores it around the whole job, so a request's ID follows the job it queued. Empty by default, which sends no headers.

settings.propagate_log_context = [:request_id]

Source
propagate_log_context=(propagate_log_context : Array(Symbol))

Log.context keys carried from the enqueuing fiber to the job. Each value present at enqueue travels as an AMQP header, and the runner restores it around the whole job, so a request's ID follows the job it queued. Empty by default, which sends no headers.

settings.propagate_log_context = [:request_id]

Source
reconnect_backoff

Initial wait between reconnect attempts. Doubles up to reconnect_backoff_max.

Source
reconnect_backoff=(reconnect_backoff : Time::Span)

Initial wait between reconnect attempts. Doubles up to reconnect_backoff_max.

Source
reconnect_backoff_max
Source
reconnect_backoff_max=(reconnect_backoff_max : Time::Span)
Source
routing_key
Source
routing_key=(routing_key : String)
Source
validate
Source
validated=(validated : Bool)
Source
validated?
Source