If we do not declare the following bean then we are getting the bean not found error.
<camelContext id="camelContext" xmlns="http://camel.apache.org/schema/spring">
<packageScan>
<package>com.sigma.omp.engine.bpmn.camel.route</package>
</packageScan>
</camelContext>
<bean id="camel" class="org.camunda.bpm.camel.spring.CamelServiceImpl">
<property name="processEngine" ref="processEngine" />
<property name="camelContext" ref="camelContext"/>
</bean>
The current Route for testing I had configured as follows.
from("direct://asyncService1").routeId("asyncService1").to("seda:asyncService1Queue?waitForTaskToComplete=Never");
from("seda:asyncService1Queue").routeId("asyncResponse").process(new Processor() {
@Override
public void process(Exchange arg0) throws Exception {
System.out.println("Camunda Testing .... ");
}
}).to("camunda-bpm:message?messageName=camel.answer");
After adding bean defination the message get posted on queue and we are able to
get the Message as 'Camunda Testing'
But after that it hault.
So seems to be camunda-bpm:message not working.
I had tried to add , Camunda - BPM manually by extending CamelServiceImpl.
But still , result is the same.
Thanks,
Amol Walanj
I haven't got any error / exception.
Thanks,
Amol Walanj
from("seda:asyncService1Queue").routeId("asyncResponse").process(new Processor() {
@Override
public void process(Exchange arg0) throws Exception {
System.out.println("Camunda Testing .... ");
}
}).to("camunda-bpm:message?messageName=camel.answer");
From my above route definition , I can see exact number of "Camunda Testing.." statement in log. But the process didn't get completed.
Thanks,
Amol Walanj