@ PostConstruct public void init ( ) throws Exception { log . info ( "=======================" ) ; log . info ( "Adding camunda BPM Component to Camel" ) ; log . info ( "=======================" ) ; CamundaBpmComponent component = new CamundaBpmComponent ( processEngine ) ; component . setCamelContext ( cdiCamelContext ) ; cdiCamelContext . addComponent ( "camunda-bpm" , component ) ; // TODO: could be done by META-INF/service as well- maybe switch? // For simplicity JMS was removed from the example - but you can easily re-add it: // inject the JMS connection factory into camel's JMS component // JmsComponent jmsComponent = cdiCamelContext.getComponent("jms", JmsComponent.class); // jmsComponent.setConnectionFactory(queueConnectionFactory); // Instead we exchanged the JMS component by replacing it with Camel seda component for in memory queues cdiCamelContext . addComponent ( "jms" , cdiCamelContext . getComponent ( "seda" , SedaComponent . class ) ) ; // add routes to camel context log . info ( "=======================" ) ; log . info ( "adding OpenAccountRoute to camel context" ) ; log . info ( "=======================" ) ; cdiCamelContext . addRoutes ( openAccountRoute ) ; log . info ( "=======================" ) ; log . info ( "Camel Components: " + cdiCamelContext . getComponentNames ( ) ) ; log . info ( "=======================" ) ; log . info ( "=======================" ) ; log . info ( "starting camel context" ) ; log . info ( "=======================" ) ; // cdiCamelContext.setTracing(true); cdiCamelContext . start ( ) ; log . info ( "=======================" ) ; log . info ( "successfully created camel context and started open account route!" ) ; log . info ( "=======================" ) ; }
private QueueConnectionFactory queueConnectionFactory ;