diff options
| author | Diana Corbacho <diana@rabbitmq.com> | 2019-03-26 20:25:16 +0000 |
|---|---|---|
| committer | Diana Corbacho <diana@rabbitmq.com> | 2019-03-27 09:03:01 +0000 |
| commit | ce55899c883839230f6e3a6546bb4db9087905bb (patch) | |
| tree | 6e2013c790cfdc417e0cbc8f6b62210ce35902b1 /src/rabbit_fifo.hrl | |
| parent | 1b87e590a232b878fa1869aff26eef675093a9bc (diff) | |
| download | rabbitmq-server-git-ce55899c883839230f6e3a6546bb4db9087905bb.tar.gz | |
Quorum queue in memory message limits
[#164735591]
Diffstat (limited to 'src/rabbit_fifo.hrl')
| -rw-r--r-- | src/rabbit_fifo.hrl | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/src/rabbit_fifo.hrl b/src/rabbit_fifo.hrl index 968ae07739..c6c58820c6 100644 --- a/src/rabbit_fifo.hrl +++ b/src/rabbit_fifo.hrl @@ -108,7 +108,9 @@ %% whether single active consumer is on or not for this queue consumer_strategy = competing :: consumer_strategy(), %% the maximum number of unsuccessful delivery attempts permitted - delivery_limit :: maybe(non_neg_integer()) + delivery_limit :: maybe(non_neg_integer()), + max_in_memory_length :: maybe(non_neg_integer()), + max_in_memory_bytes :: maybe(non_neg_integer()) }). -record(rabbit_fifo, @@ -159,7 +161,9 @@ msg_bytes_checkout = 0 :: non_neg_integer(), %% waiting consumers, one is picked active consumer is cancelled or dies %% used only when single active consumer is on - waiting_consumers = [] :: [{consumer_id(), consumer()}] + waiting_consumers = [] :: [{consumer_id(), consumer()}], + msg_bytes_in_memory = 0 :: non_neg_integer(), + msgs_ready_in_memory = 0 :: non_neg_integer() }). -type config() :: #{name := atom(), @@ -169,5 +173,7 @@ release_cursor_interval => non_neg_integer(), max_length => non_neg_integer(), max_bytes => non_neg_integer(), + max_in_memory_length => non_neg_integer(), + max_in_memory_bytes => non_neg_integer(), single_active_consumer_on => boolean(), delivery_limit => non_neg_integer()}. |