Skip to content

Commit

Permalink
Merge pull request #1669 from noxdafox/priority-info
Browse files Browse the repository at this point in the history
Handle generic data structures in priority queue info callback
  • Loading branch information
lukebakken committed Aug 13, 2018
2 parents 7af8fd2 + 000cc32 commit d35fe7c
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/rabbit_priority_queue.erl
Original file line number Diff line number Diff line change
Expand Up @@ -666,8 +666,8 @@ cse(_, lazy) -> lazy;
cse(lazy, _) -> lazy;
%% numerical stats
cse(A, B) when is_number(A) -> A + B;
cse({delta, _, _, _, _}, _) -> {delta, todo, todo, todo, todo};
cse(A, B) -> exit({A, B}).
cse({delta, _, _, _, _}, _) -> {delta, todo, todo, todo, todo};
cse(_, _) -> undefined.

%% When asked about 'head_message_timestamp' fro this priority queue, we
%% walk all the backing queues, starting by the highest priority. Once a
Expand Down

0 comments on commit d35fe7c

Please sign in to comment.