diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2011-09-28 23:26:42 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-09-28 23:26:42 +0100 |
| commit | b1397be511a622da201003ed315cc6364361435a (patch) | |
| tree | a3e7387f1828784efe58246fa33363f9b2166e61 | |
| parent | c2b65813b9b05d43de3fba687e350b9a1d94cf99 (diff) | |
| download | rabbitmq-server-bug24290.tar.gz | |
keep queues as queuesbug24290
| -rw-r--r-- | src/rabbit_variable_queue.erl | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index b8ce7de3..b41817d6 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -784,7 +784,9 @@ gb_sets_maybe_insert(false, _Val, Set) -> Set; gb_sets_maybe_insert(true, Val, Set) -> gb_sets:add(Val, Set). format_queue(Q) -> - [format_msg_status(MsgStatus) || MsgStatus <- queue:to_list(Q)]. + rabbit_misc:queue_fold( + fun (MsgStatus, Q1) -> queue:in(format_msg_status(MsgStatus), Q1) end, + queue:new()). format_msg_status(MsgStatus = #msg_status { msg = undefined }) -> MsgStatus; format_msg_status(MsgStatus) -> setelement(#msg_status.msg, MsgStatus, '_'). |