Alan-Jowett / CoPilot-For-Consensus / 20342941650 / 25
78%
main: 78%

DEFAULT BRANCH: main
Ran
Files 2
Run time 0s
Badge
Embed ▾
README BADGES
x

If you need to use a raster PNG badge, change the '.svg' to '.png' in the link

Markdown

Textile

RDoc

HTML

Rst
coverage: 91.279%. Remained the same
20342941650.25

push

github

web-flow 
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)

157 of 172 relevant lines covered (91.28%)

0.91 hits per line

Source Files on job summarization - 20342941650.25