diff --git a/cameleer3-server-app/src/main/java/com/cameleer3/server/app/config/StorageBeanConfig.java b/cameleer3-server-app/src/main/java/com/cameleer3/server/app/config/StorageBeanConfig.java index b0fc1143..78827a60 100644 --- a/cameleer3-server-app/src/main/java/com/cameleer3/server/app/config/StorageBeanConfig.java +++ b/cameleer3-server-app/src/main/java/com/cameleer3/server/app/config/StorageBeanConfig.java @@ -88,19 +88,13 @@ public class StorageBeanConfig { return new PostgresMetricsQueryStore(jdbc); } - // ── ClickHouse Execution Store ────────────────────────────────────── - - @Bean - @ConditionalOnProperty(name = "clickhouse.enabled", havingValue = "true") - public ClickHouseExecutionStore clickHouseExecutionStore( - @Qualifier("clickHouseJdbcTemplate") JdbcTemplate clickHouseJdbc) { - return new ClickHouseExecutionStore(clickHouseJdbc); - } + // ── Execution Store ────────────────────────────────────────────────── @Bean @ConditionalOnProperty(name = "cameleer.storage.executions", havingValue = "clickhouse", matchIfMissing = true) - public ExecutionStore executionStoreClickHouse(ClickHouseExecutionStore chStore) { - return chStore; // Same instance, also exposed as ExecutionStore + public ClickHouseExecutionStore clickHouseExecutionStore( + @Qualifier("clickHouseJdbcTemplate") JdbcTemplate clickHouseJdbc) { + return new ClickHouseExecutionStore(clickHouseJdbc); } @Bean @@ -110,7 +104,7 @@ public class StorageBeanConfig { } @Bean - @ConditionalOnProperty(name = "clickhouse.enabled", havingValue = "true") + @ConditionalOnProperty(name = "cameleer.storage.executions", havingValue = "clickhouse", matchIfMissing = true) public ChunkAccumulator chunkAccumulator( WriteBuffer executionBuffer, WriteBuffer processorBatchBuffer) { @@ -121,7 +115,7 @@ public class StorageBeanConfig { } @Bean - @ConditionalOnProperty(name = "clickhouse.enabled", havingValue = "true") + @ConditionalOnProperty(name = "cameleer.storage.executions", havingValue = "clickhouse", matchIfMissing = true) public ExecutionFlushScheduler executionFlushScheduler( WriteBuffer executionBuffer, WriteBuffer processorBatchBuffer,