Flux AMQP

Interface to connect to AMQP broker, sending and retrieving messages.

It uses AMQP, check their documentation to understand how this library perform the connection, configuration, consumption and delivery of AMQP messages.

Usage

Add Flux AMQP as a dependency in your mix.exs file:

def deps do
  [{:flux_amqp, "~> 0.0.5"}]
end

FluxAMQP describes how to define and close a connection and how to send a message.

FluxAMQP.Consumer describes how to consume AMQP messages.

Application Configuration

import Config

# Default values
config :flux_amqp,
  broker: [
    uri: "amqp://guest:guest@rabbitmq",
    connection: [
      prefetch_count: 50,
      reattempt_connection_on_failure?: true,
      reattempt: [
        maximum_attempts: :infinity,
        waiting_ms: 10_000
      ]
    ]
  ],
  routing_keys: []

Configuration Options

• :broker - Set the AMQP broker. Accepts keyword/0. Options are:

  • :uri - The AMQP Broker URI. Defaults to amqp://guest:guest@rabbitmq. Accepts String.t/0.

  • :connection - Set the AMQP broker connection. Accepts keyword/0. Options are:

    • :prefetch_count - Set the maximum amount of non-acknowledged messages each consumer will retain. Defaults to 50. Accepts integer/0.

    • :reattempt_connection_on_failure? - If true, when a connection to AMQP broker fails, a reattempt will be performed. Defaults to true. Accepts boolean/0.

    • :reattempt - Set the reattempt settings. Accepts keyword/0. Options are:

      • :maximum_attempts - How many attempts should be performed in case of connection failure. If set to :infinity, it will try until connection succeeds. Defaults to :infinity. Accepts integer/0 or :infinity.

      • :waiting_ms - How many milliseconds should wait before reattempting connection. Defaults to 10_000. Accepts integer/0.

• :routing_keys - The AMQP routing keys which the messages will be consumed. Defaults to an emptt list. Accepts String.t/0.