app.ex

defmodule Receive do
  use MethodMissing


  def wait_for_messages do
    receive do
      {:basic_deliver, payload, meta} ->
        IO.puts " [x] Received #{payload}"
        #IO.inspect meta.headers
        
        Friends.PersonController.save()
        
        wait_for_messages()
    end
  end
end




  {:ok, connection} = AMQP.Connection.open
  {:ok, channel} = AMQP.Channel.open(connection)
  AMQP.Queue.declare(channel, "queue", durable: true)
  AMQP.Basic.consume(channel, "queue", nil, no_ack: true)
  AMQP.Exchange.declare(channel, "default_project", :topic, durable: true)

  IO.puts " [*] Waiting for messages. To exit press CTRL+C"

  Receive.wait_for_messages