This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit 944f7db67103f2fc18a2c38a937d1fe8ad34ace0 Author: Claus Ibsen <[email protected]> AuthorDate: Mon Sep 2 15:31:31 2019 +0200 CAMEL-13917: Configuring endpoints with consumer. prefix for consumer options is no longer supported as they should be regular options instead. This also avoid reflection setting properties. --- .../camel/component/mybatis/MyBatisEndpoint.java | 6 +++--- .../camel/component/mybatis/MyBatisQueueTest.java | 2 +- .../mybatis/MyBatisRouteEmptyResultSetTest.java | 2 +- .../src/main/docs/olingo2-component.adoc | 8 ++++---- .../camel/component/olingo2/Olingo2Component.java | 6 ------ .../component/olingo2/Olingo2Configuration.java | 14 ++++++++++++++ .../camel/component/olingo2/Olingo2Endpoint.java | 7 ++----- .../olingo2/Olingo2ComponentConsumerTest.java | 16 ++++++++-------- .../camel/component/olingo2/Olingo2SampleServer.java | 2 +- .../src/main/docs/olingo4-component.adoc | 6 +++--- .../component/olingo4/Olingo4Configuration.java | 14 ++++++++++++++ .../camel/component/olingo4/Olingo4Endpoint.java | 7 ++----- .../olingo4/Olingo4ComponentConsumerTest.java | 20 ++++++++++---------- 13 files changed, 63 insertions(+), 47 deletions(-) diff --git a/components/camel-mybatis/src/main/java/org/apache/camel/component/mybatis/MyBatisEndpoint.java b/components/camel-mybatis/src/main/java/org/apache/camel/component/mybatis/MyBatisEndpoint.java index 83eae40..d2d1503 100644 --- a/components/camel-mybatis/src/main/java/org/apache/camel/component/mybatis/MyBatisEndpoint.java +++ b/components/camel-mybatis/src/main/java/org/apache/camel/component/mybatis/MyBatisEndpoint.java @@ -41,11 +41,11 @@ public class MyBatisEndpoint extends BaseMyBatisEndpoint { private boolean transacted; @UriParam(label = "consumer", defaultValue = "0") private int maxMessagesPerPoll; - @UriParam(label = "consumer", optionalPrefix = "consumer.") + @UriParam(label = "consumer") private String onConsume; - @UriParam(label = "consumer", optionalPrefix = "consumer.", defaultValue = "true") + @UriParam(label = "consumer", defaultValue = "true") private boolean useIterator = true; - @UriParam(label = "consumer", optionalPrefix = "consumer.") + @UriParam(label = "consumer") private boolean routeEmptyResultSet; @UriParam(label = "consumer,advanced") private MyBatisProcessingStrategy processingStrategy = new DefaultMyBatisProcessingStrategy(); diff --git a/components/camel-mybatis/src/test/java/org/apache/camel/component/mybatis/MyBatisQueueTest.java b/components/camel-mybatis/src/test/java/org/apache/camel/component/mybatis/MyBatisQueueTest.java index c62eac1..513ac32 100644 --- a/components/camel-mybatis/src/test/java/org/apache/camel/component/mybatis/MyBatisQueueTest.java +++ b/components/camel-mybatis/src/test/java/org/apache/camel/component/mybatis/MyBatisQueueTest.java @@ -76,7 +76,7 @@ public class MyBatisQueueTest extends MyBatisTestSupport { return new RouteBuilder() { public void configure() throws Exception { // START SNIPPET: e1 - from("mybatis:selectUnprocessedAccounts?consumer.onConsume=consumeAccount").to("mock:results"); + from("mybatis:selectUnprocessedAccounts?onConsume=consumeAccount").to("mock:results"); // END SNIPPET: e1 from("direct:start").to("mybatis:insertAccount?statementType=Insert"); diff --git a/components/camel-mybatis/src/test/java/org/apache/camel/component/mybatis/MyBatisRouteEmptyResultSetTest.java b/components/camel-mybatis/src/test/java/org/apache/camel/component/mybatis/MyBatisRouteEmptyResultSetTest.java index 0b5eb41..820de39 100644 --- a/components/camel-mybatis/src/test/java/org/apache/camel/component/mybatis/MyBatisRouteEmptyResultSetTest.java +++ b/components/camel-mybatis/src/test/java/org/apache/camel/component/mybatis/MyBatisRouteEmptyResultSetTest.java @@ -39,7 +39,7 @@ public class MyBatisRouteEmptyResultSetTest extends MyBatisTestSupport { protected RouteBuilder createRouteBuilder() throws Exception { return new RouteBuilder() { public void configure() throws Exception { - from("mybatis:selectAllAccounts?consumer.useIterator=false&consumer.routeEmptyResultSet=true").to("mock:results"); + from("mybatis:selectAllAccounts?useIterator=false&routeEmptyResultSet=true").to("mock:results"); } }; } diff --git a/components/camel-olingo2/camel-olingo2-component/src/main/docs/olingo2-component.adoc b/components/camel-olingo2/camel-olingo2-component/src/main/docs/olingo2-component.adoc index 2a4d460..83929b5 100644 --- a/components/camel-olingo2/camel-olingo2-component/src/main/docs/olingo2-component.adoc +++ b/components/camel-olingo2/camel-olingo2-component/src/main/docs/olingo2-component.adoc @@ -254,11 +254,11 @@ java.util.List<java.util.Map<String, Object>> containing list of key property na Only the *read* endpoint can be used as a consumer endpoint. Consumer endpoints can use http://camel.apache.org/polling-consumer.html#PollingConsumer-ScheduledPollConsumerOptions[Scheduled -Poll Consumer Options] with a *`consumer.`* prefix to schedule endpoint +Poll Consumer Options] to schedule endpoint invocation. By default consumer endpoints that return an array or collection will generate one exchange per element, and their routes will be executed once for each exchange. This behavior can be disabled by -setting the endpoint property *consumer.splitResult=false*. +setting the endpoint property *splitResult=false*. == Message Headers @@ -273,7 +273,7 @@ API] used by the Olingo2Component. Producer endpoints can specify the option name for incoming message body in the *`inBody`* endpoint URI parameter. For endpoints that return an array or collection, a consumer endpoint will map every element to distinct messages, unless -*consumer.splitResult* is set to *false*. +*splitResult* is set to *false*. == Use cases @@ -330,6 +330,6 @@ consumer endpoint will produce an *ODataFeed* value the first time, and [source,java] --------------------------------------------------------------------------------------------------------- -from("olingo2://read/Manufacturers?queryParams=#paramsBean&consumer.timeUnit=SECONDS&delay=30") +from("olingo2://read/Manufacturers?queryParams=#paramsBean&timeUnit=SECONDS&delay=30") .to("bean:blah"); --------------------------------------------------------------------------------------------------------- diff --git a/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2Component.java b/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2Component.java index ed49da9..35e4c7e 100644 --- a/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2Component.java +++ b/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2Component.java @@ -81,13 +81,7 @@ public class Olingo2Component extends AbstractApiComponent<Olingo2ApiName, Oling final Olingo2Configuration endpointConfiguration = createEndpointConfiguration(Olingo2ApiName.DEFAULT); final Endpoint endpoint = createEndpoint(uri, methodName, Olingo2ApiName.DEFAULT, endpointConfiguration); - - // set endpoint property inBody setProperties(endpoint, parameters); - - // configure endpoint properties and initialize state - endpoint.configureProperties(parameters); - return endpoint; } diff --git a/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2Configuration.java b/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2Configuration.java index 78b4604..4d2b6f4 100644 --- a/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2Configuration.java +++ b/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2Configuration.java @@ -65,6 +65,8 @@ public class Olingo2Configuration { private HttpClientBuilder httpClientBuilder; @UriParam private boolean filterAlreadySeen; + @UriParam(label = "consumer", defaultValue = "true") + private boolean splitResult = true; public Olingo2ApiName getApiName() { return apiName; @@ -214,6 +216,18 @@ public class Olingo2Configuration { this.filterAlreadySeen = filterAlreadySeen; } + public boolean isSplitResult() { + return splitResult; + } + + /** + * For endpoints that return an array or collection, a consumer endpoint will map every element to distinct messages, unless + * splitResult is set to false. + */ + public void setSplitResult(boolean splitResult) { + this.splitResult = splitResult; + } + @Override public int hashCode() { return new HashCodeBuilder().append(serviceUri).append(contentType).append(httpHeaders).append(connectTimeout).append(socketTimeout).append(proxy) 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 05e7c06..1cf70eb 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 @@ -95,7 +95,7 @@ public class Olingo2Endpoint extends AbstractApiEndpoint<Olingo2ApiName, Olingo2 throw new IllegalArgumentException("Only read method is supported for consumer endpoints"); } final Olingo2Consumer consumer = new Olingo2Consumer(this, processor); - // also set consumer.* properties + consumer.setSplitResult(configuration.isSplitResult()); configureConsumer(consumer); return consumer; } @@ -204,10 +204,7 @@ 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() - */ + // avoid swallowing consumer scheduler properties, which get processed in configureProperties() if (paramName.startsWith("consumer.")) { continue; } diff --git a/components/camel-olingo2/camel-olingo2-component/src/test/java/org/apache/camel/component/olingo2/Olingo2ComponentConsumerTest.java b/components/camel-olingo2/camel-olingo2-component/src/test/java/org/apache/camel/component/olingo2/Olingo2ComponentConsumerTest.java index 9d3b875..851091a 100644 --- a/components/camel-olingo2/camel-olingo2-component/src/test/java/org/apache/camel/component/olingo2/Olingo2ComponentConsumerTest.java +++ b/components/camel-olingo2/camel-olingo2-component/src/test/java/org/apache/camel/component/olingo2/Olingo2ComponentConsumerTest.java @@ -73,7 +73,7 @@ public class Olingo2ComponentConsumerTest extends AbstractOlingo2TestSupport { * Read entity set of the People object and filter already seen items on * subsequent exchanges Use a delay since the mock endpoint does not always * get the correct number of exchanges before being satisfied. Note: - - * consumer.splitResults is set to false since this ensures the first + * splitResults is set to false since this ensures the first * returned message contains all the results. This is preferred for the * purposes of this test. The default will mean the first n messages contain * the results (where n is the result total) then subsequent messages will @@ -88,7 +88,7 @@ public class Olingo2ComponentConsumerTest extends AbstractOlingo2TestSupport { RouteBuilder builder = new RouteBuilder() { public void configure() { - from("olingo2://read/Manufacturers?filterAlreadySeen=true&" + "delay=2&sendEmptyMessageWhenIdle=true&" + "consumer.splitResult=false") + from("olingo2://read/Manufacturers?filterAlreadySeen=true&" + "delay=2&sendEmptyMessageWhenIdle=true&" + "splitResult=false") .to("mock:consumer-alreadyseen"); }; }; @@ -120,7 +120,7 @@ public class Olingo2ComponentConsumerTest extends AbstractOlingo2TestSupport { * Read entity set of the People object and filter already seen items on * subsequent exchanges Use a delay since the mock endpoint does not always * get the correct number of exchanges before being satisfied. Note: - - * consumer.splitResults is set to false since this ensures the first + * splitResults is set to false since this ensures the first * returned message contains all the results. - * sendEmptyMessageWhenIdle is set to false so only 1 message * should even be returned. @@ -138,7 +138,7 @@ public class Olingo2ComponentConsumerTest extends AbstractOlingo2TestSupport { RouteBuilder builder = new RouteBuilder() { public void configure() { - from("olingo2://read/Manufacturers?filterAlreadySeen=true&" + "delay=2&sendEmptyMessageWhenIdle=false&" + "consumer.splitResult=false") + from("olingo2://read/Manufacturers?filterAlreadySeen=true&" + "delay=2&sendEmptyMessageWhenIdle=false&" + "splitResult=false") .to("mock:consumer-alreadyseen"); }; }; @@ -176,7 +176,7 @@ public class Olingo2ComponentConsumerTest extends AbstractOlingo2TestSupport { RouteBuilder builder = new RouteBuilder() { public void configure() { - from("olingo2://read/Manufacturers('1')?filterAlreadySeen=true&" + "delay=2&sendEmptyMessageWhenIdle=true&" + "consumer.splitResult=true") + from("olingo2://read/Manufacturers('1')?filterAlreadySeen=true&" + "delay=2&sendEmptyMessageWhenIdle=true&" + "splitResult=true") .to("mock:consumer-splitresult-kp-manufacturer"); }; }; @@ -226,7 +226,7 @@ public class Olingo2ComponentConsumerTest extends AbstractOlingo2TestSupport { RouteBuilder builder = new RouteBuilder() { public void configure() { - from("olingo2://read/Manufacturers('1')?filterAlreadySeen=true&" + "delay=2&sendEmptyMessageWhenIdle=false&" + "consumer.splitResult=true") + from("olingo2://read/Manufacturers('1')?filterAlreadySeen=true&" + "delay=2&sendEmptyMessageWhenIdle=false&" + "splitResult=true") .to("mock:consumer-splitresult-kp-manufacturer"); }; }; @@ -265,7 +265,7 @@ public class Olingo2ComponentConsumerTest extends AbstractOlingo2TestSupport { RouteBuilder builder = new RouteBuilder() { public void configure() { - from("olingo2://read/Manufacturers('1')/Address?consumer.splitResult=true").to("mock:consumer-value"); + from("olingo2://read/Manufacturers('1')/Address?splitResult=true").to("mock:consumer-value"); }; }; addRouteAndStartContext(builder); @@ -298,7 +298,7 @@ public class Olingo2ComponentConsumerTest extends AbstractOlingo2TestSupport { RouteBuilder builder = new RouteBuilder() { public void configure() { - from("olingo2://read/Manufacturers?consumer.splitResult=true").to("mock:consumer-splitresult"); + from("olingo2://read/Manufacturers?splitResult=true").to("mock:consumer-splitresult"); }; }; diff --git a/components/camel-olingo2/camel-olingo2-component/src/test/java/org/apache/camel/component/olingo2/Olingo2SampleServer.java b/components/camel-olingo2/camel-olingo2-component/src/test/java/org/apache/camel/component/olingo2/Olingo2SampleServer.java index 5f3935c..5e97e9e 100644 --- a/components/camel-olingo2/camel-olingo2-component/src/test/java/org/apache/camel/component/olingo2/Olingo2SampleServer.java +++ b/components/camel-olingo2/camel-olingo2-component/src/test/java/org/apache/camel/component/olingo2/Olingo2SampleServer.java @@ -82,7 +82,7 @@ public class Olingo2SampleServer { m.invoke(null, serviceUrl); } catch (Throwable t) { LOG.error("Unable to load the required sample class", t); - throw new IOException("unable to load the required sample class"); + throw new IOException("unable to load the required sample class", t); } } } diff --git a/components/camel-olingo4/camel-olingo4-component/src/main/docs/olingo4-component.adoc b/components/camel-olingo4/camel-olingo4-component/src/main/docs/olingo4-component.adoc index 8aca8ab..9977a56 100644 --- a/components/camel-olingo4/camel-olingo4-component/src/main/docs/olingo4-component.adoc +++ b/components/camel-olingo4/camel-olingo4-component/src/main/docs/olingo4-component.adoc @@ -237,11 +237,11 @@ java.util.Map<String, Object> for In body (request) Only the *read* endpoint can be used as a consumer endpoint. Consumer endpoints can use http://camel.apache.org/polling-consumer.html#PollingConsumer-ScheduledPollConsumerOptions[Scheduled -Poll Consumer Options] with a *`consumer.`* prefix to schedule endpoint +Poll Consumer Options] to schedule endpoint invocation. By default consumer endpoints that return an array or collection will generate one exchange per element, and their routes will be executed once for each exchange. This behavior can be disabled by -setting the endpoint property *consumer.splitResult=false*. +setting the endpoint property *splitResult=false*. == Message Headers @@ -256,7 +256,7 @@ API] used by the Olingo4Component. Producer endpoints can specify the option name for incoming message body in the *`inBody`* endpoint URI parameter. For endpoints that return an array or collection, a consumer endpoint will map every element to distinct messages, unless -*consumer.splitResult* is set to *false*. +*splitResult* is set to *false*. == Use cases diff --git a/components/camel-olingo4/camel-olingo4-component/src/main/java/org/apache/camel/component/olingo4/Olingo4Configuration.java b/components/camel-olingo4/camel-olingo4-component/src/main/java/org/apache/camel/component/olingo4/Olingo4Configuration.java index d264cf3..0a519b8 100644 --- a/components/camel-olingo4/camel-olingo4-component/src/main/java/org/apache/camel/component/olingo4/Olingo4Configuration.java +++ b/components/camel-olingo4/camel-olingo4-component/src/main/java/org/apache/camel/component/olingo4/Olingo4Configuration.java @@ -64,6 +64,8 @@ public class Olingo4Configuration { private HttpClientBuilder httpClientBuilder; @UriParam private boolean filterAlreadySeen; + @UriParam(label = "consumer", defaultValue = "true") + private boolean splitResult = true; public Olingo4ApiName getApiName() { return apiName; @@ -213,6 +215,18 @@ public class Olingo4Configuration { this.filterAlreadySeen = filterAlreadySeen; } + public boolean isSplitResult() { + return splitResult; + } + + /** + * For endpoints that return an array or collection, a consumer endpoint will map every element to distinct messages, unless + * splitResult is set to false. + */ + public void setSplitResult(boolean splitResult) { + this.splitResult = splitResult; + } + @Override public int hashCode() { return new HashCodeBuilder().append(serviceUri).append(contentType).append(httpHeaders).append(connectTimeout).append(socketTimeout).append(proxy) 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 31aa4cf..d0d37d4 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 @@ -95,7 +95,7 @@ public class Olingo4Endpoint extends AbstractApiEndpoint<Olingo4ApiName, Olingo4 throw new IllegalArgumentException("Only read method is supported for consumer endpoints"); } final Olingo4Consumer consumer = new Olingo4Consumer(this, processor); - // also set consumer.* properties + consumer.setSplitResult(configuration.isSplitResult()); configureConsumer(consumer); return consumer; } @@ -205,10 +205,7 @@ 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() - */ + // Avoid swallowing consumer scheduler properties, which get processed in configureProperties() if (paramName.startsWith("consumer.")) { continue; } diff --git a/components/camel-olingo4/camel-olingo4-component/src/test/java/org/apache/camel/component/olingo4/Olingo4ComponentConsumerTest.java b/components/camel-olingo4/camel-olingo4-component/src/test/java/org/apache/camel/component/olingo4/Olingo4ComponentConsumerTest.java index 55eaa40..c0ae176 100644 --- a/components/camel-olingo4/camel-olingo4-component/src/test/java/org/apache/camel/component/olingo4/Olingo4ComponentConsumerTest.java +++ b/components/camel-olingo4/camel-olingo4-component/src/test/java/org/apache/camel/component/olingo4/Olingo4ComponentConsumerTest.java @@ -82,7 +82,7 @@ public class Olingo4ComponentConsumerTest extends AbstractOlingo4TestSupport { * Read entity set of the People object and filter already seen items on * subsequent exchanges Use a delay since the mock endpoint does not always * get the correct number of exchanges before being satisfied. Note: - - * consumer.splitResults is set to false since this ensures the first + * splitResults is set to false since this ensures the first * returned message contains all the results. This is preferred for the * purposes of this test. The default will mean the first n messages contain * the results (where n is the result total) then subsequent messages will @@ -97,7 +97,7 @@ public class Olingo4ComponentConsumerTest extends AbstractOlingo4TestSupport { RouteBuilder builder = new RouteBuilder() { public void configure() { - from("olingo4://read/" + PEOPLE + "?delay=2&sendEmptyMessageWhenIdle=true&consumer.splitResult=false&filterAlreadySeen=true") + from("olingo4://read/" + PEOPLE + "?delay=2&sendEmptyMessageWhenIdle=true&splitResult=false&filterAlreadySeen=true") .to("mock:consumer-alreadyseen"); }; }; @@ -129,7 +129,7 @@ public class Olingo4ComponentConsumerTest extends AbstractOlingo4TestSupport { * Read entity set of the People object and filter already seen items on * subsequent exchanges Use a delay since the mock endpoint does not always * get the correct number of exchanges before being satisfied. Note: - - * consumer.splitResults is set to false since this ensures the first + * splitResults is set to false since this ensures the first * returned message contains all the results. - * sendEmptyMessageWhenIdle is set to false so only 1 message * should even be returned. @@ -148,7 +148,7 @@ public class Olingo4ComponentConsumerTest extends AbstractOlingo4TestSupport { RouteBuilder builder = new RouteBuilder() { public void configure() { - from("olingo4://read/" + PEOPLE + "?delay=2&sendEmptyMessageWhenIdle=false&consumer.splitResult=false&filterAlreadySeen=true") + from("olingo4://read/" + PEOPLE + "?delay=2&sendEmptyMessageWhenIdle=false&splitResult=false&filterAlreadySeen=true") .to("mock:consumer-alreadyseen"); }; }; @@ -187,7 +187,7 @@ public class Olingo4ComponentConsumerTest extends AbstractOlingo4TestSupport { RouteBuilder builder = new RouteBuilder() { public void configure() { from("olingo4://read/" + AIRPORTS + "('KSFO')" + "?filterAlreadySeen=true&" + "delay=2&sendEmptyMessageWhenIdle=true&" - + "consumer.splitResult=true").to("mock:consumer-splitresult-kp-airport"); + + "splitResult=true").to("mock:consumer-splitresult-kp-airport"); }; }; addRouteAndStartContext(builder); @@ -237,7 +237,7 @@ public class Olingo4ComponentConsumerTest extends AbstractOlingo4TestSupport { RouteBuilder builder = new RouteBuilder() { public void configure() { from("olingo4://read/" + AIRPORTS + "('KSFO')" + "?filterAlreadySeen=true&" + "delay=2&sendEmptyMessageWhenIdle=false&" - + "consumer.splitResult=true").to("mock:consumer-splitresult-kp-airport"); + + "splitResult=true").to("mock:consumer-splitresult-kp-airport"); }; }; addRouteAndStartContext(builder); @@ -274,7 +274,7 @@ public class Olingo4ComponentConsumerTest extends AbstractOlingo4TestSupport { RouteBuilder builder = new RouteBuilder() { public void configure() { - from("olingo4://read/" + PEOPLE + "?consumer.splitResult=true").to("mock:consumer-splitresult"); + from("olingo4://read/" + PEOPLE + "?splitResult=true").to("mock:consumer-splitresult"); }; }; addRouteAndStartContext(builder); @@ -317,7 +317,7 @@ public class Olingo4ComponentConsumerTest extends AbstractOlingo4TestSupport { RouteBuilder builder = new RouteBuilder() { public void configure() { - from("olingo4://read/" + TEST_PEOPLE + "/FavoriteFeature?consumer.splitResult=true").to("mock:consumer-splitresult-value"); + from("olingo4://read/" + TEST_PEOPLE + "/FavoriteFeature?splitResult=true").to("mock:consumer-splitresult-value"); }; }; addRouteAndStartContext(builder); @@ -343,7 +343,7 @@ public class Olingo4ComponentConsumerTest extends AbstractOlingo4TestSupport { RouteBuilder builder = new RouteBuilder() { public void configure() { - from("olingo4://read/" + TEST_PEOPLE + "/AddressInfo?consumer.splitResult=true").to("mock:consumer-splitresult-collection-value"); + from("olingo4://read/" + TEST_PEOPLE + "/AddressInfo?splitResult=true").to("mock:consumer-splitresult-collection-value"); }; }; addRouteAndStartContext(builder); @@ -369,7 +369,7 @@ public class Olingo4ComponentConsumerTest extends AbstractOlingo4TestSupport { RouteBuilder builder = new RouteBuilder() { public void configure() { - from("olingo4://read/" + TEST_PEOPLE + "/AddressInfo?consumer.splitResult=false").to("mock:consumer-nosplitresult-colleciton-value"); + from("olingo4://read/" + TEST_PEOPLE + "/AddressInfo?splitResult=false").to("mock:consumer-nosplitresult-colleciton-value"); }; }; addRouteAndStartContext(builder);
