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 c7a71fd  CAMEL-13063: Olingo2Endpoint swallowing consumer. options
c7a71fd is described below

commit c7a71fdadbeedec469778943b25fdc2c25dc3fa9
Author: Dmitry Volodin <dmvo...@gmail.com>
AuthorDate: Wed Jan 16 13:34:08 2019 +0300

    CAMEL-13063: Olingo2Endpoint swallowing consumer. options
---
 .../java/org/apache/camel/component/olingo2/Olingo2Endpoint.java  | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git 
a/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2Endpoint.java
 
b/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2Endpoint.java
index 94fdc7a..8ddccc5 100644
--- 
a/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2Endpoint.java
+++ 
b/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2Endpoint.java
@@ -195,6 +195,14 @@ public class Olingo2Endpoint extends 
AbstractApiEndpoint<Olingo2ApiName, Olingo2
 
             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)) {
 

Reply via email to