Skip to content

Commit 21b2459

Browse files
authored
Merge pull request #2043 from rabbitmq/qq_metrics_tweak
Qq metrics tweak
2 parents ac165a5 + 4e0211d commit 21b2459

File tree

2 files changed

+7
-0
lines changed

2 files changed

+7
-0
lines changed

src/rabbit.erl

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -539,6 +539,12 @@ start_loaded_apps(Apps, RestartTypes) ->
539539
application:set_env(ra, logger_module, rabbit_log_ra_shim),
540540
%% use a larger segments size for queues
541541
application:set_env(ra, segment_max_entries, 32768),
542+
case application:get_env(ra, wal_max_size_bytes) of
543+
undefined ->
544+
application:set_env(ra, wal_max_size_bytes, 536870912); %% 5 * 2 ^ 20
545+
_ ->
546+
ok
547+
end,
542548
ConfigEntryDecoder = case application:get_env(rabbit, config_entry_decoder) of
543549
undefined ->
544550
[];

src/rabbit_quorum_queue.erl

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -130,6 +130,7 @@ declare(Q) when ?amqqueue_is_quorum(Q) ->
130130
id => ServerId,
131131
uid => UId,
132132
friendly_name => FName,
133+
metrics_key => QName,
133134
initial_members => ServerIds,
134135
log_init_args => #{uid => UId},
135136
tick_timeout => TickTimeout,

0 commit comments

Comments
 (0)