为什么Axon框架中的RetryScheduler在NoHandlerForCommandException之后不重试？

Question

这是我对带有RetryScheduler的commandGateway的配置：

@Bean
public CommandGateway commandGateway(){

    Configurer configurer = DefaultConfigurer.defaultConfiguration();

    CommandBus commandBus = configurer.buildConfiguration().commandBus();

    ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);
    RetryScheduler rs = IntervalRetryScheduler.builder().retryExecutor(scheduledExecutorService).maxRetryCount(100).retryInterval(1000).build();
    CommandGateway commandGateway = DefaultCommandGateway.builder().commandBus(commandBus).retryScheduler(rs).build();

    return commandGateway;
}

Answer 1

为了解决手头的问题，您可以提供intervalretryScheduler的自己的实现，该实现重写intervalretryScheduler#isexplicitlynontransistal(Throwable)方法，以同时考虑重试noHandlerforCommandException。

注意，intervalretryScheduler有意只对AxonNontransientException类型的异常重试，这些异常通常是信号可恢复的异常。NoHandlerforCommandException意味着正在使用的CommandBus实现也不知道向谁发出命令，这通常意味着不能重试。

然而，似乎你有一个有意义的场景。因此，正如我在开始时指出的那样，重写IsexplicitlyNontransient(Throwable)方法以排除NoHandlerForCommandException将是我认为适合您的方法。