final List<DataPoint> dataPoints = ....
                            producerTemplate.sendBody("mongodb:mongoBean?database=" + mongoDataConfiguration.getDatabase()
                                    + "&createCollection=true&operation=insert&collection=" + mongoDataConfiguration.getDataPointCollection(), dataPoints);

.marshal(jackson) 
        .convertBodyTo(String.class) 

.marshal(jackson) 
        .convertBodyTo(String.class) 

public class MongoRouteBuilder extends RouteBuilder {

	@Override
	public void configure() throws Exception {
		from("direct:mongo").to("mongodb:mongoBean?database=" + mongoDataConfiguration.getDatabase()
				+ "&createCollection=true&operation=insert&collection="
				+ mongoDataConfiguration.getDataPointCollection()).marshal().convertBodyTo(String.class);
	}

}

    <bean id="mongoRouteBuilder" class="MongoRouteBuilder"/>

    <camel:camelContext id="mongoRoute">
        <camel:routeBuilder ref="mongoRouteBuilder" />
    </camel:camelContext>

CamelContext context = springCtx.getBean("mongoRoute", CamelContext.class);
context.start();
ProducerTemplate producerTemplate = context.createProducerTemplate();
String result = producerTemplate.requestBody("direct:mongo", dataPoints);

.process(new Processor() {
                    @Override
                    public void process(Exchange exchange) {

.process(new Processor() {
                    @Override
                    public void process(Exchange exchange) {

public void process(Exchange exchange){

}

public void process(Exchange exchange){
MyPojo pojo = exchange.getIn().getBody(MyPojo.class);
// и делайте все что хотите с данными.
}

@Document(collection = "data")
public class MyPojo {
    @Id
    private String id;
    private LocalDateTime createdDate;
    ....
}

final List<MyPojo > pojoList=....
producerTemplate.sendBody("mongodb:mongoBean?database=" + mongoDataConfiguration.getDatabase()
                                    + "&createCollection=true&operation=insert&collection=" + mongoDataConfiguration.getDataPointCollection(), 
        pojoList);

public class IsoDateSerializer extends JsonSerializer<DateTime> {
    @Override
    public void serialize(DateTime value, JsonGenerator jgen, SerializerProvider provider) throws IOException {
           jgen.writeStartObject();
        serializeContents(value.toDate(), jgen, provider);
        jgen.writeEndObject();
    }
    private void serializeContents(Date value, JsonGenerator jgen, SerializerProvider provider) throws IOException {
        jgen.writeFieldName("myDate");
        SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss'Z'");
        String formattedDate = formatter.format(value);
        jgen.writeString(formattedDate);
    }
}

ObjectMapper mapper = new ObjectMapper();
mapper.registerModule(new JodaModule());
mapper.configure(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS, true);
mapper.writeValueAsString(date);

public class IsoDateSerializer extends JsonSerializer<DateTime> {
    @Override
    public void serialize(DateTime value, JsonGenerator jgen, SerializerProvider provider) {
        String isoDate = ISODateTimeFormat.dateTime().print(value);
        jgen.writeRaw("ISODATE(\"" + isoDate + "\")");
    }

	@Override
	public void serialize(LocalDateTime value, JsonGenerator jgen, SerializerProvider provider) throws IOException {
		DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm");
		jgen.writeStartObject();
		jgen.writeFieldName("$date");
		jgen.writeString(formatter.format(value));
		jgen.writeEndObject();
	}

<dependency>
    <groupId>com.fasterxml.jackson.module</groupId>
    <artifactId>jackson-module-parameter-names</artifactId>
</dependency>
<dependency>
    <groupId>com.fasterxml.jackson.datatype</groupId>
    <artifactId>jackson-datatype-jdk8</artifactId>
</dependency>
<dependency>
    <groupId>com.fasterxml.jackson.datatype</groupId>
    <artifactId>jackson-datatype-jsr310</artifactId>
</dependency>

mapper.registerModule(new ParameterNamesModule());
mapper.registerModule(new Jdk8Module());
mapper.registerModule(new JavaTimeModule());

	@Override
	public final void process(Exchange exchange) throws Exception {
		Map<?, ?> m = new ObjectMapper().convertValue(exchange.getIn().getBody(), Map.class);
		exchange.getOut().setBody(BasicDBObject.parse(JSON.serialize(m)));
	}

producerTemplate.sendBody("mongodb:mongoBean?database=" + mongoDataConfiguration.getDatabase()
                                    + "&createCollection=true&operation=insert&collection=" + mongoDataConfiguration.getDataPointCollection(), 
        pojoList);