Alan-Jowett / CoPilot-For-Consensus / 20342941650

78%

Build Type

push

github

Committed by web-flow

Commit Message

Fix RabbitMQ channel reconnection (resolves #392) (#393)

* Fix RabbitMQ channel reconnection (resolves #392)

Implement automatic reconnection in RabbitMQPublisher to handle
closed channels and connection errors during event publishing.

Changes:
- Add _is_connected() method to check connection and channel state
- Add _reconnect() method with circuit breaker logic to prevent storms
- Enhance publish() to detect connection errors and auto-reconnect
- Retry publish operation once after successful reconnection
- Re-declare queues automatically after reconnection
- Add reconnection parameters: max_reconnect_attempts, reconnect_delay
- Add comprehensive test suite for reconnection logic

This prevents the 'Channel is closed' errors that required manual
service restarts, ensuring reliable event publishing even when
RabbitMQ connections are disrupted.

Fixes #392

Signed-off-by: Alan Jowett <alan.jowett@microsoft.com>

* copilot_events: switch connect() to exceptions across publisher/subscriber; update RabbitMQ adapters and validating wrappers; update unit tests. Reconnect now catches exceptions. Resolves #392

Signed-off-by: Alan Jowett <alan.jowett@microsoft.com>

* copilot_events: add unit test for publish connection-error path when reconnection fails; assert ConnectionError with message

Signed-off-by: Alan Jowett <alan.jowett@microsoft.com>

* copilot_events: implement exponential backoff in RabbitMQPublisher._reconnect() and align log output

Signed-off-by: Alan Jowett <alan.jowett@microsoft.com>

* copilot_events: make declare_queue raise exceptions; aggregate errors in declare_queues

Signed-off-by: Alan Jowett <alan.jowett@microsoft.com>

* docs(copilot_events): reflect exception-based API for connect/declare_queue/publish; clarify declare_queues returns bool

Signed-off-by: Alan Jowett <alan.jowett@microsoft.com>

* tests(copilot_events): add coverage for retry publish failure after successful reconnection; remove unused Mock import

Signed-off-by... (continued)

Run Details

90 of 107 new or added lines in 8 files covered. (84.11%)

2 existing lines in 1 file now uncovered.

4507 of 5430 relevant lines covered (83.0%)

0.94 hits per line