Skip to content

Conversation

@bartlomiej-korpus
Copy link

No description provided.

:ok

{:error, reject_error} ->
Logger.debug("Failed rejecting message #{delivery_tag}: #{inspect(reject_error)}")

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
Logger.debug("Failed rejecting message #{delivery_tag}: #{inspect(reject_error)}")
Logger.error("Failed rejecting message #{delivery_tag}: #{inspect(reject_error)}")

And we should def have it in Sentry 🤔 Maybe we should let it burn in this case?

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

If we were to let it burn then this spawn here would bite us again


Enum.each(consumers, fn consumer ->
Process.monitor(consumer.channel.pid)
end)

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

There's a single :DOWN handler in this module and it stops and reconnects. The entire connection. This means any consumer or producer dying will take down all the other ones 😄 IMO we should check which process died and only restart this one in case it's one of the channels.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants