diff options
| -rw-r--r-- | src/rabbit_mixed_queue.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_mixed_queue.erl b/src/rabbit_mixed_queue.erl index 1b0386e696..610a236641 100644 --- a/src/rabbit_mixed_queue.erl +++ b/src/rabbit_mixed_queue.erl @@ -53,7 +53,7 @@ start_link(Queue, IsDurable, Mode) when Mode =:= disk orelse Mode =:= mixed -> lists:foldl( fun ({_MsgId, Msg, _Size, Delivered, SeqId}, {Buf, NSeq}) when SeqId >= NSeq -> - {queue:in({SeqId, Msg, Delivered}, Buf), SeqId + 1} + {queue:in({SeqId, binary_to_term(Msg), Delivered}, Buf), SeqId + 1} end, {queue:new(), 0}, QList), {ok, #mqstate { mode = Mode, msg_buf = MsgBuf, next_write_seq = NextSeq, queue = Queue, is_durable = IsDurable }}. |