fix(core): guard mq registry cleanup

This commit is contained in:
t8y2 2026-07-05 01:55:27 +08:00
parent 68c446cd3e
commit 693eb0dbb9
1 changed files with 2 additions and 0 deletions

View File

@ -638,6 +638,8 @@ impl AppState {
pool: PoolKind,
config: &ConnectionConfig,
) {
// mq_registry only exists in mq-admin builds; other builds reject MQ connects before a pool is created.
#[cfg(feature = "mq-admin")]
if matches!(pool, PoolKind::MessageQueue) {
self.mq_registry.drop_connection(connection_id).await;
}