all java tests now pass. tiny (but significant!) bug in the mixed_queue startup post disk_queue startup.

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 }}.