Apache Camel читает сборник MongoDB - не обрабатывает никакие строки

mikeb спросил: 03 февраля 2018 в 11:53 в: mongodb

У меня есть следующее чтение настроек Camel из MongoDB и запись в файлы, но он не работает:

public static void main(String args[]) throws Exception {
    // create CamelContext
    SimpleRegistry sr = new SimpleRegistry();
    Mongo mongo = new Mongo("localhost", 27017);
    sr.put("mdb", mongo);
    CamelContext context = new DefaultCamelContext(sr);    context.addRoutes(new RouteBuilder() {
        public void configure() {
            from("mongodb:mdb?database=demo&collection=person").to("file:data/outbox");
        }
    });    // start the route and let it do its work
    context.start();
    Thread.sleep(10000l);
}

В db.person.find({}) имеется 55 записей оболочка MongoDB REPL. Тем не менее, когда я запускаю свое приложение, я получаю это в журналах и обработанных 0 файлах:

[                          main] DefaultExecutorServiceManager  DEBUG Created new ThreadPool for source: Consumer[mongodb://mdb?collection=person&database=demo] with name: mongodb://mdb?collection=person&database=demo. -> org.apache.camel.util.concurrent.RejectableThreadPoolExecutor@47d9a273[Running, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0][mongodb://mdb?collection=person&database=demo]
[                          main] MongoDbTailingProcess          INFO  Starting MongoDB Tailable Cursor consumer, binding to collection: db: DB{name='demo'}, col: person
[                          main] MongoDbTailableCursorConsumer  DEBUG Stopping consumer: Consumer[mongodb://mdb?collection=person&database=demo]
[                          main] SharedProducerServicePool      DEBUG Stopping service pool: org.apache.camel.impl.SharedProducerServicePool@1bd4fdd
[                          main] GenericFileProducer            DEBUG Stopping producer: Producer[file://data/outbox]
[                          main] DefaultManagementAgent         DEBUG Unregistered MBean with ObjectName: org.apache.camel:context=camel-1,type=producers,name=GenericFileProducer(0x7205765b)
[                          main] MongoDbTailingProcess          INFO  Stopping MongoDB Tailable Cursor consumer, bound to collection: db: DB{name='demo'}, col: person

Похоже, что курсор открыт, ничего не делает и затем закрывается. Как я могу получить его для чтения моих данных?


0 ответов