Freddy

RPC protocol over RabbitMQ. In development stage.

Installation

The package can be installed as:

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

def deps do
  [{:freddy, "~> 0.10.0"}]
end

1. Ensure freddy is started before your application:

def application do
  [applications: [:freddy]]
end

Usage

1. Create Freddy connection:

{:ok, conn} = Freddy.Conn.start_link()

1. Create RPC Client:

defmodule AMQPService do
  use Freddy.RPC.Client
  
  @routing_key "amqp-service"
  
  def start_link(conn, initial \\ nil, opts \\ []) do
    Freddy.RPC.Client.start_link(__MODULE__, conn, [], initial, opts)
  end
  
  def ping(client \\ __MODULE__) do
    Freddy.RPC.Client.request(client, @routing_key, %{type: "ping"})
  end
end

1. Put both connection and service under supervision tree (in this case we're registering connection process and RPC client process under static names):

defmodule MyApp do
  use Application
  
  def start(_type, _args) do
    import Supervisor.Spec

    children = [
      worker(Freddy.Conn, [[], [name: Freddy.Conn]]),
      worker(AMQPService, [Freddy.Conn, nil, [name: AMQPService]])
    ]

    opts = [strategy: :one_for_one, name: MyApp.Supervisor]
    Supervisor.start_link(children, opts)
  end
end

1. You can now use your client:

case AMQPService.ping() do
  {:ok, resp} -> 
    IO.puts "Response: #{inspect response}"
    
  {:error, reason} ->
    IO.puts "Something went wrong: #{inspect reason}"
end