in cafe/src/main/java/org/apache/camel/example/cafe/CafeRouteBuilder.java [47:77]
public void runCafeRouteDemo() throws Exception {
// create CamelContext
DefaultCamelContext camelContext = new DefaultCamelContext();
// bind beans to the Camel
bindBeans(camelContext.getRegistry());
// add the routes
camelContext.addRoutes(this);
// start Camel
camelContext.start();
// create a producer so we can send messages to Camel
ProducerTemplate template = camelContext.createProducerTemplate();
Order order = new Order(2);
order.addItem(DrinkType.ESPRESSO, 2, true);
order.addItem(DrinkType.CAPPUCCINO, 4, false);
order.addItem(DrinkType.LATTE, 4, false);
order.addItem(DrinkType.MOCHA, 2, false);
template.sendBody("direct:cafe", order);
// wait 6 seconds and stop
Thread.sleep(6000);
camelContext.stop();
}