You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2019/09/02 14:28:43 UTC
[camel] 08/11: 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.
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 <cl...@gmail.com>
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);