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
Я проверю на следующей неделе и дам вам знать. Спасибо за быстрый ответ
Вызывается дважды, потому что дважды регистрируется. Один раз вами и один раз 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)
Я считаю, что вам не нужно регистрировать его самостоятельно. Camel автоматически сканирует все реализации
EventNotifierв реестре bean-компонентов. Я думаю, что он зарегистрирован один раз Camel и один раз вами.