hicommonwealth / commonwealth / 21996619879

38%

push

github

Auto-cleanup deprecated RabbitMQ queues from removed subscriptions on broker init (#13383)

* feat: auto-cleanup deprecated RabbitMQ queues on broker init

Add cleanupDeprecatedQueues method to RabbitMQAdapter that uses the
RabbitMQ Management HTTP API to discover orphaned queues. Empty
deprecated queues are deleted; non-empty ones trigger a warning log.
Only targets queues matching the *Queue naming convention to avoid
touching system queues. Cleanup runs after broker init in
bootstrapBindings, guarded by CLEANUP_DEPRECATED_QUEUES (default true)
and RABBITMQ_MANAGEMENT_URL config flags. For local dev, the management
URL is auto-derived from the AMQP URI (localhost:15672, guest:guest).

Also sorts rascalConsumerMap entries alphabetically by consumer name.

Completed GitHub issue #13382

Co-Authored-By: Claude <noreply@anthropic.com>

* fix map

---------

Co-authored-by: rotorsoft <rotorsoft@outlook.com>
Co-authored-by: Claude <noreply@anthropic.com>

2051 of 5938 branches covered (34.54%)

Branch coverage included in aggregate %.

41 of 41 new or added lines in 1 file covered. (100.0%)

3660 of 9266 relevant lines covered (39.5%)

47.34 hits per line