diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_fifo.hrl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_fifo.hrl b/src/rabbit_fifo.hrl index c6c58820c6..be9dc682bb 100644 --- a/src/rabbit_fifo.hrl +++ b/src/rabbit_fifo.hrl @@ -155,8 +155,8 @@ %% overflow calculations). %% This is done so that consumers are still served in a deterministic %% order on recovery. - prefix_msgs = {[], []} :: {Return :: [msg_header()], - PrefixMsgs :: [msg_header()]}, + prefix_msgs = {[], []} :: {Return :: [msg_header() | {'$empty_msg', msg_header()}], + PrefixMsgs :: [msg_header() | {msg_header(), 'empty'}]}, msg_bytes_enqueue = 0 :: non_neg_integer(), msg_bytes_checkout = 0 :: non_neg_integer(), %% waiting consumers, one is picked active consumer is cancelled or dies |