activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rich_g <richard.gib...@citi.com>
Subject Using MongoDB queries with Timer
Date Tue, 31 Jul 2012 16:05:57 GMT
Hi all
I want to make a timer that polls a Mongo collection to get data with an id
> variable set at runtime.

I am able to get a timer working using but don't know how to set a query
filter

from("timer://myTimer?period=30000")
      
.to("mongodb:myDb?database=test&collection=test&operation=findAll&dynamicity=true")
       .to("stream:out");
but don't know


And using the unit tests for camel-mongo I am able to query using the code
below to get the filtered set.

DBObject query =
BasicDBObjectBuilder.start().push("_id").add("$gte",12).get();
Object result = template.requestBody("direct:findAll", query);

....

  from("direct:findAll")
                    .to("mongodb:myDb?database
test&collection=test&operation=findAll&dynamicity=true")
                    .to("mock:resultFindAll");


Can anyone give me some advice on how to combine the 2?

Thanks

Rich




--
View this message in context: http://activemq.2283324.n4.nabble.com/Using-MongoDB-queries-with-Timer-tp4654613.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Mime
View raw message