[camel] branch master updated: CAMEL-14284: Configuring endpoint should set properties on endpoint and not configuration object - JBPM component

[da...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
     new 0653f9c  CAMEL-14284: Configuring endpoint should set properties on endpoint and not configuration object - JBPM component
0653f9c is described below

commit 0653f9c41859e15bfe7b5ff9412a066612d0aef5
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Wed Dec 11 10:28:24 2019 +0100

    CAMEL-14284: Configuring endpoint should set properties on endpoint and not configuration object - JBPM component
---
 .../main/java/org/apache/camel/component/jbpm/JBPMComponent.java    | 6 ++++--
 .../src/main/java/org/apache/camel/component/jbpm/JBPMEndpoint.java | 4 +++-
 2 files changed, 7 insertions(+), 3 deletions(-)

diff --git a/components/camel-jbpm/src/main/java/org/apache/camel/component/jbpm/JBPMComponent.java b/components/camel-jbpm/src/main/java/org/apache/camel/component/jbpm/JBPMComponent.java
index 0863fcb..d0c5475 100644
--- a/components/camel-jbpm/src/main/java/org/apache/camel/component/jbpm/JBPMComponent.java
+++ b/components/camel-jbpm/src/main/java/org/apache/camel/component/jbpm/JBPMComponent.java
@@ -33,7 +33,9 @@ public class JBPMComponent extends DefaultComponent {
         } else {        
             configuration.setConnectionURL(new URL(remaining));
         }
-        setProperties(configuration, parameters);
-        return new JBPMEndpoint(uri, this, configuration);
+        JBPMEndpoint endpoint = new JBPMEndpoint(uri, this, configuration);
+        setProperties(endpoint, parameters);
+        return endpoint;
     }
+
 }
\ No newline at end of file
diff --git a/components/camel-jbpm/src/main/java/org/apache/camel/component/jbpm/JBPMEndpoint.java b/components/camel-jbpm/src/main/java/org/apache/camel/component/jbpm/JBPMEndpoint.java
index 08404e2..14d8d9a 100644
--- a/components/camel-jbpm/src/main/java/org/apache/camel/component/jbpm/JBPMEndpoint.java
+++ b/components/camel-jbpm/src/main/java/org/apache/camel/component/jbpm/JBPMEndpoint.java
@@ -69,7 +69,9 @@ public class JBPMEndpoint extends DefaultEndpoint {
 
     public Consumer createConsumer(Processor processor) throws Exception {
         LOGGER.debug("JBPM Consumer created and configured for deployment {}", configuration.getDeploymentId());
-        return new JBPMConsumer(this, processor);
+        JBPMConsumer consumer = new JBPMConsumer(this, processor);
+        configureConsumer(consumer);
+        return consumer;
     }
 
     public void setConfiguration(JBPMConfiguration configuration) {