Weird issue between Camel and Activiti

sdesbure — Tue, 21 Oct 2014 09:48:31 GMT

Hello all,First I'm quite a noob in Spring, Activiti and Camel so I hope that my issue is an easy one ^^.So for my further needs, I want to use Camel for a long processing task.<!–break–>I've then created the following flow to test:<?xml version="1.0" encoding="UTF-8"?><definitions xm

Re: Weird issue between Camel and Activiti

sdesbure — Tue, 21 Oct 2014 09:50:50 GMT

Hello all,
First I'm quite a noob in Spring, Activiti and Camel so I hope that my issue is an easy one ^^.
So for my further needs, I want to use Camel for a long processing task.

I've then created the following flow to test:


<?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL"
 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema"
 xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI"
 xmlns:smileysurprised:mgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:smileysurprised:mgdi="http://www.omg.org/spec/DD/20100524/DI"
 typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath"
 targetNamespace="http://www.activiti.org/test">
 <process id="camelProcess" isExecutable="true">
  <startEvent id="start">
   <extensionElements>
    <activiti:formProperty id="first_var"
     name="first Var" type="string" default="first-variable"
     required="true"></activiti:formProperty>
    <activiti:formProperty id="customer_name"
     name="Client Name" type="string" default="Customer" required="true"></activiti:formProperty>
   </extensionElements>
  </startEvent>
  <sequenceFlow id="flow1" sourceRef="start" targetRef="camelTask"></sequenceFlow>
  <serviceTask id="camelTask" name="Invoke Camel route"
   activiti:type="camel">
   <!– <extensionElements>
    <activiti:field name="camelBehaviorClass"
     stringValue="org.activiti.camel.impl.CamelBehaviorDefaultImpl" />
   </extensionElements> –>
  </serviceTask>
  <sequenceFlow id="flow2" sourceRef="camelTask" targetRef="receiveTask"></sequenceFlow>
  <receiveTask id="receiveTask" name="Wait for response"></receiveTask>
  <serviceTask id="servicetask1" name="Service Task"
   activiti:class="com.easyvpn.oss.orchestrator.workflow.TestTask"></serviceTask>
  <sequenceFlow id="flow3" sourceRef="receiveTask"
   targetRef="servicetask1"></sequenceFlow>
  <endEvent id="endevent1" name="End"></endEvent>
  <sequenceFlow id="flow4" sourceRef="servicetask1"
   targetRef="endevent1"></sequenceFlow>
 </process>
</definitions>

I've got the following route in Camel:
[java]
import org.apache.camel.builder.RouteBuilder;

public class AsyncTestCamel extends RouteBuilder {

@Override
public void configure() throws Exception {
   from("activiti:camelProcess:camelTask").to("seda:asyncQueue");
   from("seda:asyncQueue").to("bean:testAsyncTask").to("seda:receiveQueue");
   from("seda:receiveQueue").to("activiti:camelProcess:receiveTask");
}
}
[/java]

Re: Weird issue between Camel and Activiti

sdesbure — Tue, 21 Oct 2014 10:08:49 GMT

Hello all,
First I'm quite a noob in Spring, Activiti and Camel so I hope that my issue is an easy one ^^. And sorry for the previous topic which is not working…

So for my further needs, I want to use Camel for a long processing task.

I've then created the following flow to test:

<code>
<?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema"
xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI"
xmlnsmgdc="http://www.omg.org/spec/DD/20100524/DC" xmlnsmgdi="http://www.omg.org/spec/DD/20100524/DI"
typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath"
targetNamespace="http://www.activiti.org/test">
<process id="camelProcess" isExecutable="true">
<startEvent id="start">
   <extensionElements>
    <activiti:formProperty id="first_var"
     name="first Var" type="string" default="first-variable"
     required="true"></activiti:formProperty>
    <activiti:formProperty id="customer_name"
     name="Client Name" type="string" default="Customer" required="true"></activiti:formProperty>
   </extensionElements>
