use method to condifure not static variable

csviri · csviri · commit 5f6156f3e234 · 2024-03-07T11:37:11.000+01:00
Signed-off-by: Attila Mészáros &lt;csviri@gmail.com&gt;
diff --git a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/config/ConfigurationService.java b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/config/ConfigurationService.java
@@ -200,11 +200,11 @@ default Metrics getMetrics() {
   }
 
   default ExecutorService getExecutorService() {
-    return Executors.newFixedThreadPool(DEFAULT_RECONCILIATION_THREADS_NUMBER);
+    return Executors.newFixedThreadPool(concurrentReconciliationThreads());
   }
 
   default ExecutorService getWorkflowExecutorService() {
-    return Executors.newFixedThreadPool(DEFAULT_WORKFLOW_EXECUTOR_THREAD_NUMBER);
+    return Executors.newFixedThreadPool(concurrentWorkflowExecutorThreads());
   }
 
   default boolean closeClientOnStop() {

Original file line number	Diff line number	Diff line change
`@@ -200,11 +200,11 @@ default Metrics getMetrics() {`
`200`	`200`	`}`
`201`	`201`
`202`	`202`	`default ExecutorService getExecutorService() {`
`203`		`- return Executors.newFixedThreadPool(DEFAULT_RECONCILIATION_THREADS_NUMBER);`
	`203`	`+ return Executors.newFixedThreadPool(concurrentReconciliationThreads());`
`204`	`204`	`}`
`205`	`205`
`206`	`206`	`default ExecutorService getWorkflowExecutorService() {`
`207`		`- return Executors.newFixedThreadPool(DEFAULT_WORKFLOW_EXECUTOR_THREAD_NUMBER);`
	`207`	`+ return Executors.newFixedThreadPool(concurrentWorkflowExecutorThreads());`
`208`	`208`	`}`
`209`	`209`
`210`	`210`	`default boolean closeClientOnStop() {`