diff options
| -rw-r--r-- | src/rabbit_fifo.hrl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_fifo.hrl b/src/rabbit_fifo.hrl index 3329915125..4bd88fa705 100644 --- a/src/rabbit_fifo.hrl +++ b/src/rabbit_fifo.hrl @@ -144,7 +144,7 @@ -record(rabbit_fifo, {cfg :: #cfg{}, % unassigned messages - messages = lqueue:new() :: lqueue:lqueue(), + messages = lqueue:new() :: lqueue:lqueue({msg_in_id(), indexed_msg()}), % defines the next message id next_msg_num = 1 :: msg_in_id(), % queue of returned msg_in_ids - when checking out it picks from |