From 331e8f2d57a9a6f00e468d11dde95f23c3188662 Mon Sep 17 00:00:00 2001 From: Michael Klishin Date: Sat, 9 Jan 2016 13:50:10 +0300 Subject: [PATCH] Consume from task_queue --- elixir/worker.exs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/elixir/worker.exs b/elixir/worker.exs index ec33881c..79837aad 100644 --- a/elixir/worker.exs +++ b/elixir/worker.exs @@ -22,7 +22,7 @@ end AMQP.Queue.declare(channel, "task_queue", durable: true) AMQP.Basic.qos(channel, prefetch_count: 1) -AMQP.Basic.consume(channel, "hello") +AMQP.Basic.consume(channel, "task_queue") IO.puts " [*] Waiting for messages. To exit press CTRL+C, CTRL+C" Worker.wait_for_messages(channel)