Component docs
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/4c597b88 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/4c597b88 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/4c597b88 Branch: refs/heads/master Commit: 4c597b887118cdd2f6ccf5a155d7bb3c0b99cc19 Parents: 6534eb6 Author: Claus Ibsen <[email protected]> Authored: Wed Jan 6 11:27:53 2016 +0100 Committer: Claus Ibsen <[email protected]> Committed: Wed Jan 6 11:36:30 2016 +0100 ---------------------------------------------------------------------- .../apache/camel/component/test/TestEndpoint.java | 2 +- .../component/cassandra/CassandraEndpoint.java | 6 +----- .../component/disruptor/DisruptorEndpoint.java | 18 ++++++++++++++++++ ...sticsearchGetSearchDeleteExistsUpdateTest.java | 2 +- .../camel/component/elsql/ElSqlConsumerTest.java | 2 +- .../component/elsql/ElSqlDataSourceTest.java | 2 +- .../elsql/ElSqlProducerBodySimpleTest.java | 2 +- 7 files changed, 24 insertions(+), 10 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/4c597b88/camel-core/src/main/java/org/apache/camel/component/test/TestEndpoint.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/component/test/TestEndpoint.java b/camel-core/src/main/java/org/apache/camel/component/test/TestEndpoint.java index ead1396..77030e2 100644 --- a/camel-core/src/main/java/org/apache/camel/component/test/TestEndpoint.java +++ b/camel-core/src/main/java/org/apache/camel/component/test/TestEndpoint.java @@ -41,7 +41,7 @@ import org.slf4j.LoggerFactory; * This will then set up a properly configured Mock endpoint, which is only valid if the received messages * match the number of expected messages and their message payloads are equal. */ -@UriEndpoint(scheme = "test", title = "Test", syntax = "test:name", producerOnly = true, label = "core,testing") +@UriEndpoint(scheme = "test", title = "Test", syntax = "test:name", producerOnly = true, label = "core,testing", lenientProperties = true) public class TestEndpoint extends MockEndpoint { private static final Logger LOG = LoggerFactory.getLogger(TestEndpoint.class); private final Endpoint expectedMessageEndpoint; http://git-wip-us.apache.org/repos/asf/camel/blob/4c597b88/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/CassandraEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/CassandraEndpoint.java b/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/CassandraEndpoint.java index 6aa6abf..ee5acbf 100644 --- a/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/CassandraEndpoint.java +++ b/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/CassandraEndpoint.java @@ -71,11 +71,7 @@ public class CassandraEndpoint extends DefaultEndpoint { private ConsistencyLevel consistencyLevel; @UriParam private String loadBalancingPolicy; - - /** - * How many rows should be retrieved in message body - */ - @UriParam + @UriParam(javaType = "java.lang.String") private ResultSetConversionStrategy resultSetConversionStrategy = ResultSetConversionStrategies.all(); public CassandraEndpoint(String endpointUri, Component component) { http://git-wip-us.apache.org/repos/asf/camel/blob/4c597b88/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorEndpoint.java b/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorEndpoint.java index cffb7ff..ec758a8 100644 --- a/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorEndpoint.java +++ b/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorEndpoint.java @@ -67,6 +67,8 @@ public class DisruptorEndpoint extends DefaultEndpoint implements MultipleConsum private WaitForTaskToComplete waitForTaskToComplete = WaitForTaskToComplete.IfReplyExpected; @UriParam(label = "producer", defaultValue = "30000") private long timeout = 30000; + @UriParam(defaultValue = "" + DisruptorComponent.DEFAULT_BUFFER_SIZE) + private int size; @UriParam(label = "producer") private boolean blockWhenFull; @UriParam(label = "consumer", defaultValue = "Blocking") @@ -140,6 +142,22 @@ public class DisruptorEndpoint extends DefaultEndpoint implements MultipleConsum this.timeout = timeout; } + @ManagedAttribute(description = "The maximum capacity of the Disruptors ringbuffer") + public int getSize() { + return size; + } + + /** + * The maximum capacity of the Disruptors ringbuffer + * Will be effectively increased to the nearest power of two. + * Notice: Mind if you use this option, then its the first endpoint being created with the queue name, + * that determines the size. To make sure all endpoints use same size, then configure the size option + * on all of them, or the first endpoint being created. + */ + public void setSize(int size) { + this.size = size; + } + @Override @ManagedAttribute(description = "Specifies whether multiple consumers are allowed") public boolean isMultipleConsumersSupported() { http://git-wip-us.apache.org/repos/asf/camel/blob/4c597b88/components/camel-elasticsearch/src/test/java/org/apache/camel/component/elasticsearch/ElasticsearchGetSearchDeleteExistsUpdateTest.java ---------------------------------------------------------------------- diff --git a/components/camel-elasticsearch/src/test/java/org/apache/camel/component/elasticsearch/ElasticsearchGetSearchDeleteExistsUpdateTest.java b/components/camel-elasticsearch/src/test/java/org/apache/camel/component/elasticsearch/ElasticsearchGetSearchDeleteExistsUpdateTest.java index 760745c..40cf6d8 100644 --- a/components/camel-elasticsearch/src/test/java/org/apache/camel/component/elasticsearch/ElasticsearchGetSearchDeleteExistsUpdateTest.java +++ b/components/camel-elasticsearch/src/test/java/org/apache/camel/component/elasticsearch/ElasticsearchGetSearchDeleteExistsUpdateTest.java @@ -308,7 +308,7 @@ public class ElasticsearchGetSearchDeleteExistsUpdateTest extends ElasticsearchB return new RouteBuilder() { @Override public void configure() { - from("direct:start").to("elasticsearch://local"); + from("direct:start").to("elasticsearch://local?operation=INDEX"); from("direct:index").to("elasticsearch://local?operation=INDEX&indexName=twitter&indexType=tweet"); from("direct:get").to("elasticsearch://local?operation=GET_BY_ID&indexName=twitter&indexType=tweet"); from("direct:multiget").to("elasticsearch://local?operation=MULTIGET&indexName=twitter&indexType=tweet"); http://git-wip-us.apache.org/repos/asf/camel/blob/4c597b88/components/camel-elsql/src/test/java/org/apache/camel/component/elsql/ElSqlConsumerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-elsql/src/test/java/org/apache/camel/component/elsql/ElSqlConsumerTest.java b/components/camel-elsql/src/test/java/org/apache/camel/component/elsql/ElSqlConsumerTest.java index 7d34cb3..a7f881f 100644 --- a/components/camel-elsql/src/test/java/org/apache/camel/component/elsql/ElSqlConsumerTest.java +++ b/components/camel-elsql/src/test/java/org/apache/camel/component/elsql/ElSqlConsumerTest.java @@ -80,7 +80,7 @@ public class ElSqlConsumerTest extends CamelTestSupport { return new RouteBuilder() { @Override public void configure() throws Exception { - from("elsql:allProjects:elsql/projects.elsql?dataSource=dataSource") + from("elsql:allProjects:elsql/projects.elsql?dataSource=#dataSource") .to("mock:result"); } }; http://git-wip-us.apache.org/repos/asf/camel/blob/4c597b88/components/camel-elsql/src/test/java/org/apache/camel/component/elsql/ElSqlDataSourceTest.java ---------------------------------------------------------------------- diff --git a/components/camel-elsql/src/test/java/org/apache/camel/component/elsql/ElSqlDataSourceTest.java b/components/camel-elsql/src/test/java/org/apache/camel/component/elsql/ElSqlDataSourceTest.java index e555808..37d6f16 100644 --- a/components/camel-elsql/src/test/java/org/apache/camel/component/elsql/ElSqlDataSourceTest.java +++ b/components/camel-elsql/src/test/java/org/apache/camel/component/elsql/ElSqlDataSourceTest.java @@ -77,7 +77,7 @@ public class ElSqlDataSourceTest extends CamelTestSupport { return new RouteBuilder() { public void configure() { from("direct:simple") - .to("elsql:projectsById:elsql/projects.elsql?dataSource=dataSource") + .to("elsql:projectsById:elsql/projects.elsql?dataSource=#dataSource") .to("mock:result"); } }; http://git-wip-us.apache.org/repos/asf/camel/blob/4c597b88/components/camel-elsql/src/test/java/org/apache/camel/component/elsql/ElSqlProducerBodySimpleTest.java ---------------------------------------------------------------------- diff --git a/components/camel-elsql/src/test/java/org/apache/camel/component/elsql/ElSqlProducerBodySimpleTest.java b/components/camel-elsql/src/test/java/org/apache/camel/component/elsql/ElSqlProducerBodySimpleTest.java index 595017e..63f2ed9 100644 --- a/components/camel-elsql/src/test/java/org/apache/camel/component/elsql/ElSqlProducerBodySimpleTest.java +++ b/components/camel-elsql/src/test/java/org/apache/camel/component/elsql/ElSqlProducerBodySimpleTest.java @@ -80,7 +80,7 @@ public class ElSqlProducerBodySimpleTest extends CamelTestSupport { return new RouteBuilder() { public void configure() { from("direct:simple") - .to("elsql:projectsByIdBody:elsql/projects.elsql?dataSource=dataSource") + .to("elsql:projectsByIdBody:elsql/projects.elsql?dataSource=#dataSource") .to("mock:result"); } };
