diff options
| author | Diana Corbacho <diana@rabbitmq.com> | 2019-04-10 13:19:49 +0100 |
|---|---|---|
| committer | Diana Corbacho <diana@rabbitmq.com> | 2019-04-10 13:19:49 +0100 |
| commit | 6d931d531567e4d51e3606ae8b5e2c35e9a59e05 (patch) | |
| tree | 88eb708c3c651107b904e8e3e0a3cfb74e9d6c19 /src | |
| parent | 0e416ead07251c2a4c1d9ae57b7b176e33d6d792 (diff) | |
| download | rabbitmq-server-git-6d931d531567e4d51e3606ae8b5e2c35e9a59e05.tar.gz | |
Fix prefix msgs types
[#164735591]
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 |