public class SomeTest extends CamelTestSupport { @Override protected RouteBuilder createRouteBuilder() throws Exception { return new RouteBuilder() { @Override public void configure() throws Exception { from("direct:findAll") .to("mongodb:myConnectionBean?database=flights&collection=tickets&operation=findAll") .to("mock:resultFindAll"); } }; } @Override protected JndiRegistry createRegistry() throws Exception { JndiRegistry reg = new JndiRegistry(createJndiContext()); Mongo connectionBean = new Mongo("localhost", 27017); reg.bind("myConnectionBean", connectionBean); return reg; } @Test public void testSomething() throws InterruptedException { // test something here } }