Skip to content

Commit f14ac8f

Browse files
committed
made exector service configurable again
1 parent edd52e2 commit f14ac8f

File tree

2 files changed

+7
-2
lines changed

2 files changed

+7
-2
lines changed

spring-boot-starter-camunda/src/main/java/io/camunda/zeebe/spring/client/configuration/ZeebeClientAllAutoConfiguration.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,8 @@ public ZeebeClientAllAutoConfiguration(ZeebeClientConfigurationProperties config
3939
@Bean
4040
@ConditionalOnMissingBean
4141
public ZeebeClientExecutorService zeebeClientExecutorService() {
42-
return ZeebeClientExecutorService.createDefault();
42+
return ZeebeClientExecutorService.createDefault(
43+
configurationProperties.getNumJobWorkerExecutionThreads());
4344
}
4445

4546
@Bean

spring-client-zeebe/src/main/java/io/camunda/zeebe/spring/client/jobhandling/ZeebeClientExecutorService.java

+5-1
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,11 @@ public ScheduledExecutorService get() {
2323
}
2424

2525
public static ZeebeClientExecutorService createDefault() {
26-
ScheduledExecutorService threadPool = Executors.newSingleThreadScheduledExecutor();
26+
return createDefault(1);
27+
}
28+
29+
public static ZeebeClientExecutorService createDefault(int threads) {
30+
ScheduledExecutorService threadPool = Executors.newScheduledThreadPool(threads);
2731
return new ZeebeClientExecutorService(threadPool);
2832
}
2933

0 commit comments

Comments
 (0)