defmodule Subscribex.TestSubscriber do
  use Subscribex.Subscriber

  require Logger

  exchange "events"
  queue "test.queue"
  routing_key "test.queue"

  def start_link, do: Subscribex.Subscriber.start_link(__MODULE__)

  def handle_payload(payload) do
    Logger.info(payload)
    Subscribex.channel(&(Subscribex.publish(&1, exchange, routing_key, payload)))
    {:ok, :ack}
  end
end