146
146
-define (SNAPSHOT_INTERVAL , 8192 ). % % the ra default is 4096
147
147
% -define(UNLIMITED_PREFETCH_COUNT, 2000). %% something large for ra
148
148
-define (MIN_CHECKPOINT_INTERVAL , 8192 ). % % the ra default is 16384
149
- -define (QQ_LEADER_HEALTH_CHECK_TIMEOUT , 1_000 ).
150
- -define (QQ_GLOBAL_LEADER_HEALTH_CHECK_TIMEOUT , 60_000 ).
149
+ -define (LEADER_HEALTH_CHECK_TIMEOUT , 1_000 ).
150
+ -define (GLOBAL_LEADER_HEALTH_CHECK_TIMEOUT , 60_000 ).
151
151
152
152
% %----------- QQ policies ---------------------------------------------------
153
153
@@ -2188,7 +2188,7 @@ leader_health_check(QueueNameOrRegEx, VHost, ProcessLimitThreshold) ->
2188
2188
2189
2189
run_leader_health_check (ClusterName , QResource , HealthCheckRef , From ) ->
2190
2190
Leader = ra_leaderboard :lookup_leader (ClusterName ),
2191
- case ra_server_proc :ping (Leader , ? QQ_LEADER_HEALTH_CHECK_TIMEOUT ) of
2191
+ case ra_server_proc :ping (Leader , ? LEADER_HEALTH_CHECK_TIMEOUT ) of
2192
2192
{pong ,leader } ->
2193
2193
From ! {ok , HealthCheckRef , QResource };
2194
2194
_ ->
@@ -2208,7 +2208,7 @@ wait_for_leader_health_checks(Ref, N, UnhealthyAcc) ->
2208
2208
{error , Ref , QResource } ->
2209
2209
wait_for_leader_health_checks (Ref , N - 1 , [amqqueue :to_printable (QResource , ? MODULE ) | UnhealthyAcc ])
2210
2210
after
2211
- ? QQ_GLOBAL_LEADER_HEALTH_CHECK_TIMEOUT ->
2211
+ ? GLOBAL_LEADER_HEALTH_CHECK_TIMEOUT ->
2212
2212
UnhealthyAcc
2213
2213
end .
2214
2214
0 commit comments