Я хочу настроить Camel для Spring с помощью MINA 2.
Я сделал следующий код конфигурации:
@Configuration
public class SpringConfiguration {
public static final String THREADPOOL_ID = "poolId";
@Bean
CamelContextConfiguration contextConfiguration() {
return new CamelContextConfiguration() {
@Override
public void beforeApplicationStart(CamelContext context) {
context.addComponent("mina2", new Mina2Component());
}
@Override
public void afterApplicationStart(CamelContext arg0) {
}
};
}
}
Но когда я написал код маршрутизатора, как показано ниже. Но это не работает:
@Component
public class RouteConfiguration extends RouteBuilder {
@Value("${app.collectorStringInput}")
private String collectorStringInput;
@Value("${app.mapOutputQueue}")
private String mapOutputQueue;
private final SiemParserProcessor parserProcessor;
public RouteConfiguration(SiemParserProcessor parser) {
this.parserProcessor = parser;
}
@Override
public void configure() throws Exception {
from("mina2:udp://10.31.0.32:514?disconnectOnNoReply=false&sync=false").to("log:edu.accs.siem.collector?level=DEBUG");
}
}
Тем не менее, я вижу эти строки в журнале:
2018-06-30 11:37:14.270 INFO 480 --- [ restartedMain] o.a.camel.spring.SpringCamelContext : Route: route1 started and consuming from: mina2://udp://10.31.0.32:514?disconnectOnNoReply=false&sync=false
2018-06-30 11:37:14.270 INFO 480 --- [ restartedMain] o.a.camel.spring.SpringCamelContext : Total 1 routes, of which 1 are started
2018-06-30 11:37:14.271 INFO 480 --- [ restartedMain] o.a.camel.spring.SpringCamelContext : Apache Camel 2.21.1 (CamelContext: camel-1) started in 0.185 seconds
Он работает без использования Spring. Так что я предполагаю, что есть проблема с конфигурацией.
Может ли кто-нибудь сказать мне, что мне не хватает?
PS: я проверил netty, но, похоже, он не работает, даже если Spring не используется.