Как сохранить информацию в LevelDB, а затем обработать эту информацию другим маршрутом? - PullRequest
1 голос
/ 10 июля 2020

Я хочу сохранить обрабатываемую информацию в базе данных уровня, прямо сейчас у меня есть

from(sourceUri)
                
                .transacted()
                .unmarshal().json(JsonLibrary.Jackson, HashMap::class.java)
                .log(LoggingLevel.INFO, "input ${body}")
                <not sure what to put here>
                .end()

Итак, что мне поместить туда, чтобы сохранить данные, поступающие в levelDB? Я не хочу использовать агрегатор, так как он не подходит для того, что я делаю в данный момент, мне нужно сохранить его в базе данных. Затем я хочу сделать другой маршрут, используя таймер quartz2, чтобы обрабатывать все в этой базе данных каждую минуту.

from("quartz2://myGroup/myTimerName?cron=30+*+*+?+*+*+*")
    .bean(processData)
    .to("activemq:output");
...