diff --git a/src/main/java/net/siegeln/cameleer/saas/config/AsyncConfig.java b/src/main/java/net/siegeln/cameleer/saas/config/AsyncConfig.java index 055f154..c830ac4 100644 --- a/src/main/java/net/siegeln/cameleer/saas/config/AsyncConfig.java +++ b/src/main/java/net/siegeln/cameleer/saas/config/AsyncConfig.java @@ -18,8 +18,8 @@ public class AsyncConfig { this.runtimeConfig = runtimeConfig; } - @Bean(name = "deploymentExecutor") - public Executor deploymentExecutor() { + @Bean(name = "deploymentTaskExecutor") + public Executor deploymentTaskExecutor() { var executor = new ThreadPoolTaskExecutor(); // Core == max: no burst threads. Deployments beyond pool size queue (up to 25). executor.setCorePoolSize(runtimeConfig.getDeploymentThreadPoolSize()); diff --git a/src/main/java/net/siegeln/cameleer/saas/deployment/DeploymentExecutor.java b/src/main/java/net/siegeln/cameleer/saas/deployment/DeploymentExecutor.java index bfbce6e..fd4a9a0 100644 --- a/src/main/java/net/siegeln/cameleer/saas/deployment/DeploymentExecutor.java +++ b/src/main/java/net/siegeln/cameleer/saas/deployment/DeploymentExecutor.java @@ -47,7 +47,7 @@ public class DeploymentExecutor { this.runtimeConfig = runtimeConfig; } - @Async("deploymentExecutor") + @Async("deploymentTaskExecutor") public void executeAsync(DeploymentEntity deployment, AppEntity app, EnvironmentEntity env) { try { var jarPath = appService.resolveJarPath(app.getJarStoragePath());