Skip to content

Conversation

carlhoerberg
Copy link
Member

  • Modify onerror handler in AMQPChannel to propagate errors to the connection level
  • Ensure channel errors are properly handled regardless of closure reason
  • Prevent propagation from connection channel (id=0) to avoid recursion

🤖 Generated with Claude Code

…properly

- Modify onerror handler in AMQPChannel to propagate errors to the connection level
- Ensure channel errors are properly handled regardless of closure reason
- Prevent propagation from connection channel (id=0) to avoid recursion

🤖 Generated with [Claude Code](https://claude.ai/code)

Co-Authored-By: Claude <[email protected]>
@carlhoerberg carlhoerberg force-pushed the channel-error-handling branch from d969fe6 to afa527c Compare June 10, 2025 19:13
@carlhoerberg carlhoerberg marked this pull request as ready for review June 11, 2025 09:00
if (closedByServer) this.onerror(err.message)

// Call onerror for any error, whether from server or from a channel operation
if (err.message !== "Connection closed by client") {
Copy link
Member

Choose a reason for hiding this comment

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

We cloud have our own Error class for this to make this check a bit more future proof.

@baelter baelter merged commit 749ca4b into main Sep 9, 2025
6 checks passed
@baelter baelter deleted the channel-error-handling branch September 9, 2025 11:20
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