File tree Expand file tree Collapse file tree 1 file changed +8
-2
lines changed
src/main/java/com/arpnetworking/clusteraggregator/configuration Expand file tree Collapse file tree 1 file changed +8
-2
lines changed Original file line number Diff line number Diff line change @@ -603,9 +603,15 @@ public Builder setCalculateClusterAggregations(final Boolean value) {
603
603
return this ;
604
604
}
605
605
606
+ /**
607
+ * Validate that the aggregator liveliness timeout is less than the reaggregation timeout.
608
+ *
609
+ * @param aggregatorLivelinessTimeout the configured liveliness timeout
610
+ * @return true if the given value is valid
611
+ */
606
612
@ SuppressFBWarnings (value = "UPM_UNCALLED_PRIVATE_METHOD" , justification = "invoked reflectively by @ValidateWithMethod" )
607
613
public boolean validateAggregatorLivelinessTimeout (final Duration aggregatorLivelinessTimeout ) {
608
- return aggregatorLivelinessTimeout .compareTo (_reaggregationTimeout ) < 0 ;
614
+ return aggregatorLivelinessTimeout .compareTo (_reaggregationTimeout ) > 0 ;
609
615
}
610
616
611
617
@ NotNull
@@ -655,7 +661,7 @@ public boolean validateAggregatorLivelinessTimeout(final Duration aggregatorLive
655
661
@ NotNull
656
662
private Duration _reaggregationTimeout = Duration .ofMinutes (1 );
657
663
@ NotNull
658
- @ ValidateWithMethod (methodName = "validateAggregatorLivelinessTimeout" , parameterType = Duration .class )
664
+ @ ValidateWithMethod (methodName = "validateAggregatorLivelinessTimeout" , parameterType = Duration .class )
659
665
private Duration _aggregatorLivelinessTimeout = _reaggregationTimeout .multipliedBy (2 );
660
666
@ NotNull
661
667
private File _hostPipelineConfiguration ;
You can’t perform that action at this time.
0 commit comments