Skip to content

Commit 11be1f7

Browse files
committed
made exector service configurable again
1 parent ddc4679 commit 11be1f7

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
@@ -37,7 +37,8 @@ public ZeebeClientAllAutoConfiguration(
3737
@Bean
3838
@ConditionalOnMissingBean
3939
public ZeebeClientExecutorService zeebeClientExecutorService() {
40-
return ZeebeClientExecutorService.createDefault();
40+
return ZeebeClientExecutorService.createDefault(
41+
configurationProperties.getNumJobWorkerExecutionThreads());
4142
}
4243

4344
@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)