CamelContextStartedEvent вызывается дважды

CamelContextStartedEvent вызывается дважды для одного и того же верблюжьего контекста (camel-1). Проблема может заключаться в том, как я регистрирую EventNotifier. Вы можете воспроизвести проблему с помощью Spring Initializr с помощью Spring Boot 1.5.14, Spring Boot Camel Starter 2.21.1 и Spring Boot Web Starter.

Смотрите логи:

2018-07-06 11:04:41.104  INFO 19092 --- [           main] o.a.camel.spring.SpringCamelContext      : Apache Camel 2.21.1 (CamelContext: camel-1) is starting
2018-07-06 11:04:41.106  INFO 19092 --- [           main] o.a.c.m.ManagedManagementStrategy        : JMX is enabled
2018-07-06 11:04:41.191  INFO 19092 --- [           main] o.a.camel.spring.SpringCamelContext      : StreamCaching is not in use. If using streams then its recommended to enable stream caching. See more details at http://camel.apache.org/stream-caching.html
2018-07-06 11:04:41.193  INFO 19092 --- [           main] o.a.camel.spring.boot.RoutesCollector    : Starting CamelMainRunController to ensure the main thread keeps running
2018-07-06 11:04:41.193  INFO 19092 --- [           main] o.a.camel.spring.SpringCamelContext      : Total 0 routes, of which 0 are started
2018-07-06 11:04:41.194  INFO 19092 --- [           main] o.a.camel.spring.SpringCamelContext      : Apache Camel 2.21.1 (CamelContext: camel-1) started in 0.090 seconds
2018-07-06 11:04:41.195  INFO 19092 --- [           main] c.e.bug.service.StartupEventNotifier     : CamelContextStartedEvent for SpringCamelContext(camel-1) with spring id application:11223
2018-07-06 11:04:41.195  INFO 19092 --- [           main] c.e.bug.service.StartupEventNotifier     : CamelContextStartedEvent for SpringCamelContext(camel-1) with spring id application:11223
2018-07-06 11:04:41.216  INFO 19092 --- [           main] s.b.c.e.t.TomcatEmbeddedServletContainer : Tomcat started on port(s): 11223 (http)
2018-07-06 11:04:41.221  INFO 19092 --- [           main] com.example.bug.BugApplication           : Started BugApplication in 4.684 seconds (JVM running for 6.773)

Служба, которая инициализирует EventNotifier:

@Service
public class SchedulerService {

    private final CamelContext camelContext;

    private final StartupEventNotifier startupEventNotifier;

    public SchedulerService(CamelContext camelContext, StartupEventNotifier startupEventNotifier) {
        this.camelContext = camelContext;
        this.startupEventNotifier = startupEventNotifier;
    }

    @PostConstruct
    public void init() {
        camelContext.getManagementStrategy().addEventNotifier(startupEventNotifier);
    }

}

EventNotifier:

@Component
public class StartupEventNotifier extends EventNotifierSupport {

    private static final Logger logger = LoggerFactory.getLogger(StartupEventNotifier.class);

    @Override
    public void notify(EventObject event) throws Exception {
        if (event instanceof CamelContextStartedEvent) {
            logger.info("CamelContextStartedEvent for {}", event.getSource());
        }
    }

    @Override
    public boolean isEnabled(EventObject event) {
        if (event instanceof CamelContextStartedEvent) {
            return true;
        }
        return false;
    }
}

application.yml:

camel:
  springboot:
    main-run-controller: true
server:
  port: 11223

Я считаю, что вам не нужно регистрировать его самостоятельно. Camel автоматически сканирует все реализации EventNotifier в реестре bean-компонентов. Я думаю, что он зарегистрирован один раз Camel и один раз вами.

Bedla 06.07.2018 15:51

Я проверю на следующей неделе и дам вам знать. Спасибо за быстрый ответ

Sydney 06.07.2018 17:57
1
2
659
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Вызывается дважды, потому что дважды регистрируется. Один раз вами и один раз Apache Camel. EventNotifier регистрируется автоматически, если обнаружен в Registry. Поскольку ваш StartupEventNotifier помечен как Component, он является частью Registry, и Apache Camel зарегистрировал его во время запуска CamelContext(Вы можете увидеть это в строке 424 CamelAutoConfiguration).

У вас есть четыре варианта:

  • Удалите вашу индивидуальную регистрацию из SchedulerService.
  • Удалите аннотацию @Component из StartupEventNotifier и зарегистрируйте ее с помощью camelContext.getManagementStrategy().addEventNotifier(new StartupEventNotifier())
  • Добавьте к вашему SchedulerService проверку на дублирование. Что-то вроде:

    if (!context.getManagementStrategy().getEventNotifiers().contains(startupEventNotifier)){
        context.getManagementStrategy().addEventNotifier(startupEventNotifier);
    }
    
  • Зарегистрируйте EventNotifier в @PostConstruct из RouteBuilder. Он будет зарегистрирован до запуска автоматического обнаружения, а затем будет пропущен в CamelAutoConfiguration(См. Строку 422)

Другие вопросы по теме