diff options
| -rw-r--r-- | src/rabbit_priority_queue.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/rabbit_priority_queue.erl b/src/rabbit_priority_queue.erl index 0d75753be6..b7a3afd129 100644 --- a/src/rabbit_priority_queue.erl +++ b/src/rabbit_priority_queue.erl @@ -418,6 +418,8 @@ info(Item, #state{bq = BQ, bqss = BQSs}) -> info(Item, #passthrough{bq = BQ, bqs = BQS}) -> BQ:info(Item, BQS). +invoke(Mod, {P, Fun}, State = #state{bq = BQ}) -> + pick1(fun (_P, BQSN) -> BQ:invoke(Mod, Fun, BQSN) end, P, State); invoke(Mod, Fun, State = #state{bq = BQ, max_priority = P}) -> pick1(fun (_P, BQSN) -> BQ:invoke(Mod, Fun, BQSN) end, P, State); invoke(Mod, Fun, State = #passthrough{bq = BQ, bqs = BQS}) -> |