broadway_rabbitmq

broadway_rabbitmq copied to clipboard

this is a initial approach to tackle #116. while i was writing it, i was thinking if it would be interesting to have a checkout/checkin function instead of just a...

fcevado

proposal to allow usage of connection/channel pool

4

this relates with the discussion on #60 but i'm creating a new issue to address just the points related to handling the resource that the producer uses to connect/communicate with...

fcevado

ACK timeout kills connection without getting restarted

4

versions: broadway: 1.0.0 bradway_rabbitmq: 0.7.0 amqp: 2.1 elixir: 1.12 otp: 24.0.5 I have some long-running tasks that sometime may time-out the `consumer_timeout` from rabbitmq with message: > 09:38:26.044 [warn] AMQP...

D4no0

Pass in an established connection

10

Hi there... Wondering if there's a way to pass in an already established connection to use for creating channels. (Probably please excuse my ignorance) When I bump up the concurrency...

hassox

broadway_rabbitmq won't compile on Elixir 1.17 and Erlang 27

3

This looks to be related to this issue https://github.com/rabbitmq/rabbitmq-server/issues/11328. Seems like it is fixed in the newest version of https://hex.pm/packages/rabbit_common but the dependency chain from here to there will need...

raulchedrese

Documentation change: refactors dead-letter exchange example and its description

4

This PR affects documentation _only_. It is submitted as a fix for issue #133

fireproofsocks

Documentation for setting up dead-letter exchange is inaccurate and/or incomplete

3

If the example from https://hexdocs.pm/broadway_rabbitmq/BroadwayRabbitMQ.Producer.html#module-dead-letter-exchanges is run, it generates errors: ``` [error] GenServer Rarebit.Pipelines.Inspection.Broadway.Producer_0 terminating ** (stop) exited in: :gen_server.call(#PID, {:subscribe, {:"basic.consume", 0, "my_queue.dlx", "", false, false, false, false, []},...

fireproofsocks