Hi, I want to handle messages from multiple RabbitMQ queues in one GenServer. So with following code: def init(_) do ... AMQP.Queue.declare(channel, "q1") AMQP.Queue.declare(channel, "q2") AMQP.Basic.consume(channel, "q", nilm no_ack: true) AMQP.Basic.consume(channel, "q", nilm no_ack: tr…

Thank you! IO.inspect(meta) in my case gives me: %{ app_id: :undefined, cluster_id: :undefined, consumer_tag: "amq.ctag-BFsF3LZZU_oFnf15FdzgFw", content_encoding: :undefined, content_type: :undefined, correlation_id: :undefined, delivery_tag: 1, exchange: "", expiration:…

Elixir Programming Language Forum

GenServer, subscribed to multiple RabbitMQ queues [SOLVED]

Questions & Help Questions

egze April 25, 2019, 11:22am 2

Try to inspect the meta parameter.