Блог

Я работаю над проектом Java с использованием Camel amp; Spring. Мы хотели бы запустить метод инициализации для одноэлементного компонента после того, как Spring закончит свою работу, а Camel завершит построение всех маршрутов.

Мы не можем вызвать метод во время создания класса, поскольку он имеет динамические ссылки на другие классы, которые он выбирает из аннотации @Component spring, и мы не знаем, когда / если эти классы были загружены, чтобы фактически запустить метод init как часть конструктора.

Как я могу вызвать метод или методы для запуска только один раз сразу после завершения запуска Camel?

Спасибо!

другой простой вариант, который дает вам немного больше гибкости, — это использовать camel-timer с repeatCount= 1 и значением задержки, достаточным для инициализации всего. вы также можете добавить базовую обработку исключений для задержки / повторной попытки и т. Д…

 from("timer://runOnce?repeatCount=1amp;delay=5000").to("bean:runOnceBean");
  

Если компонент должен быть вызван после того, как CamelContext запустил все маршруты и т.д., Тогда вы можете, как предлагает Бен, использовать маршрут с таймером.

Возможной лучшей альтернативой является использование API EventNotifier от Camel. А затем вызовите логику для запускаемого CamelContextStartedEvent . Некоторые подробности об API EventNotifier здесь: http://camel.apache.org/eventnotifier-to-log-details-about-all-sent-exchanges.html

Добавьте логику в метод вашего компонента и прокомментируйте его с помощью @PostConstruct — spring вызовет этот метод, как только этот компонент будет полностью инициализирован и все его зависимости установлены.

 @Component
class SomeClass {

 @PostConstruct
 void init() {
 }

}
  

Если логику необходимо вызвать после полной инициализации всего контекста приложения spring, вы можете сделать это, реализовав интерфейс жизненного цикла.

Одним из решений было бы исправление пары файлов (см. PR https://github.com/apache/camel/pull/684 ): Конфигурация CamelContextConfiguration.java и RoutesCollector.java .

В CamelContextConfiguration добавьте метод:

 void afterApplicationStart(CamelContext camelContext);
  

И в onApplicationEvent of RoutesCollector добавьте что-то вроде:

         if (camelContextConfigurations != null) {
            for (CamelContextConfiguration camelContextConfiguration : camelContextConfigurations) {
                camelContextConfiguration.afterApplicationStart(camelContext);
            }
        }
  

Вы можете опустить if (camelContextConfigurations != null) , если используете последнюю версию на эту дату.

Затем создайте компонент Spring следующим образом, чтобы добавить свой код:

 @Bean
CamelContextConfiguration contextConfiguration() {
    return new CamelContextConfiguration() {

        @Override
        public void beforeApplicationStart(CamelContext camelContext) {
        }

        @Override
        public void afterApplicationStart(CamelContext camelContext) {
            // Put your code here
        }
    };
}
  

ОБНОВЛЕНИЕ: этот запрос на извлечение был объединен.

Вы можете использовать функциональность порядка запуска в Camel, задокументированную на http://camel.apache.org/configuring-route-startup-ordering-and-autostartup.html :-

 <route startupOrder="1" id="thisOneGoesFirst">    
  <from uri="seda:foo"/>
  <to uri="mock:result"/>
</route>
<route startupOrder="2" id="thisOneGoesSecond">
  <from uri="direct:start"/>
  <to uri="seda:foo"/>
</route> 
<route id="thisOneGoesLast">
  <from uri="direct:bar"/>
  <to uri="seda:bar"/>
</route>
  

где маршруты с атрибутом startupOrder будут выполняться по порядку и ПЕРЕД всеми маршрутами, у которых нет startupOrder . Таким образом, вы можете проложить свой маршрут с потребителем таймера в любой момент, когда захотите, до или после запуска ваших маршрутов.

Вы можете попробовать внедрить контекст camel в свой одноэлементный компонент. Внедрение не произойдет, пока контекст не будет полностью инициализирован … включая построение всех маршрутов. Недостатком является то, что вам может не потребоваться контекст внутри вашего компонента. Я обдумываю идею связать зависимость одноэлементного компонента с camelContext инициализацией в файле конфигурации spring, но не уверен, что это действительно сработает.

Как уже указывалось в предыдущих ответах, это скорее проблема Spring, чем Camel. Весной вы можете просто реализовать InitializingBean и реализовать menthod afterPropertiesSet . Это вызывается, когда подключение выполнено.