diff options
| author | Diana Corbacho <diana.corbacho@erlang-solutions.com> | 2016-06-27 14:30:21 +0100 |
|---|---|---|
| committer | Diana Corbacho <diana.corbacho@erlang-solutions.com> | 2016-06-27 14:30:21 +0100 |
| commit | 9f30621e86abcb7bccb1534b9bfede44b50c589e (patch) | |
| tree | fc5da2ede7b2b9e2c76286c668535238c40c16b6 /src | |
| parent | ab03861f77395b99249274d1a023dcd414036e8a (diff) | |
| download | rabbitmq-server-git-9f30621e86abcb7bccb1534b9bfede44b50c589e.tar.gz | |
Restore invoke clause
Diffstat (limited to 'src')
| -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}) -> |