Consume from task_queue

arunjosephselvakumar · Jan 9, 2016 · 331e8f2 · 331e8f2
1 parent 7ba330d
commit 331e8f2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)