Module: Agni

Defined in:

lib/agni.rb,
lib/agni/queue.rb,
lib/agni/version.rb,
lib/agni/messenger.rb,
lib/agni/agni_error.rb

Defined Under Namespace

Classes: AgniError, Messenger, Queue

Constant Summary

DEFAULT_QUEUE_OPTS =

Enforce durability-by-default at the queue and message level

{durable: true}.freeze

DEFAULT_MESSAGE_OPTS =

{persistent: true}.freeze

DEFAULT_CHANNEL_OPTS =

{
  auto_recovery: true,
}.freeze

DEFAULT_CONNECTION_OPTS =

{
  auto_recovery: true,
  # Log cases in which we're unexpectedly disconnected from the server
  on_tcp_connection_failure: ->{ warning("TCP connection failure detected") }
}

PRIORITY_LEVELS =

Each logical queue has 10 AMQP queues backing it to support prioritization. Those priorities are numbered 0 (highest) through 9 (lowest).

(0..9).to_a.freeze

DEFAULT_PRIORITY =

To allow room above and below the default, we put it in the middle

4

DEFAULT_PREFETCH =

50

DEFAULT_THREADPOOL_SIZE =

5

VERSION =

"0.0.4"