Change in Exchange creation

goozi · Aug 17, 2015 · 004f1d3 · 004f1d3
1 parent 82e5f89
commit 004f1d3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/modules/activiti-camel/src/main/java/org/activiti/camel/CamelBehavior.java b/modules/activiti-camel/src/main/java/org/activiti/camel/CamelBehavior.java
@@ -132,7 +132,7 @@ protected ActivitiEndpoint getEndpoint(String key) {
   }
 
   protected Exchange createExchange(ActivityExecution activityExecution, ActivitiEndpoint endpoint) {
-    Exchange ex = new DefaultExchange(camelContextObj);
+    Exchange ex = endpoint.createExchange();
     ex.setProperty(ActivitiProducer.PROCESS_ID_PROPERTY, activityExecution.getProcessInstanceId());
     ex.setProperty(ActivitiProducer.EXECUTION_ID_PROPERTY, activityExecution.getId());
     Map<String, Object> variables = activityExecution.getVariables();