TJLavin::Configuration
Inherits Reference / Object
Instance methods
amqp_url
Sourceamqp_url=(amqp_url : String | Nil)
Sourcedefault_exchange
Sourcedefault_exchange=(default_exchange : String)
Sourcedelayed_exchange
Sourcedelayed_exchange=(delayed_exchange : String)
Sourceheartbeat
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.
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.
reconnect_backoff
Initial wait between reconnect attempts. Doubles up to reconnect_backoff_max.
reconnect_backoff=(reconnect_backoff : Time::Span)
Initial wait between reconnect attempts. Doubles up to reconnect_backoff_max.
reconnect_backoff_max
Sourcereconnect_backoff_max=(reconnect_backoff_max : Time::Span)
Sourcerouting_key
Sourcerouting_key=(routing_key : String)
Sourcevalidate
Sourcevalidated=(validated : Bool)
Sourcevalidated?
Source