时间戳

首页 > 解决方案 > Axon - 事件处理程序拦截器配置

java - Axon - 事件处理程序拦截器配置

问题描述

我正在尝试定义我的“事件处理程序拦截器”，我按照官方文档here的说明进行操作，但出现以下错误：

org.springframework.beans.factory.BeanCreationException: error when creating the bean with name 'configureEventProcessing' defined in the resource path class [com / prog / boot / config / EventProcessorConfiguration.class]: invalid factory method 'configureEventProcessing': must have an empty non-return type!

我当前的配置调用：

@Configuration
public class EventProcessorConfiguration {

    @Bean
    public void configureEventProcessing(Configurer configurer) {
        configurer.eventProcessing()
                  .registerTrackingEventProcessor("my-tracking-processor")
                  .registerHandlerInterceptor("my-tracking-processor",
                                              configuration -> new MyEventHandlerInterceptor());
    }
}

我的活动MessageHandlerInterceptor实现：

public class MyEventHandlerInterceptor implements MessageHandlerInterceptor<EventMessage<?>> {

    @Override
    public Object handle(UnitOfWork<? extends EventMessage<?>> unitOfWork, InterceptorChain interceptorChain)
            throws Exception {
        EventMessage<?> event = unitOfWork.getMessage();
        String userId = Optional.ofNullable(event.getMetaData().get("userId")).map(uId -> (String) uId)
                .orElseThrow(Exception::new);
        if ("axonUser".equals(userId)) {
            return interceptorChain.proceed();
        }
        return null;
    }
}

我究竟做错了什么？

谢谢！

标签： javaspringeventhandleraxon

解决方案

幸运的是，这个问题相当简单（并且与 Axon 没有直接关系）。

问题是你应该使用而@Autowired不是方法。方法上的注释将使其成为“Bean 创建方法”，而您只想绑定到自动配置以“进一步配置”事件处理器。@BeanconfigureEventProcessing(Configurer)@Bean

微调的最后说明，您可以使用EventProcessingConfigurer作为参数而不是Configurer#eventProcessing调用。这会稍微缩短您的代码。

更新

鉴于自动布线调整按预期工作，所提供的配置将。当然，它确实希望存在一个事件处理组件，它是""my-tracking-processor"处理组的一部分。

如果该处理组中不存在事件处理组件，则不会将任何事件传递给它，因此不会通过MessageHandlerInterceptor.

为事件处理组件指定处理组的一种快速简便的方法是@ProcessingGroup在类级别添加注释。

推荐阅读