[camel] 02/05: CAMEL-13054: Olingo4Endpoint - avoid swallowing consumer options

[dm...@apache.org]

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

dmvolod pushed a commit to branch camel-2.23.x
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 00397557e28859a3c5415c50b1bb72872e00463a
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 109bfba..62e94a3 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