gistfile1.java

    public void configure() {
        
        from("direct:cafe")
            .split().method("orderSplitter")
            .to("direct:drink");
        
        from("direct:drink").recipientList().method("drinkRouter");
        
        from("seda:coldDrinks?concurrentConsumers=2")
            .to("bean:barista?method=prepareColdDrink")
            .to("direct:deliveries");
            
        from("seda:hotDrinks?concurrentConsumers=3")
            .to("bean:barista?method=prepareHotDrink")
            .to("direct:deliveries");
        
        from("direct:deliveries")
            .aggregate(new CafeAggregationStrategy()).method("waiter", "checkOrder").completionTimeout(5 * 1000L)
            .to("bean:waiter?method=prepareDelivery")
            .to("bean:waiter?method=deliverCafes");

    }