如何从轴突禁用特定事件处理程序？

Question

我们在代码中配置了一些事件处理程序。但是，我想从轴突禁用特定的事件处理程序。

请注意 - 我可以使用 @Profile 或 @Conditional 参数来执行此操作。但是，我很想知道是否有类似 EventConfig 中的配置的方法可以从处理中排除特定的事件处理程序。

请参考下面的代码。

事件源配置

public class AxonConfig {
   
    public void configureProcessorDefault(EventProcessingConfigurer processingConfigurer) {
        processingConfigurer.usingSubscribingEventProcessors();
    }
}

事件处理程序

@ProcessingGroup("this")
class ThisEventHandler {
    // your event handlers here...
}

@ProcessingGroup("that")
class ThatEventHandler {
    // your event handlers here...
}

@ProcessingGroup("other")
class OtherEventHandler {
    // your event handlers here...
}```

Answer 1

作为 EventProcessingConfigurer 的结果而构造的 EventProcessingConfiguration 提供了一种检索事件处理器实例的方法。此外，任何 EventProcessor 实现都有 start() 和 shutDown() 方法。

因此，您可以停止您想要停止的事件处理器。

以下代码将为您完成此任务：

class EventProcessorControl {

    private final EventProcessingConfiguration processingConfig;

    EventProcessorControl(EventProcessingConfiguration processingConfig) {
        this.processingConfig = processingConfig;
    }

    public void startProcessor(String processorName) {
        processingConfig.eventProcessor(processorName)
                        .ifPresent(EventProcessor::start);
    }

    public void stopProcessor(String processorName) {
        processingConfig.eventProcessor(processorName)
                        .ifPresent(EventProcessor::shutDown);
    }
}

作为附注，我会警告仅使用SubscribingEventProcessor。在事件处理器实现中，它在性能、分发和错误处理方面提供的灵活性最少。我宁愿尝试使用 PooledStreamingEventProcessor 来代替。