CBSNexora/cbsnexora-backend
4
0
Fork 0
Code Issues Pull Requests Actions 47 Packages Projects Releases Wiki Activity

FINERACT-2181: Use disruptor only if it is configured

Browse Source
This commit is contained in:
Adam Saghy
2025-05-25 19:18:13 +02:00
parent 1aa8395458
commit b0a9bcb3ec
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
fineract-command/src/main/java/org/apache/fineract/command/starter/CommandConfiguration.java
+3
View File
@@ -29,6 +29,7 @@ import org.apache.fineract.command.core.CommandProperties;
import org.apache.fineract.command.core.CommandRouter; import org.apache.fineract.command.core.CommandRouter;
import org.apache.fineract.command.implementation.DisruptorCommandExecutor; import org.apache.fineract.command.implementation.DisruptorCommandExecutor;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.boot.context.properties.EnableConfigurationProperties; import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan; import org.springframework.context.annotation.ComponentScan;
@@ -42,11 +43,13 @@ class CommandConfiguration {
@Bean @Bean
@ConditionalOnMissingBean @ConditionalOnMissingBean
@ConditionalOnProperty(value = "fineract.command.executor", havingValue = "disruptor")
WaitStrategy waitStrategy() { WaitStrategy waitStrategy() {
return new YieldingWaitStrategy(); return new YieldingWaitStrategy();
} }
@Bean @Bean
@ConditionalOnProperty(value = "fineract.command.executor", havingValue = "disruptor")
Disruptor<?> disruptor(CommandProperties properties, WaitStrategy waitStrategy, List<CommandMiddleware> middlewares, Disruptor<?> disruptor(CommandProperties properties, WaitStrategy waitStrategy, List<CommandMiddleware> middlewares,
CommandRouter router) { CommandRouter router) {
// TODO: make this more configurable // TODO: make this more configurable