subscriber_base.ex

defmodule Toolex.AMQP.SubscriberBase do
    use GenServer
    ...
    def handle_info({:basic_deliver, payload, meta}, state) do
        Logger.info "Deliver received for #{state.module}"

        try do
          payload = Poison.decode!(payload)
          apply state.module, :handle, [payload, meta]
          AMQP.Basic.ack state.channel, meta.delivery_tag
        ...
    end
    ...
end