elixir-rabbitmq-delayed-messages

elixir-rabbitmq-delayed-messages

defmodule Testing do
  @moduledoc """
  Documentation for `Testing`.
  """

  @doc """
  Hello world.

  ## Examples

      iex> Testing.hello()
      :world

  """
  def hello do
    :world
  end

  def rabbit do
    {:ok, conn} = AMQP.Connection.open()
# {:ok, %AMQP.Connection{pid: #PID<0.165.0>}}

    {:ok, chan} = AMQP.Channel.open(conn)
# {:ok, %AMQP.Channel{conn: %AMQP.Connection{pid: #PID<0.165.0>}, pid: #PID<0.177.0>}

    AMQP.Queue.declare(chan, "test_queue")
# {:ok, %{consumer_count: 0, message_count: 0, queue: "test_queue"}}
    
    args = [ {"x-delayed-type", :longstr, "direct"} ]
    AMQP.Exchange.declare(chan, "test_exchange", :"x-delayed-message", arguments: args)
# :ok

    AMQP.Queue.bind(chan, "test_queue", "test_exchange")

    AMQP.Queue.subscribe(chan, "test_queue", fn payload, _meta -> IO.puts("Received: #{payload}") end)
# {:ok, "amq.ctag-5L8U-n0HU5doEsNTQpaXWg"}

    args = [ {"x-delay", :long, 2000} ]

    AMQP.Basic.publish(chan, "test_exchange", "", "Hello, World!", headers: args)
# :ok
# Received: Hello, World!
  end
end