This is an automated email from the ASF dual-hosted git repository. dmvolod pushed a commit to branch camel-2.x in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-2.x by this push: new e7e5316 CAMEL-13054: Olingo4Endpoint - avoid swallowing consumer options e7e5316 is described below commit e7e531607d906eb0a3d4599fe2cede1f59b68dba Author: phantomjinx <p.g.richard...@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