Я хочу сохранить обрабатываемую информацию в базе данных уровня, прямо сейчас у меня есть
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");