defmodule Subscribex.TestSubscriber do
  use Subscribex.Subscriber

  require Logger

  header_exchange "he_events"
  queue "test.queue"
  routing_key "test.queue.de"
  provide_channel!

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

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