gistfile1.java

//ERROR is:
/*
Caused by: org.apache.camel.CamelExchangeException: No consumers available on endpoint: Endpoint[direct://updatePlayer]. Exchange[Message: [DataWarehousePlayer [id=-99, name=PersonName [firstName=Rusty, lastName=Shackleford], sugarPlayer=true, advantagePlayer=false], DataWarehousePlayer [id=-99, name=PersonName [firstName=Rusty, lastName=Shackleford], sugarPlayer=true, advantagePlayer=true]]]
	at org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:56)
	at org.apache.camel.processor.UnitOfWorkProcessor.processAsync(UnitOfWorkProcessor.java:150)
	at org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:117)
	at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:99)
	at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:86)
	at org.apache.camel.processor.UnitOfWorkProducer.process(UnitOfWorkProducer.java:63)
	at org.apache.camel.impl.ProducerCache$2.doInProducer(ProducerCache.java:352)
	at org.apache.camel.impl.ProducerCache$2.doInProducer(ProducerCache.java:324)
	at org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:223)
	at org.apache.camel.impl.ProducerCache.sendExchange(ProducerCache.java:324)
	at org.apache.camel.impl.ProducerCache.send(ProducerCache.java:186)
	at org.apache.camel.impl.DefaultProducerTemplate.send(DefaultProducerTemplate.java:115)
	at org.apache.camel.impl.DefaultProducerTemplate.sendBody(DefaultProducerTemplate.java:119)
	... 33 more


*/

private void setupCamel() {
	SimpleRegistry registry = new SimpleRegistry();
        registry.put("sugarService", sugarService);
        registry.put("advantageService", advantageService);
        registry.put("dataWarehouseService", dataWarehouseService);
        camelContext = new DefaultCamelContext(registry);
        
        try {
            camelContext.addRoutes(new RouteBuilder() {

                @Override
                public void configure() throws Exception {
                    from("direct:updatePlayer")
                    .choice()
                       .when(new SugarPredicate())
                       .to("mock:bleh");
                    
                }
                
            });
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
        
        camelProducerTemplate = camelContext.createProducerTemplate();
}

public WsUpdateStatus updatePlayer(WsPlayer player) {
        setupCamel();
        List<DataWarehousePlayer> players = new ArrayList<DataWarehousePlayer>();
        players.add(new WarehousePlayerFacade(player));
        players.add(dataWarehouseService.getPlayerById(player.getId()));
        
        camelProducerTemplate.requestBody("direct:updatePlayer", players);
        
        return null;
        
        
}