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 2015/03/01 08:42:35 UTC
[08/11] camel git commit: CAMEL-8320: Component doc to include
endpoint syntax.
CAMEL-8320: Component doc to include endpoint syntax.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/fc6f5ff1
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/fc6f5ff1
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/fc6f5ff1
Branch: refs/heads/master
Commit: fc6f5ff13f10c35c57951deddb31908c6e74c84a
Parents: 5c38e8b
Author: Claus Ibsen <da...@apache.org>
Authored: Sat Feb 28 19:33:07 2015 +0100
Committer: Claus Ibsen <da...@apache.org>
Committed: Sat Feb 28 19:33:07 2015 +0100
----------------------------------------------------------------------
.../camel/component/solr/SolrEndpoint.java | 5 ++--
.../component/sparkrest/SparkConfiguration.java | 6 ++---
.../component/sparkrest/SparkEndpoint.java | 11 +++++----
.../component/splunk/SplunkConfiguration.java | 5 ++--
.../camel/component/splunk/SplunkEndpoint.java | 2 +-
.../spring/batch/SpringBatchEndpoint.java | 5 ++--
.../integration/SpringIntegrationEndpoint.java | 7 +++---
.../springldap/SpringLdapEndpoint.java | 5 ++--
.../component/redis/RedisConfiguration.java | 9 +++----
.../camel/component/redis/RedisEndpoint.java | 2 +-
.../spring/ws/SpringWebserviceEndpoint.java | 2 +-
.../spring/ws/type/EndpointMappingKey.java | 5 ++--
.../apache/camel/component/sql/SqlEndpoint.java | 5 ++--
.../camel/component/stax/StAXEndpoint.java | 5 ++--
.../camel/component/stomp/StompEndpoint.java | 5 ++--
.../stringtemplate/StringTemplateEndpoint.java | 2 +-
.../component/twitter/TwitterConfiguration.java | 3 ++-
.../twitter/TwitterEndpointDirect.java | 2 +-
.../component/twitter/TwitterEndpointEvent.java | 2 +-
.../twitter/TwitterEndpointPolling.java | 2 +-
.../camel/component/vertx/VertxEndpoint.java | 7 +++---
.../component/weather/WeatherConfiguration.java | 3 ++-
.../component/weather/WeatherEndpoint.java | 2 +-
.../component/websocket/WebsocketEndpoint.java | 25 ++++++++++----------
.../camel/component/xmlrpc/XmlRpcEndpoint.java | 5 ++--
.../xmlsecurity/XmlSignatureEndpoint.java | 7 +++---
.../camel/component/xmpp/XmppEndpoint.java | 11 +++++----
.../component/yammer/YammerConfiguration.java | 3 ++-
.../camel/component/yammer/YammerEndpoint.java | 2 +-
.../zookeeper/ZooKeeperConfiguration.java | 5 ++--
.../component/zookeeper/ZooKeeperEndpoint.java | 2 +-
31 files changed, 91 insertions(+), 71 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-solr/src/main/java/org/apache/camel/component/solr/SolrEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-solr/src/main/java/org/apache/camel/component/solr/SolrEndpoint.java b/components/camel-solr/src/main/java/org/apache/camel/component/solr/SolrEndpoint.java
index 4853d7e..6c69ae1 100644
--- a/components/camel-solr/src/main/java/org/apache/camel/component/solr/SolrEndpoint.java
+++ b/components/camel-solr/src/main/java/org/apache/camel/component/solr/SolrEndpoint.java
@@ -24,6 +24,7 @@ import org.apache.camel.Consumer;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
import org.apache.camel.impl.DefaultEndpoint;
+import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriPath;
@@ -34,10 +35,10 @@ import org.apache.solr.client.solrj.impl.HttpSolrServer;
/**
* Represents a Solr endpoint.
*/
-@UriEndpoint(scheme = "solr", producerOnly = true, label = "monitoring,search")
+@UriEndpoint(scheme = "solr", syntax = "solr:url", producerOnly = true, label = "monitoring,search")
public class SolrEndpoint extends DefaultEndpoint {
- @UriPath
+ @UriPath @Metadata(required = "true")
private String url;
private String scheme = "http://";
@UriParam(defaultValue = "" + SolrConstants.DEFUALT_STREAMING_QUEUE_SIZE)
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-spark-rest/src/main/java/org/apache/camel/component/sparkrest/SparkConfiguration.java
----------------------------------------------------------------------
diff --git a/components/camel-spark-rest/src/main/java/org/apache/camel/component/sparkrest/SparkConfiguration.java b/components/camel-spark-rest/src/main/java/org/apache/camel/component/sparkrest/SparkConfiguration.java
index 1367645..cae1e7b 100644
--- a/components/camel-spark-rest/src/main/java/org/apache/camel/component/sparkrest/SparkConfiguration.java
+++ b/components/camel-spark-rest/src/main/java/org/apache/camel/component/sparkrest/SparkConfiguration.java
@@ -24,11 +24,11 @@ public class SparkConfiguration {
@UriParam(defaultValue = "true")
private boolean mapHeaders = true;
- @UriParam(defaultValue = "false")
+ @UriParam
private boolean disableStreamCache;
- @UriParam(defaultValue = "false")
+ @UriParam
private boolean urlDecodeHeaders;
- @UriParam(defaultValue = "false")
+ @UriParam
private boolean transferException;
public boolean isMapHeaders() {
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-spark-rest/src/main/java/org/apache/camel/component/sparkrest/SparkEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-spark-rest/src/main/java/org/apache/camel/component/sparkrest/SparkEndpoint.java b/components/camel-spark-rest/src/main/java/org/apache/camel/component/sparkrest/SparkEndpoint.java
index 8a7ae69..b91c2b3 100644
--- a/components/camel-spark-rest/src/main/java/org/apache/camel/component/sparkrest/SparkEndpoint.java
+++ b/components/camel-spark-rest/src/main/java/org/apache/camel/component/sparkrest/SparkEndpoint.java
@@ -21,21 +21,22 @@ import org.apache.camel.Consumer;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
import org.apache.camel.impl.DefaultEndpoint;
+import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriPath;
import org.apache.camel.util.ObjectHelper;
import spark.route.HttpMethod;
-@UriEndpoint(scheme = "spark-rest", consumerOnly = true, consumerClass = SparkConsumer.class, label = "rest")
+@UriEndpoint(scheme = "spark-rest", syntax = "spark-rest:verb:path", consumerOnly = true, consumerClass = SparkConsumer.class, label = "rest")
public class SparkEndpoint extends DefaultEndpoint {
- @UriParam
- SparkConfiguration sparkConfiguration;
- @UriPath
+ @UriPath @Metadata(required = "true")
private String verb;
- @UriPath
+ @UriPath @Metadata(required = "true")
private String path;
@UriParam
+ SparkConfiguration sparkConfiguration;
+ @UriParam
private SparkBinding sparkBinding;
@UriParam
private String accept;
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-splunk/src/main/java/org/apache/camel/component/splunk/SplunkConfiguration.java
----------------------------------------------------------------------
diff --git a/components/camel-splunk/src/main/java/org/apache/camel/component/splunk/SplunkConfiguration.java b/components/camel-splunk/src/main/java/org/apache/camel/component/splunk/SplunkConfiguration.java
index 49a1ed2..2864310 100644
--- a/components/camel-splunk/src/main/java/org/apache/camel/component/splunk/SplunkConfiguration.java
+++ b/components/camel-splunk/src/main/java/org/apache/camel/component/splunk/SplunkConfiguration.java
@@ -17,6 +17,7 @@
package org.apache.camel.component.splunk;
import com.splunk.Service;
+import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriParams;
import org.apache.camel.spi.UriPath;
@@ -25,7 +26,7 @@ import org.apache.camel.util.ObjectHelper;
@UriParams
public class SplunkConfiguration {
- @UriPath(description = "Name has no purpose")
+ @UriPath(description = "Name has no purpose") @Metadata(required = "true")
private String name;
@UriParam
private String scheme = Service.DEFAULT_SCHEME;
@@ -43,7 +44,7 @@ public class SplunkConfiguration {
private String password;
@UriParam(defaultValue = "5000")
private int connectionTimeout = 5000;
- @UriParam(defaultValue = "false")
+ @UriParam
private boolean useSunHttpsHandler;
@UriParam
private String index;
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-splunk/src/main/java/org/apache/camel/component/splunk/SplunkEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-splunk/src/main/java/org/apache/camel/component/splunk/SplunkEndpoint.java b/components/camel-splunk/src/main/java/org/apache/camel/component/splunk/SplunkEndpoint.java
index 52ec4da..8693802 100644
--- a/components/camel-splunk/src/main/java/org/apache/camel/component/splunk/SplunkEndpoint.java
+++ b/components/camel-splunk/src/main/java/org/apache/camel/component/splunk/SplunkEndpoint.java
@@ -34,7 +34,7 @@ import org.slf4j.LoggerFactory;
/**
* Represents a Splunk endpoint.
*/
-@UriEndpoint(scheme = "splunk", consumerClass = SplunkConsumer.class, label = "monitoring")
+@UriEndpoint(scheme = "splunk", syntax = "splunk:name", consumerClass = SplunkConsumer.class, label = "monitoring")
public class SplunkEndpoint extends ScheduledPollEndpoint {
private static final Logger LOG = LoggerFactory.getLogger(SplunkEndpoint.class);
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/SpringBatchEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/SpringBatchEndpoint.java b/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/SpringBatchEndpoint.java
index 7f20bec..cabebe1 100644
--- a/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/SpringBatchEndpoint.java
+++ b/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/SpringBatchEndpoint.java
@@ -23,6 +23,7 @@ import org.apache.camel.Consumer;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
import org.apache.camel.impl.DefaultEndpoint;
+import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriPath;
@@ -30,10 +31,10 @@ import org.apache.camel.util.CamelContextHelper;
import org.springframework.batch.core.Job;
import org.springframework.batch.core.launch.JobLauncher;
-@UriEndpoint(scheme = "spring-batch", producerOnly = true, label = "spring,batch,scheduling")
+@UriEndpoint(scheme = "spring-batch", syntax = "spring-batch:jobName", producerOnly = true, label = "spring,batch,scheduling")
public class SpringBatchEndpoint extends DefaultEndpoint {
- @UriPath
+ @UriPath @Metadata(required = "true")
private String jobName;
/**
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationEndpoint.java b/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationEndpoint.java
index fc687c0..97b05d0 100644
--- a/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationEndpoint.java
+++ b/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationEndpoint.java
@@ -21,6 +21,7 @@ import org.apache.camel.Consumer;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
import org.apache.camel.impl.DefaultEndpoint;
+import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriPath;
@@ -32,16 +33,16 @@ import org.springframework.integration.MessageChannel;
*
* @version
*/
-@UriEndpoint(scheme = "spring-integration", consumerClass = SpringIntegrationConsumer.class, label = "spring,eventbus")
+@UriEndpoint(scheme = "spring-integration", syntax = "spring-integration:defaultChannel", consumerClass = SpringIntegrationConsumer.class, label = "spring,eventbus")
public class SpringIntegrationEndpoint extends DefaultEndpoint {
- @UriPath
+ @UriPath @Metadata(required = "true")
private String defaultChannel;
@UriParam
private String inputChannel;
@UriParam
private String outputChannel;
private MessageChannel messageChannel;
- @UriParam(defaultValue = "false")
+ @UriParam
private boolean inOut;
public SpringIntegrationEndpoint(String uri, String channel, SpringIntegrationComponent component) {
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-spring-ldap/src/main/java/org/apache/camel/component/springldap/SpringLdapEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-spring-ldap/src/main/java/org/apache/camel/component/springldap/SpringLdapEndpoint.java b/components/camel-spring-ldap/src/main/java/org/apache/camel/component/springldap/SpringLdapEndpoint.java
index 0e9ea44..cbd4ee0 100644
--- a/components/camel-spring-ldap/src/main/java/org/apache/camel/component/springldap/SpringLdapEndpoint.java
+++ b/components/camel-spring-ldap/src/main/java/org/apache/camel/component/springldap/SpringLdapEndpoint.java
@@ -25,12 +25,13 @@ import org.apache.camel.Consumer;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
import org.apache.camel.impl.DefaultEndpoint;
+import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriPath;
import org.springframework.ldap.core.LdapTemplate;
-@UriEndpoint(scheme = "spring-ldap", producerOnly = true, label = "spring,ldap")
+@UriEndpoint(scheme = "spring-ldap", syntax = "spring-ldap:templateName", producerOnly = true, label = "spring,ldap")
public class SpringLdapEndpoint extends DefaultEndpoint {
private static final String OBJECT_SCOPE_NAME = "object";
@@ -41,7 +42,7 @@ public class SpringLdapEndpoint extends DefaultEndpoint {
private static Map<String, Integer> scopeMap;
private LdapTemplate ldapTemplate;
- @UriPath
+ @UriPath @Metadata(required = "true")
private String templateName;
@UriParam
private LdapOperation operation;
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisConfiguration.java
----------------------------------------------------------------------
diff --git a/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisConfiguration.java b/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisConfiguration.java
index 4576a82..0c48845 100755
--- a/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisConfiguration.java
+++ b/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisConfiguration.java
@@ -16,6 +16,7 @@
*/
package org.apache.camel.component.redis;
+import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriParams;
import org.apache.camel.spi.UriPath;
@@ -28,9 +29,9 @@ import org.springframework.data.redis.serializer.RedisSerializer;
@UriParams
public class RedisConfiguration {
- @UriPath
+ @UriPath @Metadata(required = "true")
private String host;
- @UriPath
+ @UriPath @Metadata(required = "true")
private Integer port;
@UriParam
private String command;
@@ -44,9 +45,9 @@ public class RedisConfiguration {
private RedisConnectionFactory connectionFactory;
@UriParam
private RedisSerializer serializer;
- @UriParam(defaultValue = "false")
+ @UriParam
private boolean managedListenerContainer;
- @UriParam(defaultValue = "false")
+ @UriParam
private boolean managedConnectionFactory;
public String getCommand() {
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisEndpoint.java b/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisEndpoint.java
index 67ed9ec..a387186 100755
--- a/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisEndpoint.java
+++ b/components/camel-spring-redis/src/main/java/org/apache/camel/component/redis/RedisEndpoint.java
@@ -26,7 +26,7 @@ import org.apache.camel.spi.UriParam;
/**
* Represents a Redis endpoint.
*/
-@UriEndpoint(scheme = "spring-redis", consumerClass = RedisConsumer.class, label = "spring,nosql")
+@UriEndpoint(scheme = "spring-redis", syntax = "spring-redist:host:port", consumerClass = RedisConsumer.class, label = "spring,nosql")
public class RedisEndpoint extends DirectEndpoint {
@UriParam
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceEndpoint.java b/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceEndpoint.java
index 1084cd3..5ee09e2 100644
--- a/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceEndpoint.java
+++ b/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/SpringWebserviceEndpoint.java
@@ -24,7 +24,7 @@ import org.apache.camel.impl.DefaultEndpoint;
import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
-@UriEndpoint(scheme = "spring-ws", consumerClass = SpringWebserviceConsumer.class, label = "http,soap,webservice")
+@UriEndpoint(scheme = "spring-ws", syntax = "spring-ws:type:lookupKey", consumerClass = SpringWebserviceConsumer.class, label = "http,soap,webservice")
public class SpringWebserviceEndpoint extends DefaultEndpoint {
@UriParam
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/type/EndpointMappingKey.java
----------------------------------------------------------------------
diff --git a/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/type/EndpointMappingKey.java b/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/type/EndpointMappingKey.java
index 7c8391c..158d39e 100644
--- a/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/type/EndpointMappingKey.java
+++ b/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/type/EndpointMappingKey.java
@@ -16,15 +16,16 @@
*/
package org.apache.camel.component.spring.ws.type;
+import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriParams;
import org.apache.camel.spi.UriPath;
import org.springframework.xml.xpath.XPathExpression;
@UriParams
public class EndpointMappingKey {
- @UriPath
+ @UriPath @Metadata(required = "true")
private EndpointMappingType type;
- @UriPath
+ @UriPath @Metadata(required = "true")
private String lookupKey;
/* expression in case type is 'xpath' */
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlEndpoint.java b/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlEndpoint.java
index b95351e..21837eb 100644
--- a/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlEndpoint.java
+++ b/components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlEndpoint.java
@@ -29,6 +29,7 @@ import org.apache.camel.Consumer;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
import org.apache.camel.impl.DefaultPollingEndpoint;
+import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriPath;
@@ -44,11 +45,11 @@ import org.springframework.jdbc.core.RowMapperResultSetExtractor;
* question marks (that are parameter placeholders), sharp signs should be used.
* This is because in camel question mark has other meaning.
*/
-@UriEndpoint(scheme = "sql", consumerClass = SqlConsumer.class, label = "database")
+@UriEndpoint(scheme = "sql", syntax = "sql:query", consumerClass = SqlConsumer.class, label = "database")
public class SqlEndpoint extends DefaultPollingEndpoint {
private JdbcTemplate jdbcTemplate;
- @UriPath
+ @UriPath @Metadata(required = "true")
private String query;
@UriParam
@Deprecated
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-stax/src/main/java/org/apache/camel/component/stax/StAXEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-stax/src/main/java/org/apache/camel/component/stax/StAXEndpoint.java b/components/camel-stax/src/main/java/org/apache/camel/component/stax/StAXEndpoint.java
index 425fd3b..6cd0cb8 100644
--- a/components/camel-stax/src/main/java/org/apache/camel/component/stax/StAXEndpoint.java
+++ b/components/camel-stax/src/main/java/org/apache/camel/component/stax/StAXEndpoint.java
@@ -16,6 +16,7 @@
*/
package org.apache.camel.component.stax;
+import org.apache.camel.spi.Metadata;
import org.xml.sax.ContentHandler;
import org.apache.camel.CamelContext;
@@ -25,10 +26,10 @@ import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriPath;
import org.apache.camel.util.EndpointHelper;
-@UriEndpoint(scheme = "stax", producerOnly = true, label = "transformation")
+@UriEndpoint(scheme = "stax", syntax = "stax:contentHandlerClass", producerOnly = true, label = "transformation")
public class StAXEndpoint extends ProcessorEndpoint {
- @UriPath
+ @UriPath @Metadata(required = "true")
private String contentHandlerClass;
public StAXEndpoint(String endpointUri, CamelContext context) {
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompEndpoint.java b/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompEndpoint.java
index b7a426b..ca8c72c 100644
--- a/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompEndpoint.java
+++ b/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompEndpoint.java
@@ -25,6 +25,7 @@ import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
import org.apache.camel.impl.DefaultEndpoint;
+import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriPath;
@@ -44,10 +45,10 @@ import static org.fusesource.stomp.client.Constants.SEND;
import static org.fusesource.stomp.client.Constants.SUBSCRIBE;
import static org.fusesource.stomp.client.Constants.UNSUBSCRIBE;
-@UriEndpoint(scheme = "stomp", consumerClass = StompConsumer.class, label = "messaging")
+@UriEndpoint(scheme = "stomp", syntax = "stomp:destination", consumerClass = StompConsumer.class, label = "messaging")
public class StompEndpoint extends DefaultEndpoint {
- @UriPath
+ @UriPath @Metadata(required = "true")
private String destination;
@UriParam
private StompConfiguration configuration;
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-stringtemplate/src/main/java/org/apache/camel/component/stringtemplate/StringTemplateEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-stringtemplate/src/main/java/org/apache/camel/component/stringtemplate/StringTemplateEndpoint.java b/components/camel-stringtemplate/src/main/java/org/apache/camel/component/stringtemplate/StringTemplateEndpoint.java
index c29e7a1..1f31a6b 100644
--- a/components/camel-stringtemplate/src/main/java/org/apache/camel/component/stringtemplate/StringTemplateEndpoint.java
+++ b/components/camel-stringtemplate/src/main/java/org/apache/camel/component/stringtemplate/StringTemplateEndpoint.java
@@ -34,7 +34,7 @@ import org.stringtemplate.v4.STGroup;
/**
* @version
*/
-@UriEndpoint(scheme = "stringtemplate", producerOnly = true, label = "transformation")
+@UriEndpoint(scheme = "stringtemplate", syntax = "stringtemplate:resourceUri", producerOnly = true, label = "transformation")
public class StringTemplateEndpoint extends ResourceEndpoint {
@UriParam
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterConfiguration.java
----------------------------------------------------------------------
diff --git a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterConfiguration.java b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterConfiguration.java
index 8de58c8..1a7a621 100644
--- a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterConfiguration.java
+++ b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterConfiguration.java
@@ -21,6 +21,7 @@ import java.text.SimpleDateFormat;
import java.util.Date;
import org.apache.camel.component.twitter.data.EndpointType;
+import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriParams;
import org.apache.camel.spi.UriPath;
@@ -37,7 +38,7 @@ public class TwitterConfiguration {
/**
* Defines the Twitter API endpoint.
*/
- @UriPath(description = "What kind of type to use")
+ @UriPath(description = "What kind of type to use") @Metadata(required = "true")
private EndpointType type = EndpointType.DIRECT;
/**
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointDirect.java
----------------------------------------------------------------------
diff --git a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointDirect.java b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointDirect.java
index 59791af..b3e4353 100644
--- a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointDirect.java
+++ b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointDirect.java
@@ -32,7 +32,7 @@ import org.apache.camel.spi.UriParam;
/**
* Twitter direct endpoint
*/
-@UriEndpoint(scheme = "twitter", consumerClass = Twitter4JConsumer.class, label = "api,social")
+@UriEndpoint(scheme = "twitter", syntax = "twitter:type", consumerClass = Twitter4JConsumer.class, label = "api,social")
public class TwitterEndpointDirect extends DirectEndpoint implements TwitterEndpoint {
@UriParam
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointEvent.java
----------------------------------------------------------------------
diff --git a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointEvent.java b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointEvent.java
index fefbf44..38d171a 100644
--- a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointEvent.java
+++ b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointEvent.java
@@ -26,7 +26,7 @@ import org.apache.camel.component.twitter.data.EndpointType;
import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
-@UriEndpoint(scheme = "twitter", consumerClass = Twitter4JConsumer.class, label = "api,social")
+@UriEndpoint(scheme = "twitter", syntax = "twitter:type", consumerClass = Twitter4JConsumer.class, label = "api,social")
public class TwitterEndpointEvent extends DirectEndpoint implements TwitterEndpoint {
@UriParam
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointPolling.java
----------------------------------------------------------------------
diff --git a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointPolling.java b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointPolling.java
index 9c70773..4e201b8 100644
--- a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointPolling.java
+++ b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/TwitterEndpointPolling.java
@@ -33,7 +33,7 @@ import org.apache.camel.spi.UriParam;
* Twitter polling endpoint
*/
@ManagedResource(description = "Managed Twitter Endpoint")
-@UriEndpoint(scheme = "twitter", consumerClass = Twitter4JConsumer.class, label = "api,social")
+@UriEndpoint(scheme = "twitter", syntax = "twitter:type", consumerClass = Twitter4JConsumer.class, label = "api,social")
public class TwitterEndpointPolling extends DefaultPollingEndpoint implements TwitterEndpoint {
@UriParam
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-vertx/src/main/java/org/apache/camel/component/vertx/VertxEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-vertx/src/main/java/org/apache/camel/component/vertx/VertxEndpoint.java b/components/camel-vertx/src/main/java/org/apache/camel/component/vertx/VertxEndpoint.java
index b46711e..3d4a882 100644
--- a/components/camel-vertx/src/main/java/org/apache/camel/component/vertx/VertxEndpoint.java
+++ b/components/camel-vertx/src/main/java/org/apache/camel/component/vertx/VertxEndpoint.java
@@ -20,6 +20,7 @@ import org.apache.camel.Consumer;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
import org.apache.camel.impl.DefaultEndpoint;
+import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriPath;
@@ -29,12 +30,12 @@ import org.vertx.java.core.eventbus.EventBus;
/**
* A Camel Endpoint for working with <a href="http://vertx.io/">vert.x</a> event bus endpoints
*/
-@UriEndpoint(scheme = "vertx", consumerClass = VertxConsumer.class, label = "eventbus")
+@UriEndpoint(scheme = "vertx", syntax = "vertx:address", consumerClass = VertxConsumer.class, label = "eventbus")
public class VertxEndpoint extends DefaultEndpoint {
- @UriPath
+ @UriPath @Metadata(required = "true")
private String address;
- @UriParam(defaultValue = "false")
+ @UriParam
private Boolean pubSub;
public VertxEndpoint(String uri, VertxComponent component, String address) {
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-weather/src/main/java/org/apache/camel/component/weather/WeatherConfiguration.java
----------------------------------------------------------------------
diff --git a/components/camel-weather/src/main/java/org/apache/camel/component/weather/WeatherConfiguration.java b/components/camel-weather/src/main/java/org/apache/camel/component/weather/WeatherConfiguration.java
index a47b7d3..2c9d3ef 100644
--- a/components/camel-weather/src/main/java/org/apache/camel/component/weather/WeatherConfiguration.java
+++ b/components/camel-weather/src/main/java/org/apache/camel/component/weather/WeatherConfiguration.java
@@ -19,6 +19,7 @@ package org.apache.camel.component.weather;
import java.net.URL;
import java.util.Scanner;
+import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriParams;
import org.apache.camel.spi.UriPath;
@@ -35,7 +36,7 @@ public class WeatherConfiguration {
private final WeatherComponent component;
- @UriPath(description = "The name value is not used.")
+ @UriPath(description = "The name value is not used.") @Metadata(required = "true")
private String name;
@UriParam
private String location = "";
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-weather/src/main/java/org/apache/camel/component/weather/WeatherEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-weather/src/main/java/org/apache/camel/component/weather/WeatherEndpoint.java b/components/camel-weather/src/main/java/org/apache/camel/component/weather/WeatherEndpoint.java
index d7a7e10..4055cdf 100644
--- a/components/camel-weather/src/main/java/org/apache/camel/component/weather/WeatherEndpoint.java
+++ b/components/camel-weather/src/main/java/org/apache/camel/component/weather/WeatherEndpoint.java
@@ -26,7 +26,7 @@ import org.apache.camel.spi.UriParam;
/**
* Weather Endpoint
*/
-@UriEndpoint(scheme = "weather", consumerClass = WeatherConsumer.class, label = "api")
+@UriEndpoint(scheme = "weather", syntax = "weather:name", consumerClass = WeatherConsumer.class, label = "api")
public class WeatherEndpoint extends DefaultPollingEndpoint {
@UriParam
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketEndpoint.java b/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketEndpoint.java
index e9c0815..4ffc293 100644
--- a/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketEndpoint.java
+++ b/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketEndpoint.java
@@ -25,6 +25,7 @@ import org.apache.camel.Consumer;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
import org.apache.camel.impl.DefaultEndpoint;
+import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriPath;
@@ -33,7 +34,7 @@ import org.apache.camel.util.ServiceHelper;
import org.apache.camel.util.jsse.SSLContextParameters;
import org.eclipse.jetty.server.Handler;
-@UriEndpoint(scheme = "websocket", consumerClass = WebsocketConsumer.class, label = "http,websocket")
+@UriEndpoint(scheme = "websocket", syntax = "websocket:host:port/resourceUri", consumerClass = WebsocketConsumer.class, label = "http,websocket")
public class WebsocketEndpoint extends DefaultEndpoint {
private NodeSynchronization sync;
@@ -42,21 +43,21 @@ public class WebsocketEndpoint extends DefaultEndpoint {
private URI uri;
private List<Handler> handlers;
- @UriParam(defaultValue = "false")
+ @UriPath @Metadata(required = "true")
+ private String host;
+ @UriPath @Metadata(required = "true")
+ private Integer port;
+ @UriPath @Metadata(required = "true")
+ private String resourceUri;
+
+ @UriParam
private Boolean sendToAll;
- @UriParam(defaultValue = "false")
+ @UriParam
private boolean enableJmx;
- @UriParam(defaultValue = "false")
+ @UriParam
private boolean sessionSupport;
- @UriParam(defaultValue = "false")
+ @UriParam
private boolean crossOriginFilterOn;
-
- @UriPath
- private String host;
- @UriPath
- private Integer port;
- @UriPath
- private String resourceUri;
@UriParam
private SSLContextParameters sslContextParameters;
@UriParam
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-xmlrpc/src/main/java/org/apache/camel/component/xmlrpc/XmlRpcEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-xmlrpc/src/main/java/org/apache/camel/component/xmlrpc/XmlRpcEndpoint.java b/components/camel-xmlrpc/src/main/java/org/apache/camel/component/xmlrpc/XmlRpcEndpoint.java
index ce916eb..f86e336 100644
--- a/components/camel-xmlrpc/src/main/java/org/apache/camel/component/xmlrpc/XmlRpcEndpoint.java
+++ b/components/camel-xmlrpc/src/main/java/org/apache/camel/component/xmlrpc/XmlRpcEndpoint.java
@@ -26,6 +26,7 @@ import org.apache.camel.Processor;
import org.apache.camel.Producer;
import org.apache.camel.impl.DefaultEndpoint;
import org.apache.camel.impl.SynchronousDelegateProducer;
+import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriPath;
@@ -36,9 +37,9 @@ import org.apache.xmlrpc.client.XmlRpcClientConfigImpl;
/**
* Represents a xmlrpc endpoint.
*/
-@UriEndpoint(scheme = "xmlrpc", producerOnly = true, label = "transformation")
+@UriEndpoint(scheme = "xmlrpc", syntax = "xmlrpc:address", producerOnly = true, label = "transformation")
public class XmlRpcEndpoint extends DefaultEndpoint {
- @UriPath
+ @UriPath @Metadata(required = "true")
private String address;
@UriParam
private XmlRpcConfiguration configuration;
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/XmlSignatureEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/XmlSignatureEndpoint.java b/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/XmlSignatureEndpoint.java
index 4727183..9a11575 100644
--- a/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/XmlSignatureEndpoint.java
+++ b/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/XmlSignatureEndpoint.java
@@ -26,16 +26,17 @@ import org.apache.camel.component.xmlsecurity.processor.XmlSignatureConfiguratio
import org.apache.camel.component.xmlsecurity.processor.XmlSignerConfiguration;
import org.apache.camel.component.xmlsecurity.processor.XmlVerifierConfiguration;
import org.apache.camel.impl.DefaultEndpoint;
+import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriPath;
-@UriEndpoint(scheme = "xmlsecurity", producerOnly = true, label = "security,transformation")
+@UriEndpoint(scheme = "xmlsecurity", syntax = "xmlsecurity:command/name", producerOnly = true, label = "security,transformation")
public abstract class XmlSignatureEndpoint extends DefaultEndpoint {
- @UriPath
+ @UriPath @Metadata(required = "true")
private XmlCommand command;
- @UriPath
+ @UriPath @Metadata(required = "true")
private String name;
// to include both kind of configuration params
@UriParam
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java
index ad26724..cbbff28 100644
--- a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java
+++ b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppEndpoint.java
@@ -29,6 +29,7 @@ import org.apache.camel.impl.DefaultExchange;
import org.apache.camel.impl.DefaultHeaderFilterStrategy;
import org.apache.camel.spi.HeaderFilterStrategy;
import org.apache.camel.spi.HeaderFilterStrategyAware;
+import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriPath;
@@ -50,7 +51,7 @@ import org.slf4j.LoggerFactory;
/**
* A XMPP Endpoint
*/
-@UriEndpoint(scheme = "xmpp", consumerClass = XmppConsumer.class, label = "chat,messaging")
+@UriEndpoint(scheme = "xmpp", syntax = "xmpp:host:port/participant", consumerClass = XmppConsumer.class, label = "chat,messaging")
public class XmppEndpoint extends DefaultEndpoint implements HeaderFilterStrategyAware {
private static final Logger LOG = LoggerFactory.getLogger(XmppEndpoint.class);
@@ -59,9 +60,9 @@ public class XmppEndpoint extends DefaultEndpoint implements HeaderFilterStrateg
private XmppBinding binding;
private HeaderFilterStrategy headerFilterStrategy = new DefaultHeaderFilterStrategy();
- @UriPath
+ @UriPath @Metadata(required = "true")
private String host;
- @UriPath
+ @UriPath @Metadata(required = "true")
private int port;
@UriPath
private String participant;
@@ -81,11 +82,11 @@ public class XmppEndpoint extends DefaultEndpoint implements HeaderFilterStrateg
private String nickname;
@UriParam
private String serviceName;
- @UriParam(defaultValue = "false")
+ @UriParam
private boolean pubsub;
//Set a doc header on the IN message containing a Document form of the incoming packet;
//default is true if pubsub is true, otherwise false
- @UriParam(defaultValue = "false")
+ @UriParam
private boolean doc;
@UriParam(defaultValue = "true")
private boolean testConnectionOnStartup = true;
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-yammer/src/main/java/org/apache/camel/component/yammer/YammerConfiguration.java
----------------------------------------------------------------------
diff --git a/components/camel-yammer/src/main/java/org/apache/camel/component/yammer/YammerConfiguration.java b/components/camel-yammer/src/main/java/org/apache/camel/component/yammer/YammerConfiguration.java
index d679d72..deee282 100644
--- a/components/camel-yammer/src/main/java/org/apache/camel/component/yammer/YammerConfiguration.java
+++ b/components/camel-yammer/src/main/java/org/apache/camel/component/yammer/YammerConfiguration.java
@@ -16,6 +16,7 @@
*/
package org.apache.camel.component.yammer;
+import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriParams;
import org.apache.camel.spi.UriPath;
@@ -23,7 +24,7 @@ import org.apache.camel.spi.UriPath;
@UriParams
public class YammerConfiguration {
- @UriPath(name = "function")
+ @UriPath(name = "function") @Metadata(required = "true")
private YammerFunctionType functionType;
private String function;
@UriParam
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-yammer/src/main/java/org/apache/camel/component/yammer/YammerEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-yammer/src/main/java/org/apache/camel/component/yammer/YammerEndpoint.java b/components/camel-yammer/src/main/java/org/apache/camel/component/yammer/YammerEndpoint.java
index 95be167..4461842 100644
--- a/components/camel-yammer/src/main/java/org/apache/camel/component/yammer/YammerEndpoint.java
+++ b/components/camel-yammer/src/main/java/org/apache/camel/component/yammer/YammerEndpoint.java
@@ -26,7 +26,7 @@ import org.apache.camel.spi.UriParam;
/**
* Represents a Yammer endpoint.
*/
-@UriEndpoint(scheme = "yammer", consumerClass = YammerMessagePollingConsumer.class, label = "social")
+@UriEndpoint(scheme = "yammer", syntax = "yammer:function", consumerClass = YammerMessagePollingConsumer.class, label = "social")
public class YammerEndpoint extends ScheduledPollEndpoint {
@UriParam
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperConfiguration.java
----------------------------------------------------------------------
diff --git a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperConfiguration.java b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperConfiguration.java
index 65b1cab..315166f 100644
--- a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperConfiguration.java
+++ b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperConfiguration.java
@@ -20,6 +20,7 @@ import java.util.ArrayList;
import java.util.List;
import org.apache.camel.RuntimeCamelException;
+import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriParams;
import org.apache.camel.spi.UriPath;
@@ -37,10 +38,10 @@ public class ZooKeeperConfiguration implements Cloneable {
private transient boolean changed;
- @UriPath
+ @UriPath @Metadata(required = "true")
private String serverUrls;
private List<String> servers;
- @UriPath
+ @UriPath @Metadata(required = "true")
private String path;
@UriParam(defaultValue = "5000")
private int timeout = 5000;
http://git-wip-us.apache.org/repos/asf/camel/blob/fc6f5ff1/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperEndpoint.java b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperEndpoint.java
index 5086736..d9fc34d 100644
--- a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperEndpoint.java
+++ b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperEndpoint.java
@@ -33,7 +33,7 @@ import org.apache.camel.spi.UriParam;
* <code>ZooKeeperEndpoint</code>
*/
@ManagedResource(description = "ZooKeeper Endpoint")
-@UriEndpoint(scheme = "zookeeper", consumerClass = ZooKeeperConsumer.class, label = "clustering")
+@UriEndpoint(scheme = "zookeeper", syntax = "zookeeper:serverUrls/path", consumerClass = ZooKeeperConsumer.class, label = "clustering")
public class ZooKeeperEndpoint extends DefaultEndpoint {
@UriParam
private ZooKeeperConfiguration configuration;