</startEvent>
<sequenceFlow id="flow1" sourceRef="start" targetRef="camelTask"></sequenceFlow>
<serviceTask id="camelTask" name="Invoke Camel route"
   activiti:type="camel">
   <!– <extensionElements>
    <activiti:field name="camelBehaviorClass"
     stringValue="org.activiti.camel.impl.CamelBehaviorDefaultImpl" />
   </extensionElements> –>
</serviceTask>
<sequenceFlow id="flow2" sourceRef="camelTask" targetRef="receiveTask"></sequenceFlow>
<receiveTask id="receiveTask" name="Wait for response"></receiveTask>
<serviceTask id="servicetask1" name="Service Task"
   activiti:class="com.easyvpn.oss.orchestrator.workflow.TestTask"></serviceTask>
<sequenceFlow id="flow3" sourceRef="receiveTask"
   targetRef="servicetask1"></sequenceFlow>
<endEvent id="endevent1" name="End"></endEvent>
<sequenceFlow id="flow4" sourceRef="servicetask1"
   targetRef="endevent1"></sequenceFlow>
</process>
</definitions>
</code>

I've got the following route in Camel:
<code>
import org.apache.camel.builder.RouteBuilder;

public class AsyncTestCamel extends RouteBuilder {

@Override
public void configure() throws Exception {
   from("activiti:camelProcess:camelTask").to("seda:asyncQueue");
   from("seda:asyncQueue").to("bean:testAsyncTask").to("seda:receiveQueue");
   from("seda:receiveQueue").to("activiti:camelProcess:receiveTask");
}
}
</code>

I've got the following classes:
<code>
import java.util.Map;

import org.apache.camel.OutHeaders;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class TestAsyncTask {
private static final Logger logger = LoggerFactory.getLogger(CreateInternetFirewallServiceInstance.class);

public void execute(String first_var, String customer_name, @OutHeaders Map<String,String> headers) throws Exception {
logger.debug("Entering CreateInternetFirewallServiceInstance");
logger.debug("value received: first_var: "+first_var+", customer_name: "+customer_name);

String name = customer_name.replaceAll(" ", "-").replaceAll("_", "-").toLowerCase() + "-test-test";
headers.put("new_var", name);
}
}
</code>

<code>
import org.activiti.engine.delegate.DelegateExecution;
import org.activiti.engine.delegate.JavaDelegate;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class TestTask implements JavaDelegate {
private static final Logger logger = LoggerFactory.getLogger(CreateCoreVirtualNetwork.class);

@Override
public void execute(DelegateExecution execution) throws Exception {
String new_var = (String) execution.getVariable("new_var");
logger.debug("retrieved new_var: "+new_var);
}

}
</code>

To test that, I use the following test class:
<code>
import static org.junit.Assert.assertNotNull;

import java.util.HashMap;
import java.util.Map;

import org.activiti.engine.RuntimeService;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.test.ActivitiRule;
import org.activiti.engine.test.Deployment;
import org.junit.Rule;
import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class MyProcessTest {
private static final Logger logger = LoggerFactory.getLogger(CreateInternetChainTest.class);

@Rule
public ActivitiRule activitiRule = new ActivitiRule("activiti.cfg-mem.xml");

@Test
@Deployment(resources={"diagrams/MyProcess.bpmn"})
public void startMyProcess() {
logger.debug("Starting test");
RuntimeService runtimeService = activitiRule.getProcessEngine().getRuntimeService();

Map<String, Object> formProperties = new HashMap<String, Object>();
formProperties.put("first_var", "var-var");
formProperties.put("customer_name", "Customer Name");

ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("camelProcess", formProperties);
logger.debug("processInstance ID: "+processInstance.getId());

assertNotNull(processInstance.getId());
}

}
</code>

Finally, I use the following spring configurations (activiti.cfg-mem.xml):
<code>
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
xmlns:camel="http://camel.apache.org/schema/spring"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd
http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">

