X3m.Rabbit

Wrapper around RabbitMQ. Rest of the documentation is TBD.

Configuration examples

[
  {:publisher, MyApp.Rabbit.ExchangePublisher, [
     {:exchange, %{
                    name:    "exchange_name",
                    type:    :topic,
                    options: [durable: true]
                  }}
  ]},
  {:publisher, MyApp.Rabbit.QueuePublisher, [
     {:queue,    %{
                    name:    "queue_name_to_publish",
                    options: [
                               durable:   true,
                               arguments: [{"x-dead-letter-exchange",    :longstr, "dead"}, 
                                           {"x-dead-letter-routing-key", :longstr, "dead.my_app.queue_name_to_publish"}]
                             ]
                  }}
  ]},
  {:listener, MyApp.Rabbit.SomeQueueListener, %{
     event_processor: MyApp.SomeQueueProcessor,
     exchange: %{
       name:    "exchange_name",
       type:    :topic,
       options: [durable: true]
     },
     queue: %{
       name:         "some_queue_listener",
       qos_opts:     [prefetch_count: 100],
       declare_opts: [
         exclusive: false, 
         durable: true, 
         arguments: [
           {"x-dead-letter-exchange", :longstr, "dead"}, 
           {"x-dead-letter-routing-key", :longstr, "dead.my_app.some_queue_listener"}
         ]
       ],
       bind_opts: [routing_key: "#"],
     }
  }}
]

Minimal required configuration (when exchanges and queues are declared somewhere else) is:

[
  {:publisher, MyApp.RabbitPublisher, [
     {:exchange, %{ name: "exchange_name" }},
     {:queue,    %{ name: "queue_name_to_publish" }}
  ]},
  {:listener,  MyApp.Rabbit.SomeQueueListener, %{
     event_processor: MyApp.SomeQueueProcessor,
     exchange:        %{ name: "exchange_name" },
     queue:           %{ name: "some_queue_listener" }
  }}
]

When listener receives message it calls event_processor.process(route, payload, [redelivered?: redelivered?]=options) function. If it returns :ok, messages is acked. On {:error, :discard_message} message is nacked. On anything else message is returned for redelivery.

Installation

If available in Hex, the package can be installed by adding x3m_rabbit to your list of dependencies in mix.exs:

def deps do
  [
    {:x3m_rabbit, "~> 0.1.0"}
  ]
end