You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by dm...@apache.org on 2019/01/15 15:51:39 UTC
[camel] branch camel-2.21.x updated: CAMEL-13054: Olingo4Endpoint -
avoid swallowing consumer options
This is an automated email from the ASF dual-hosted git repository.
dmvolod pushed a commit to branch camel-2.21.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-2.21.x by this push:
new f4d42e6 CAMEL-13054: Olingo4Endpoint - avoid swallowing consumer options
f4d42e6 is described below
commit f4d42e64a943dbca8545187b79f77d0617071050
Author: phantomjinx <p....@phantomjinx.co.uk>
AuthorDate: Tue Jan 15 08:47:23 2019 +0000
CAMEL-13054: Olingo4Endpoint - avoid swallowing consumer options
* Those options prefixed with 'consumer' are required to be processed by
Olingo4Endpoint's parent class. However, they are getting added to the
query options instead and never applied to the scheduling consumer.
closes #2708
---
.../java/org/apache/camel/component/olingo4/Olingo4Endpoint.java | 8 ++++++++
1 file changed, 8 insertions(+)
diff --git a/components/camel-olingo4/camel-olingo4-component/src/main/java/org/apache/camel/component/olingo4/Olingo4Endpoint.java b/components/camel-olingo4/camel-olingo4-component/src/main/java/org/apache/camel/component/olingo4/Olingo4Endpoint.java
index 1c727b2..98f2c46 100644
--- a/components/camel-olingo4/camel-olingo4-component/src/main/java/org/apache/camel/component/olingo4/Olingo4Endpoint.java
+++ b/components/camel-olingo4/camel-olingo4-component/src/main/java/org/apache/camel/component/olingo4/Olingo4Endpoint.java
@@ -196,6 +196,14 @@ public class Olingo4Endpoint extends AbstractApiEndpoint<Olingo4ApiName, Olingo4
final Map.Entry<String, Object> entry = it.next();
final String paramName = entry.getKey();
+ /**
+ * Avoid swallowing consumer scheduler properties, which
+ * get processed in configureProperties()
+ */
+ if (paramName.startsWith("consumer.")) {
+ continue;
+ }
+
if (!endpointPropertyNames.contains(paramName)) {
// add to query params