raulk / camel-mongodb Goto Github PK

This type converter needs to return a "real" java.util.Map?

From:

@Converter
    public static Map<String, Object> fromBasicDBObjectToMap(BasicDBObject basicDbObject) {
        return basicDbObject;
    }

To:

@Converter
    public static Map<String, Object> fromBasicDBObjectToMap(BasicDBObject basicDbObject) {
        return basicDbObject.toMap();
    }

This way, wee can convert mongodb response body, directly to xml, o send generated Map directly to a relational database using spring simple jdbc insert, etc...

More, we can use simple language like: ${body[_id]}

What do you think @raulk ?

Or maybe i'm doing things the wrong way :(

Thanks.

in MongoDbProducer.doInsert, there is this line:
Object insert = exchange.getIn().getBody(DBObject.class);
that throws exception instead of silently outputting null.
The body is of type ArrayList -- so the call exchange.getIn().getBody(List.class) would be successful, but it never gets there.

In MongoDbTailingProcess.java there is:
// the loop finished, persist the lastValue just in case we are shutting down
// TODO: perhaps add a functionality to persist every N records
tailTracking.persistToStore();
}

The problem here is that this code is never reached if I ctrl-c my program, there is no time that the camelTailTracking is persisted to store.

I had to place:
tailTracking.persistToStore();

inside the main while loop inside MongoDBTailingProcess.java