From b0a9bcb3ec8d281d67def8594074ac9db92166a2 Mon Sep 17 00:00:00 2001 From: Adam Saghy Date: Fri, 23 May 2025 16:58:53 +0200 Subject: [PATCH] FINERACT-2181: Use `disruptor` only if it is configured --- .../apache/fineract/command/starter/CommandConfiguration.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/fineract-command/src/main/java/org/apache/fineract/command/starter/CommandConfiguration.java b/fineract-command/src/main/java/org/apache/fineract/command/starter/CommandConfiguration.java index b2de1a6bc..f16969b20 100644 --- a/fineract-command/src/main/java/org/apache/fineract/command/starter/CommandConfiguration.java +++ b/fineract-command/src/main/java/org/apache/fineract/command/starter/CommandConfiguration.java @@ -29,6 +29,7 @@ import org.apache.fineract.command.core.CommandProperties; import org.apache.fineract.command.core.CommandRouter; import org.apache.fineract.command.implementation.DisruptorCommandExecutor; import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; +import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.boot.context.properties.EnableConfigurationProperties; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.ComponentScan; @@ -42,11 +43,13 @@ class CommandConfiguration { @Bean @ConditionalOnMissingBean + @ConditionalOnProperty(value = "fineract.command.executor", havingValue = "disruptor") WaitStrategy waitStrategy() { return new YieldingWaitStrategy(); } @Bean + @ConditionalOnProperty(value = "fineract.command.executor", havingValue = "disruptor") Disruptor disruptor(CommandProperties properties, WaitStrategy waitStrategy, List middlewares, CommandRouter router) { // TODO: make this more configurable