hqoss / rabbit_mq Goto Github PK

I'm trying to do the following but can't:

defmodule Tmp2.QConfig do

def configuration do

%{
  Tmp2.Foo.Queue1  => [exchange: "example_queue", worker_count: 3],
  Tmp2.Foo.Queue2  => [exchange: "other_queue", worker_count: 2]
}

end
end

defmodule Tmp2.Foo do

for {module, options} <- Tmp2.QConfig.configuration() do

defmodule module do

    use RabbitMQ.Producer, options

    @impl true
    def handle_publisher_nack(unackd_messages) do
      Logger.error("Failed to publish messages: #{inspect(unackd_messages)}")
    end

end

end
end

This fixes the problem (producer.ex):

Change from:

  @confirm_type unquote(Keyword.get(opts, :confirm_type, :async))
  @exchange unquote(Keyword.fetch!(opts, :exchange))
  @worker_count unquote(Keyword.get(opts, :worker_count, 3))

To:
@confirm_type Keyword.get(unquote(opts), :confirm_type, :async)
@eXchange Keyword.fetch!(unquote(opts), :exchange)
@worker_count Keyword.get(unquote(opts), :worker_count, 3)

Many thanks to Kip from the ex_cldr team for figuring it out.

Currently we only support :topic in the Topology module.

Consult https://www.cloudamqp.com/blog/2015-09-03-part4-rabbitmq-for-beginners-exchanges-routing-keys-bindings.html to cover as much as possible.