diff --git a/ofborg/src/bin/mass-rebuilder.rs b/ofborg/src/bin/mass-rebuilder.rs index 86b02e6..695ff20 100644 --- a/ofborg/src/bin/mass-rebuilder.rs +++ b/ofborg/src/bin/mass-rebuilder.rs @@ -70,6 +70,7 @@ fn main() { })); */ + channel.basic_prefetch(1); channel.basic_consume( worker::new(mrw), "mass-rebuild-check-jobs",