Code

Resolve observed connection errors#111

Code

Merged

NeonDaniel merged 12 commits intodevNeonGeckoCom/neon_mq_connector:devfrom FIX_PreventReconnectionErrorsNeonGeckoCom/neon_mq_connector:FIX_PreventReconnectionErrorsCopy head branch name to clipboardJan 16, 2025

+36-8

Commits

Commits on Jan 15, 2025

• Prevent attempting to restart an exclusive consumer (will fail repeatedly)

  NeonDaniel

  committed
  56770c8

  Copy full SHA for 56770c8

• Catch errors during shutdown to suppress extra errors in Sentry

  NeonDaniel

  committed
  4ab9b2c

  Copy full SHA for 4ab9b2c

• Log async consumer param with other registration logs

  NeonDaniel

  committed
  e7d56b1

  Copy full SHA for e7d56b1

• Mark subscriber not queue_exclusive to allow for consumer restarts

  NeonDaniel

  committed
  758698e

  Copy full SHA for 758698e

Commits on Jan 16, 2025

• Ensure SelectConsumerThread has an available asynctio event loop

  Show description for 96b1c88
  NeonDaniel

  committed
  96b1c88

  Copy full SHA for 96b1c88

• Explicitly pass io_loop to SelectConnection to troubleshoot https://neon-ai.sentry.io/issues/6036439787/events/e198c87d13c54295adf30a0d12cc0780/

  NeonDaniel

  committed
  28e4330

  Copy full SHA for 28e4330

• Update asyncio ioloop handling

  NeonDaniel

  committed
  ec83ddc

  Copy full SHA for ec83ddc

• Update asyncio ioloop handling (https://neon-ai.sentry.io/issues/6222347480/events/487e1f7cbb284c8a8db2aa96d95e8d9a/)

  NeonDaniel

  committed
  64dd025

  Copy full SHA for 64dd025

• Troubleshooting IOLoop handling

  Show description for e09e9f5
  NeonDaniel

  committed
  e09e9f5

  Copy full SHA for e09e9f5

• Troubleshoot IOLoop init in SelectConsumerThread

  NeonDaniel

  committed
  2ef70bb

  Copy full SHA for 2ef70bb

• Ensure ioloops defined in run are started

  NeonDaniel

  committed
  f01d50a

  Copy full SHA for f01d50a

• Update event loop handling to ensure a maximum of one loop per SelectConsumer

  Show description for 818fd22
  NeonDaniel

  committed
  818fd22

  Copy full SHA for 818fd22