You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/10/05 08:43:59 UTC
[camel-kafka-connector] branch issue-498 created (now 7c211a8)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch issue-498
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
at 7c211a8 A
This branch includes the following new commits:
new aea04bf [camel-main-support] Reordering props should not be required anymore
new 7c211a8 A
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[camel-kafka-connector] 02/02: A
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch issue-498
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 7c211a8382effaad5793e8a5a36d4fb09615edf5
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Oct 5 08:31:25 2020 +0200
A
---
.../java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java
index c950696..cd01cf9 100644
--- a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java
+++ b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java
@@ -76,8 +76,9 @@ public class CamelMainSupport {
camelMain.addMainListener(new CamelMainFinishedListener());
camelMain.configure().setAutoConfigurationLogSummary(false);
+
Properties camelProperties = new OrderedProperties();
- camelProperties.putAll(orderedProps);
+ camelProperties.putAll(props);
LOG.info("Setting initial properties in Camel context: [{}]", camelProperties);
this.camel.getPropertiesComponent().setInitialProperties(camelProperties);
[camel-kafka-connector] 01/02: [camel-main-support] Reordering
props should not be required anymore
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch issue-498
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit aea04bfb27de3c0ae16c1e9edbd3e92fb274da43
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Oct 5 08:29:58 2020 +0200
[camel-main-support] Reordering props should not be required anymore
---
.../org/apache/camel/kafkaconnector/utils/CamelMainSupport.java | 9 ---------
1 file changed, 9 deletions(-)
diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java
index 51dad11..c950696 100644
--- a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java
+++ b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java
@@ -76,15 +76,6 @@ public class CamelMainSupport {
camelMain.addMainListener(new CamelMainFinishedListener());
camelMain.configure().setAutoConfigurationLogSummary(false);
- // reordering properties to place the one starting with "#class:" first
- LinkedHashMap<String, String> orderedProps = new LinkedHashMap<>();
- props.keySet().stream()
- .filter(k -> props.get(k).startsWith("#class:"))
- .forEach(k -> orderedProps.put(k, props.get(k)));
- props.keySet().stream()
- .filter(k -> !props.get(k).startsWith("#class:"))
- .forEach(k -> orderedProps.put(k, props.get(k)));
-
Properties camelProperties = new OrderedProperties();
camelProperties.putAll(orderedProps);