<contextroperty-placeholder location="classpath:application.properties"
ignore-resource-not-found="false" />

<import resource="orchestrator.xml" />

<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
<property name="url" value="jdbc:h2:mem:activiti;DB_CLOSE_DELAY=1000" />
</bean>

<bean id="transactionManager"
class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource" />
</bean>

<bean id="processEngineConfiguration" class="org.activiti.spring.SpringProcessEngineConfiguration">
<property name="dataSource" ref="dataSource" />
<property name="transactionManager" ref="transactionManager" />
<property name="databaseSchemaUpdate" value="true" />
<property name="jobExecutorActivate" value="false" />
</bean>

<bean id="processEngine" class="org.activiti.spring.ProcessEngineFactoryBean">
<property name="processEngineConfiguration" ref="processEngineConfiguration" />
</bean>

<bean id="repositoryService" factory-bean="processEngine"
factory-method="getRepositoryService" />
<bean id="runtimeService" factory-bean="processEngine"
factory-method="getRuntimeService" />
<bean id="taskService" factory-bean="processEngine"
factory-method="getTaskService" />
<bean id="historyService" factory-bean="processEngine"
factory-method="getHistoryService" />
<bean id="managementService" factory-bean="processEngine"
factory-method="getManagementService" />

</beans>
</code>

(orchestrator.xml)
<code>
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
xmlns:camel="http://camel.apache.org/schema/spring"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd
http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">

<contextroperty-placeholder location="classpath:application.properties"
ignore-resource-not-found="false" />

<bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent">
<property name="brokerURL" value="tcp://somehost:61616" />
</bean>

<camelContext id="camelContext" xmlns="http://camel.apache.org/schema/spring">
<packageScan>
   <package>com.easyvpn.oss.orchestrator.routes</package>
</packageScan>
</camelContext>

<bean id="mapper" class="com.fasterxml.jackson.databind.ObjectMapper" />

<bean id="testTask" class="com.easyvpn.oss.orchestrator.workflow.TestTask">
</bean>

<bean id="testAsyncTask" class="com.easyvpn.oss.orchestrator.workflow.TestAsyncTask">
</bean>

</beans>
</code>

When I launch my test via Eclipse (maven seems to load the right jars, i.e. activiti-***-5.16.4, camel-***-2.14.0, activemq-***-5.10, …), Here's the following error I have:
<code>
DEBUG TransactionTemplate - Initiating transaction rollback on application exception
java.lang.NullPointerException
at org.activiti.camel.CamelBehavior.setAppropriateCamelContext(CamelBehavior.java:222)
at org.activiti.camel.CamelBehavior.execute(CamelBehavior.java:107)
</code>

the log of the test is attached

any idea why it's not working?

Thanks in advance

Re: Weird issue between Camel and Activiti

smirzai — Tue, 21 Oct 2014 12:20:13 GMT

I am not sure if activiti initialized the context if you use @Deployment.
Try it with something like this:

@ContextConfiguration("classpath:your_context_file.xml")
public class MyProcessTest {

public class AsyncPingTest extends SpringActivitiTestCase {

Re: Weird issue between Camel and Activiti

smirzai — Tue, 21 Oct 2014 12:20:44 GMT

If not working, a compilable test case is a great help to debug the problem.

Re: Weird issue between Camel and Activiti

sdesbure — Tue, 21 Oct 2014 12:57:40 GMT

hello : <code>@ContextConfiguration("classpath:your_context_file.xml")</code> did the trick!
Thansk a lot

Re: Weird issue between Camel and Activiti

smirzai — Tue, 21 Oct 2014 13:05:49 GMT

Great !

topic Weird issue between Camel and Activiti in Alfresco Archive

Weird issue between Camel and Activiti

Re: Weird issue between Camel and Activiti

Re: Weird issue between Camel and Activiti

Re: Weird issue between Camel and Activiti

Re: Weird issue between Camel and Activiti

Re: Weird issue between Camel and Activiti

Re: Weird issue between Camel and Activiti