README.md

# AMQP RPC Client/Server templates [![Build Status](https://travis-ci.org/deadtrickster/amqp_rpc.svg?branch=master)](https://travis-ci.org/deadtrickster/amqp_rpc) [![Hex.pm](https://img.shields.io/hexpm/v/amqp_rpc.svg?maxAge=2592000?style=plastic)](https://hex.pm/packages/amqp_rpc) 

**Warning!** POC quality!

## Goals
 - Reduce boilerplate
 - Handle reconnects
 - Messages housekeeping 
 - Logging
 - Monitoring
 - Use [fuse](https://github.com/jlouis/fuse)
 - Content negotiation

## Example

Below is 'classic' RPC example from [RabbitMQ tutorials](http://www.rabbitmq.com/tutorials/tutorial-six-elixir.html)
rewritten using amqp_rpc:

Client:

```elixir
defmodule Fibonacci do
  use AMQP.RPC.Client, [exchange: "",
                        queue: "rpc_queue"]

  def fib(n, timeout \\ @timeout) do
    rpc(%{command_name: "fib",
          args: n}, timeout)
  end
end
```

Server:

```elixir
defmodule FibonacciServer do
  use AMQP.RPC.Server, [exchange: "",
                        queue: "rpc_queue",
                        commands: [:fib]]

  ## adapted from https://gist.github.com/stevedowney/2f910bd3d72678b4cf99

  def fib(0), do: 0

  def fib(n)
  when is_number(n) and n > 0,
    do: fib(n, 1, 0, 1)

  def fib(_), do: [error: "positive integers only"]

  def fib(n, m, _prev_fib, current_fib)
  when n == m,
    do: current_fib

  def fib(n, m, prev_fib, current_fib),
    do: fib(n, m+1, current_fib, prev_fib + current_fib)

end
```

## Installation

[Available in Hex](https://hex.pm/packages/amqp_rpc), the package can be installed as:

  1. Add `amqp_rpc` to your list of dependencies in `mix.exs`:

    ```elixir
    def deps do
      [{:amqp_rpc, "~> 0.0.4"}]
    end
    ```

  2. Ensure `amqp_rpc` is started before your application:

    ```elixir
    def application do
      [applications: [:amqp_rpc]]
    end
    ```