Presume Closed subscriptions that don't give a machine-readable prefix are failures of some kind to avoid loops

This commit is contained in:
Mike Dilger 2024-06-25 08:59:39 +12:00
parent ba50179377
commit f7a8b4f69c

View File

@ -344,6 +344,8 @@ impl Minion {
}
_ => {
tracing::debug!("{} closed with unknown prefix {}", &self.url, prefix);
// Presume any other kind of Closed is an failed subscription
self.failed_subs.insert(handle.clone());
}
}
}