Настройка Camel для Spring с помощью MINA 2

Я хочу настроить 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 не используется.


person Harikrishnan    schedule 30.06.2018    source источник
comment
Маршрут начинается в соответствии с журналом, который вы показываете, не могли бы вы пояснить, почему это неправильно?   -  person Namphibian    schedule 02.07.2018
comment
Я не знаю, что не так. Без пружины работает. Без весны мне не нужно добавлять какие-либо конфигурации   -  person Harikrishnan    schedule 02.07.2018
comment
Маршрут начался. Итак, вы можете отправить пакет udp в сокет? Похоже, он работает.   -  person Namphibian    schedule 02.07.2018
comment
Пробовал отправлять упакованным. Это отображается с помощью команды nc. Но не с проектом java spring.   -  person Harikrishnan    schedule 02.07.2018
comment
Я имею в виду, что nc -ul -p 514 перечисляет пакеты. Но не с весенним проектом   -  person Harikrishnan    schedule 02.07.2018


Ответы (1)


Я заработал. На самом деле, это была обработка, но журнал почему-то не отображался.

person Harikrishnan    schedule 02.07.2018