You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by pp...@apache.org on 2020/04/24 18:43:02 UTC
[camel] 01/02: CAMEL-14934: (Batch 4) Improve Component descriptions
This is an automated email from the ASF dual-hosted git repository.
ppalaga pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 21ef63eb8edfd896c5af66d38e0d700d1d2d7db7
Author: Peter Palaga <pp...@redhat.com>
AuthorDate: Fri Apr 24 18:49:32 2020 +0200
CAMEL-14934: (Batch 4) Improve Component descriptions
---
.../camel/component/hbase/HBaseEndpoint.java | 2 +-
.../apache/camel/component/hdfs/HdfsEndpoint.java | 2 +-
.../camel/component/hipchat/HipchatEndpoint.java | 2 +-
.../apache/camel/component/http/HttpEndpoint.java | 2 +-
.../component/iec60870/client/ClientEndpoint.java | 3 +-
.../component/iec60870/server/ServerEndpoint.java | 3 +-
.../ignite/cache/IgniteCacheEndpoint.java | 55 ++++++++++------------
.../ignite/compute/IgniteComputeEndpoint.java | 9 ++--
.../ignite/events/IgniteEventsEndpoint.java | 6 +--
.../ignite/idgen/IgniteIdGenEndpoint.java | 5 +-
.../ignite/messaging/IgniteMessagingEndpoint.java | 4 +-
.../ignite/queue/IgniteQueueEndpoint.java | 4 +-
.../component/ignite/set/IgniteSetEndpoint.java | 4 +-
.../component/infinispan/InfinispanEndpoint.java | 2 +-
.../camel/component/influxdb/InfluxDbEndpoint.java | 6 +--
.../apache/camel/component/iota/IOTAEndpoint.java | 2 +-
.../apache/camel/component/ipfs/IPFSEndpoint.java | 2 +-
.../apache/camel/component/irc/IrcEndpoint.java | 10 ++--
.../camel/component/ironmq/IronMQEndpoint.java | 4 +-
.../apache/camel/component/jbpm/JBPMEndpoint.java | 3 +-
.../camel/component/jcache/JCacheEndpoint.java | 2 +-
.../camel/component/jclouds/JcloudsEndpoint.java | 2 +-
.../apache/camel/component/jcr/JcrEndpoint.java | 14 +++---
.../apache/camel/component/jdbc/JdbcEndpoint.java | 2 +-
.../camel/component/jetty9/JettyHttpEndpoint9.java | 2 +-
.../jgroups/raft/JGroupsRaftEndpoint.java | 2 +-
.../camel/component/jgroups/JGroupsEndpoint.java | 2 +-
.../component/validator/jing/JingEndpoint.java | 2 +-
.../apache/camel/component/jira/JiraEndpoint.java | 2 +-
.../apache/camel/component/jms/JmsEndpoint.java | 6 +--
.../apache/camel/component/jmx/JMXEndpoint.java | 30 ++++++------
.../apache/camel/component/jolt/JoltEndpoint.java | 2 +-
.../apache/camel/component/jooq/JooqEndpoint.java | 3 ++
.../apache/camel/component/jpa/JpaEndpoint.java | 4 +-
.../apache/camel/component/scp/ScpEndpoint.java | 4 +-
.../apache/camel/component/jslt/JsltEndpoint.java | 2 +-
.../jsonvalidator/JsonValidatorEndpoint.java | 18 +++----
.../camel/component/jt400/Jt400Endpoint.java | 12 ++---
.../camel/component/kafka/KafkaEndpoint.java | 3 +-
.../config_maps/KubernetesConfigMapsEndpoint.java | 3 +-
.../deployments/KubernetesDeploymentsEndpoint.java | 3 +-
.../kubernetes/hpa/KubernetesHPAEndpoint.java | 3 +-
.../kubernetes/job/KubernetesJobEndpoint.java | 3 +-
.../namespaces/KubernetesNamespacesEndpoint.java | 3 +-
.../kubernetes/nodes/KubernetesNodesEndpoint.java | 3 +-
.../KubernetesPersistentVolumesEndpoint.java | 3 +-
.../KubernetesPersistentVolumesClaimsEndpoint.java | 3 +-
.../kubernetes/pods/KubernetesPodsEndpoint.java | 3 +-
.../KubernetesReplicationControllersEndpoint.java | 4 +-
.../KubernetesResourcesQuotaEndpoint.java | 3 +-
.../secrets/KubernetesSecretsEndpoint.java | 3 +-
.../KubernetesServiceAccountsEndpoint.java | 3 +-
.../services/KubernetesServicesEndpoint.java | 3 +-
.../OpenshiftBuildConfigsEndpoint.java | 3 +-
.../openshift/builds/OpenshiftBuildsEndpoint.java | 3 +-
.../apache/camel/component/kudu/KuduEndpoint.java | 3 +-
.../camel/component/language/LanguageEndpoint.java | 2 +-
.../apache/camel/component/ldap/LdapEndpoint.java | 2 +-
.../apache/camel/component/ldif/LdifEndpoint.java | 2 +-
.../apache/camel/component/log/LogEndpoint.java | 2 +-
.../camel/component/lucene/LuceneEndpoint.java | 4 +-
.../component/lumberjack/LumberjackEndpoint.java | 2 +-
.../apache/camel/component/mail/MailEndpoint.java | 2 +-
.../camel/component/master/MasterEndpoint.java | 3 +-
.../camel/component/metrics/MetricsEndpoint.java | 2 +-
.../component/micrometer/MicrometerEndpoint.java | 2 +-
.../metrics/MicroProfileMetricsEndpoint.java | 3 ++
.../component/milo/client/MiloClientEndpoint.java | 3 +-
.../component/milo/server/MiloServerEndpoint.java | 2 +-
.../apache/camel/component/mina/MinaEndpoint.java | 2 +-
.../apache/camel/component/mllp/MllpEndpoint.java | 2 +-
.../apache/camel/component/mock/MockEndpoint.java | 34 ++++++-------
.../component/mongodb/gridfs/GridFsEndpoint.java | 2 +-
.../camel/component/mongodb/MongoDbEndpoint.java | 2 +-
.../camel/component/validator/msv/MsvEndpoint.java | 2 +-
.../camel/component/mustache/MustacheEndpoint.java | 2 +-
.../apache/camel/component/mvel/MvelEndpoint.java | 2 +-
.../component/mybatis/MyBatisBeanEndpoint.java | 2 +-
.../camel/component/nagios/NagiosEndpoint.java | 2 +-
.../apache/camel/component/nats/NatsEndpoint.java | 10 ++--
.../component/netty/http/NettyHttpEndpoint.java | 2 +-
.../camel/component/netty/NettyEndpoint.java | 2 +-
.../camel/component/nitrite/NitriteEndpoint.java | 2 +-
.../apache/camel/component/nsq/NsqEndpoint.java | 2 +-
.../camel/component/olingo2/Olingo2Endpoint.java | 2 +-
.../camel/component/olingo4/Olingo4Endpoint.java | 2 +-
.../component/openstack/cinder/CinderEndpoint.java | 2 +-
.../component/openstack/glance/GlanceEndpoint.java | 2 +-
.../openstack/keystone/KeystoneEndpoint.java | 2 +-
.../openstack/neutron/NeutronEndpoint.java | 2 +-
.../component/openstack/nova/NovaEndpoint.java | 2 +-
.../component/openstack/swift/SwiftEndpoint.java | 2 +-
.../component/optaplanner/OptaPlannerEndpoint.java | 2 +-
.../apache/camel/component/paho/PahoEndpoint.java | 2 +-
.../apache/camel/component/pdf/PdfEndpoint.java | 2 +-
.../slot/PgReplicationSlotEndpoint.java | 2 +-
.../camel/component/pgevent/PgEventEndpoint.java | 2 +-
.../platform/http/PlatformHttpEndpoint.java | 3 ++
.../camel/component/printer/PrinterEndpoint.java | 6 +--
.../camel/component/pubnub/PubNubEndpoint.java | 2 +-
.../camel/component/pulsar/PulsarEndpoint.java | 3 ++
.../camel/component/quartz/QuartzEndpoint.java | 2 +-
.../component/quickfixj/QuickfixjEndpoint.java | 6 +--
.../camel/component/rabbitmq/RabbitMQEndpoint.java | 3 +-
.../reactive/streams/ReactiveStreamsEndpoint.java | 2 +-
.../apache/camel/component/ref/RefEndpoint.java | 2 +-
.../rest/openapi/RestOpenApiEndpoint.java | 3 +-
.../rest/swagger/RestSwaggerEndpoint.java | 3 +-
.../camel/component/rest/RestApiEndpoint.java | 2 +-
.../apache/camel/component/rest/RestEndpoint.java | 2 +-
.../robotframework/RobotFrameworkEndpoint.java | 6 +--
.../apache/camel/component/rss/RssEndpoint.java | 2 +-
.../apache/camel/component/saga/SagaEndpoint.java | 2 +-
.../component/salesforce/SalesforceEndpoint.java | 3 +-
.../component/sap/netweaver/NetWeaverEndpoint.java | 2 +-
.../camel/component/xquery/XQueryEndpoint.java | 2 +-
.../component/scheduler/SchedulerEndpoint.java | 2 +-
.../component/schematron/SchematronEndpoint.java | 2 +-
.../camel/component/service/ServiceEndpoint.java | 4 +-
.../component/servicenow/ServiceNowEndpoint.java | 2 +-
.../camel/component/servlet/ServletEndpoint.java | 2 +-
.../apache/camel/component/sip/SipEndpoint.java | 4 +-
.../apache/camel/component/sjms/SjmsEndpoint.java | 6 +--
.../component/sjms/batch/SjmsBatchEndpoint.java | 2 +-
.../camel/component/sjms2/Sjms2Endpoint.java | 2 +-
.../camel/component/slack/SlackEndpoint.java | 4 +-
.../apache/camel/component/smpp/SmppEndpoint.java | 16 +++----
.../apache/camel/component/snmp/SnmpEndpoint.java | 2 +-
.../apache/camel/component/solr/SolrEndpoint.java | 4 +-
.../soroushbot/component/SoroushBotEndpoint.java | 2 +-
.../camel/component/spark/SparkEndpoint.java | 2 +-
.../camel/component/splunk/SplunkEndpoint.java | 2 +-
.../spring/batch/SpringBatchEndpoint.java | 10 ++--
.../integration/SpringIntegrationEndpoint.java | 2 +-
.../component/springldap/SpringLdapEndpoint.java | 2 +-
.../camel/component/redis/RedisEndpoint.java | 2 +-
.../spring/ws/SpringWebserviceEndpoint.java | 2 +-
.../camel/component/event/EventEndpoint.java | 2 +-
.../apache/camel/component/sql/SqlEndpoint.java | 2 +-
.../component/sql/stored/SqlStoredEndpoint.java | 2 +-
.../apache/camel/component/ssh/SshEndpoint.java | 3 +-
.../apache/camel/component/stax/StAXEndpoint.java | 2 +-
.../camel/component/stomp/StompEndpoint.java | 8 ++--
.../camel/component/stream/StreamEndpoint.java | 8 ++--
.../stringtemplate/StringTemplateEndpoint.java | 4 +-
.../apache/camel/component/stub/StubEndpoint.java | 2 +-
.../camel/component/telegram/TelegramEndpoint.java | 2 +-
.../camel/component/thrift/ThriftEndpoint.java | 7 ++-
.../apache/camel/component/tika/TikaEndpoint.java | 3 ++
.../camel/component/timer/TimerEndpoint.java | 4 +-
.../camel/component/twilio/TwilioEndpoint.java | 2 +-
.../TwitterDirectMessageEndpoint.java | 2 +-
.../twitter/search/TwitterSearchEndpoint.java | 2 +-
.../twitter/timeline/TwitterTimelineEndpoint.java | 2 +-
.../camel/component/undertow/UndertowEndpoint.java | 12 ++---
.../component/validator/ValidatorEndpoint.java | 12 ++---
.../camel/component/velocity/VelocityEndpoint.java | 6 +--
.../camel/component/vertx/VertxEndpoint.java | 2 +-
.../org/apache/camel/component/vm/VmEndpoint.java | 2 +-
.../camel/component/weather/WeatherEndpoint.java | 2 +-
.../camel/component/web3j/Web3jEndpoint.java | 2 +-
.../camel/component/webhook/WebhookEndpoint.java | 3 +-
.../camel/websocket/jsr356/JSR356Endpoint.java | 3 ++
.../component/websocket/WebsocketEndpoint.java | 4 +-
.../apache/camel/component/weka/WekaEndpoint.java | 2 +-
.../component/wordpress/WordpressEndpoint.java | 2 +-
.../camel/component/workday/WorkdayEndpoint.java | 2 +-
.../camel/component/xchange/XChangeEndpoint.java | 14 +++---
.../org/apache/camel/component/xj/XJEndpoint.java | 2 +-
.../component/xmlsecurity/XmlSignerEndpoint.java | 2 +-
.../component/xmlsecurity/XmlVerifierEndpoint.java | 2 +-
.../apache/camel/component/xmpp/XmppEndpoint.java | 2 +-
.../component/xslt/saxon/XsltSaxonEndpoint.java | 12 ++---
.../apache/camel/component/xslt/XsltEndpoint.java | 2 +-
.../camel/component/yammer/YammerEndpoint.java | 2 +-
.../camel/component/zendesk/ZendeskEndpoint.java | 2 +-
.../component/zookeepermaster/MasterEndpoint.java | 2 +-
.../component/zookeeper/ZooKeeperEndpoint.java | 2 +-
178 files changed, 349 insertions(+), 361 deletions(-)
diff --git a/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java b/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java
index 365282d..c312ac1 100644
--- a/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java
+++ b/components/camel-hbase/src/main/java/org/apache/camel/component/hbase/HBaseEndpoint.java
@@ -38,7 +38,7 @@ import org.apache.hadoop.hbase.filter.Filter;
import org.apache.hadoop.security.UserGroupInformation;
/**
- * For reading/writing from/to an HBase store (Hadoop database).
+ * Reading and write from/to an HBase store (Hadoop database).
*/
@UriEndpoint(firstVersion = "2.10.0", scheme = "hbase", title = "HBase", syntax = "hbase:tableName", label = "hadoop")
public class HBaseEndpoint extends DefaultEndpoint {
diff --git a/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsEndpoint.java b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsEndpoint.java
index 69764e9..048fba8 100644
--- a/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsEndpoint.java
+++ b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsEndpoint.java
@@ -27,7 +27,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.support.ScheduledPollEndpoint;
/**
- * For reading/writing from/to an HDFS filesystem using Hadoop 2.x.
+ * Read and write from/to an HDFS filesystem using Hadoop 2.x.
*/
@UriEndpoint(firstVersion = "2.14.0", scheme = "hdfs", title = "HDFS", syntax = "hdfs:hostName:port/path", label = "hadoop,file")
public class HdfsEndpoint extends ScheduledPollEndpoint {
diff --git a/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatEndpoint.java b/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatEndpoint.java
index 44d0c1b..ded7503 100644
--- a/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatEndpoint.java
+++ b/components/camel-hipchat/src/main/java/org/apache/camel/component/hipchat/HipchatEndpoint.java
@@ -24,7 +24,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.support.ScheduledPollEndpoint;
/**
- * The hipchat component supports producing and consuming messages from/to Hipchat service.
+ * Send and receive messages to/from Hipchat service.
*/
@UriEndpoint(firstVersion = "2.15.0", scheme = "hipchat", title = "Hipchat", syntax = "hipchat:protocol:host:port", label = "api,cloud")
public class HipchatEndpoint extends ScheduledPollEndpoint {
diff --git a/components/camel-http/src/main/java/org/apache/camel/component/http/HttpEndpoint.java b/components/camel-http/src/main/java/org/apache/camel/component/http/HttpEndpoint.java
index 5e43f44..42e3423 100644
--- a/components/camel-http/src/main/java/org/apache/camel/component/http/HttpEndpoint.java
+++ b/components/camel-http/src/main/java/org/apache/camel/component/http/HttpEndpoint.java
@@ -53,7 +53,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * For calling out to external HTTP servers using Apache HTTP Client 4.x.
+ * Send requests to external HTTP servers using Apache HTTP Client 4.x.
*/
@UriEndpoint(firstVersion = "2.3.0", scheme = "http,https", title = "HTTP,HTTPS", syntax = "http:httpUri",
producerOnly = true, label = "http", lenientProperties = true)
diff --git a/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/client/ClientEndpoint.java b/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/client/ClientEndpoint.java
index c9e3cc9..f1b82d0 100644
--- a/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/client/ClientEndpoint.java
+++ b/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/client/ClientEndpoint.java
@@ -27,8 +27,7 @@ import org.apache.camel.support.DefaultComponent;
import static java.util.Objects.requireNonNull;
/**
- * IEC 60870 component used for telecontrol (supervisory control and data acquisition)
- * such as controlling electric power transmission grids and other geographically widespread control systems.
+ * IEC 60870 supervisory control and data acquisition (SCADA) client using NeoSCADA™ implementation.
*/
@UriEndpoint(firstVersion = "2.20.0", scheme = "iec60870-client", syntax = "iec60870-client:uriPath",
title = "IEC 60870 Client", label = "iot")
diff --git a/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/server/ServerEndpoint.java b/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/server/ServerEndpoint.java
index d43e825..04025c8 100644
--- a/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/server/ServerEndpoint.java
+++ b/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/server/ServerEndpoint.java
@@ -28,8 +28,7 @@ import org.apache.camel.support.DefaultComponent;
import static java.util.Objects.requireNonNull;
/**
- * IEC 60870 component used for telecontrol (supervisory control and data acquisition)
- * such as controlling electric power transmission grids and other geographically widespread control systems.
+ * IEC 60870 supervisory control and data acquisition (SCADA) server using NeoSCADA™ implementation.
*/
@UriEndpoint(firstVersion = "2.20.0", scheme = "iec60870-server", syntax = "iec60870-server:uriPath",
title = "IEC 60870 Server", label = "iot")
diff --git a/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/cache/IgniteCacheEndpoint.java b/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/cache/IgniteCacheEndpoint.java
index d654f57..17c4785 100644
--- a/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/cache/IgniteCacheEndpoint.java
+++ b/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/cache/IgniteCacheEndpoint.java
@@ -36,10 +36,7 @@ import org.apache.ignite.cache.query.ContinuousQuery;
import org.apache.ignite.cache.query.Query;
/**
- * The Ignite Cache endpoint is one of camel-ignite endpoints which allows you to interact with
- * an <a href="https://apacheignite.readme.io/docs/data-grid">Ignite Cache</a>.
- * This offers both a Producer (to invoke cache operations on an Ignite cache) and
- * a Consumer (to consume changes from a continuous query).
+ * Perform cache operations on an Ignite cache or consume changes from a continuous query.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "ignite-cache", title = "Ignite Cache", syntax = "ignite-cache:cacheName", label = "nosql,cache,compute")
public class IgniteCacheEndpoint extends AbstractIgniteEndpoint {
@@ -108,7 +105,7 @@ public class IgniteCacheEndpoint extends AbstractIgniteEndpoint {
/**
* Gets the cache name.
- *
+ *
* @return
*/
public String getCacheName() {
@@ -117,7 +114,7 @@ public class IgniteCacheEndpoint extends AbstractIgniteEndpoint {
/**
* The cache name.
- *
+ *
* @param cacheName cache name
*/
public void setCacheName(String cacheName) {
@@ -126,7 +123,7 @@ public class IgniteCacheEndpoint extends AbstractIgniteEndpoint {
/**
* Gets the cache operation to invoke.
- *
+ *
* @return cache name
*/
public IgniteCacheOperation getOperation() {
@@ -136,7 +133,7 @@ public class IgniteCacheEndpoint extends AbstractIgniteEndpoint {
/**
* The cache operation to invoke.
* <p>Possible values: GET, PUT, REMOVE, SIZE, REBALANCE, QUERY, CLEAR.</p>
- *
+ *
* @param operation
*/
public void setOperation(IgniteCacheOperation operation) {
@@ -145,7 +142,7 @@ public class IgniteCacheEndpoint extends AbstractIgniteEndpoint {
/**
* Whether to fail the initialization if the cache doesn't exist.
- *
+ *
* @return
*/
public boolean isFailIfInexistentCache() {
@@ -154,7 +151,7 @@ public class IgniteCacheEndpoint extends AbstractIgniteEndpoint {
/**
* Whether to fail the initialization if the cache doesn't exist.
- *
+ *
* @param failIfInexistentCache
*/
public void setFailIfInexistentCache(boolean failIfInexistentCache) {
@@ -163,7 +160,7 @@ public class IgniteCacheEndpoint extends AbstractIgniteEndpoint {
/**
* Gets the {@link CachePeekMode}, only needed for operations that require it ({@link IgniteCacheOperation#SIZE}).
- *
+ *
* @return
*/
public CachePeekMode getCachePeekMode() {
@@ -172,7 +169,7 @@ public class IgniteCacheEndpoint extends AbstractIgniteEndpoint {
/**
* The {@link CachePeekMode}, only needed for operations that require it ({@link IgniteCacheOperation#SIZE}).
- *
+ *
* @param cachePeekMode
*/
public void setCachePeekMode(CachePeekMode cachePeekMode) {
@@ -180,9 +177,9 @@ public class IgniteCacheEndpoint extends AbstractIgniteEndpoint {
}
/**
- * Gets the query to execute, only needed for operations that require it,
+ * Gets the query to execute, only needed for operations that require it,
* and for the Continuous Query Consumer.
- *
+ *
* @return
*/
public Query<Entry<Object, Object>> getQuery() {
@@ -192,7 +189,7 @@ public class IgniteCacheEndpoint extends AbstractIgniteEndpoint {
/**
* The {@link Query} to execute, only needed for operations that require it,
* and for the Continuous Query Consumer.
- *
+ *
* @param query
*/
public void setQuery(Query<Entry<Object, Object>> query) {
@@ -201,7 +198,7 @@ public class IgniteCacheEndpoint extends AbstractIgniteEndpoint {
/**
* Gets the remote filter, only used by the Continuous Query Consumer.
- *
+ *
* @return
*/
public CacheEntryEventSerializableFilter<Object, Object> getRemoteFilter() {
@@ -210,7 +207,7 @@ public class IgniteCacheEndpoint extends AbstractIgniteEndpoint {
/**
* The remote filter, only used by the Continuous Query Consumer.
- *
+ *
* @param remoteFilter
*/
public void setRemoteFilter(CacheEntryEventSerializableFilter<Object, Object> remoteFilter) {
@@ -220,7 +217,7 @@ public class IgniteCacheEndpoint extends AbstractIgniteEndpoint {
/**
* Gets whether to pack each update in an individual Exchange, even if multiple updates are
* received in one batch. Only used by the Continuous Query Consumer.
- *
+ *
* @return
*/
public boolean isOneExchangePerUpdate() {
@@ -230,7 +227,7 @@ public class IgniteCacheEndpoint extends AbstractIgniteEndpoint {
/**
* Whether to pack each update in an individual Exchange, even if multiple updates are
* received in one batch. Only used by the Continuous Query Consumer.
- *
+ *
* @param oneExchangePerUpdate
*/
public void setOneExchangePerUpdate(boolean oneExchangePerUpdate) {
@@ -239,7 +236,7 @@ public class IgniteCacheEndpoint extends AbstractIgniteEndpoint {
/**
* Gets whether auto unsubscribe is enabled in the Continuous Query Consumer.
- *
+ *
* @return
*/
public boolean isAutoUnsubscribe() {
@@ -248,7 +245,7 @@ public class IgniteCacheEndpoint extends AbstractIgniteEndpoint {
/**
* Whether auto unsubscribe is enabled in the Continuous Query Consumer.
- *
+ *
* @param autoUnsubscribe
*/
public void setAutoUnsubscribe(boolean autoUnsubscribe) {
@@ -257,7 +254,7 @@ public class IgniteCacheEndpoint extends AbstractIgniteEndpoint {
/**
* Gets the page size. Only used by the Continuous Query Consumer.
- *
+ *
* @return
*/
public int getPageSize() {
@@ -266,7 +263,7 @@ public class IgniteCacheEndpoint extends AbstractIgniteEndpoint {
/**
* The page size. Only used by the Continuous Query Consumer.
- *
+ *
* @param pageSize
*/
public void setPageSize(int pageSize) {
@@ -274,9 +271,9 @@ public class IgniteCacheEndpoint extends AbstractIgniteEndpoint {
}
/**
- * Gets whether to process existing results that match the query. Used on initialization of
+ * Gets whether to process existing results that match the query. Used on initialization of
* the Continuous Query Consumer.
- *
+ *
* @return
*/
public boolean isFireExistingQueryResults() {
@@ -284,9 +281,9 @@ public class IgniteCacheEndpoint extends AbstractIgniteEndpoint {
}
/**
- * Whether to process existing results that match the query. Used on initialization of
+ * Whether to process existing results that match the query. Used on initialization of
* the Continuous Query Consumer.
- *
+ *
* @param fireExistingQueryResults
*/
public void setFireExistingQueryResults(boolean fireExistingQueryResults) {
@@ -295,7 +292,7 @@ public class IgniteCacheEndpoint extends AbstractIgniteEndpoint {
/**
* Gets the time interval for the Continuous Query Consumer.
- *
+ *
* @return
*/
public long getTimeInterval() {
@@ -304,7 +301,7 @@ public class IgniteCacheEndpoint extends AbstractIgniteEndpoint {
/**
* The time interval for the Continuous Query Consumer.
- *
+ *
* @param timeInterval
*/
public void setTimeInterval(long timeInterval) {
diff --git a/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/compute/IgniteComputeEndpoint.java b/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/compute/IgniteComputeEndpoint.java
index 04e7269..055bd95 100644
--- a/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/compute/IgniteComputeEndpoint.java
+++ b/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/compute/IgniteComputeEndpoint.java
@@ -31,9 +31,10 @@ import org.apache.ignite.Ignite;
import org.apache.ignite.IgniteCompute;
/**
- * The Ignite Compute endpoint is one of camel-ignite endpoints which allows you to run
- * <a href="https://apacheignite.readme.io/docs/compute-grid">compute operations</a>
- * on the cluster by passing in an IgniteCallable, an IgniteRunnable, an IgniteClosure,
+ * Run <a href="https://apacheignite.readme.io/docs/compute-grid">compute operations</a>
+ * on an Ignite cluster.
+ *
+ * You can pass an IgniteCallable, an IgniteRunnable, an IgniteClosure,
* or collections of them, along with their parameters if necessary.
* This endpoint only supports producers.
*/
@@ -146,7 +147,7 @@ public class IgniteComputeEndpoint extends AbstractIgniteEndpoint {
}
/**
- * Gets the name of the compute job, which will be set via {@link IgniteCompute#withName(String)}.
+ * Gets the name of the compute job, which will be set via {@link IgniteCompute#withName(String)}.
*/
public String getComputeName() {
return computeName;
diff --git a/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/events/IgniteEventsEndpoint.java b/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/events/IgniteEventsEndpoint.java
index 586af7c..f05bd0d 100644
--- a/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/events/IgniteEventsEndpoint.java
+++ b/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/events/IgniteEventsEndpoint.java
@@ -40,9 +40,9 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The Ignite Events endpoint is one of camel-ignite endpoints which allows you to
- * <a href="https://apacheignite.readme.io/docs/events">receive events</a> from
- * the Ignite cluster by creating a local event listener.
+ * <a href="https://apacheignite.readme.io/docs/events">Receive events</a> from
+ * an Ignite cluster by creating a local event listener.
+ *
* This endpoint only supports consumers.
* The Exchanges created by this consumer put the received Event object into the body of the IN message.
*/
diff --git a/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/idgen/IgniteIdGenEndpoint.java b/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/idgen/IgniteIdGenEndpoint.java
index d3e5b98..32df2a3 100644
--- a/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/idgen/IgniteIdGenEndpoint.java
+++ b/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/idgen/IgniteIdGenEndpoint.java
@@ -32,8 +32,9 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The Ignite ID Generator endpoint is one of camel-ignite endpoints which allows you to interact with
- * <a href="https://apacheignite.readme.io/docs/id-generator">Ignite Atomic Sequences and ID Generators</a>.
+ * Interact with <a href="https://apacheignite.readme.io/docs/id-generator">Ignite Atomic Sequences and ID Generators
+ * </a>.
+ *
* This endpoint only supports producers.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "ignite-idgen", title = "Ignite ID Generator", syntax = "ignite-idgen:name", label = "nosql,cache,compute", producerOnly = true)
diff --git a/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/messaging/IgniteMessagingEndpoint.java b/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/messaging/IgniteMessagingEndpoint.java
index b3ead2e..bd13259 100644
--- a/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/messaging/IgniteMessagingEndpoint.java
+++ b/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/messaging/IgniteMessagingEndpoint.java
@@ -31,8 +31,8 @@ import org.apache.ignite.Ignite;
import org.apache.ignite.IgniteMessaging;
/**
- * The Ignite Messaging endpoint is one of camel-ignite endpoints which allows you to send and
- * consume messages from an <a href="https://apacheignite.readme.io/docs/messaging">Ignite topic</a>.
+ * Send and receive messages from an <a href="https://apacheignite.readme.io/docs/messaging">Ignite topic</a>.
+ *
* This endpoint supports producers (to send messages) and consumers (to receive messages).
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "ignite-messaging", title = "Ignite Messaging", syntax = "ignite-messaging:topic", label = "nosql,cache,messaging")
diff --git a/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/queue/IgniteQueueEndpoint.java b/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/queue/IgniteQueueEndpoint.java
index e53196a..48f091d 100644
--- a/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/queue/IgniteQueueEndpoint.java
+++ b/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/queue/IgniteQueueEndpoint.java
@@ -33,8 +33,8 @@ import org.apache.ignite.IgniteQueue;
import org.apache.ignite.configuration.CollectionConfiguration;
/**
- * The Ignite Queue endpoint is one of camel-ignite endpoints which allows you to interact with
- * <a href="https://apacheignite.readme.io/docs/queue-and-set">Ignite Queue data structures</a>.
+ * Interact with <a href="https://apacheignite.readme.io/docs/queue-and-set">Ignite Queue data structures</a>.
+ *
* This endpoint only supports producers.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "ignite-queue", title = "Ignite Queues", syntax = "ignite-queue:name", label = "nosql,cache", producerOnly = true)
diff --git a/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/set/IgniteSetEndpoint.java b/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/set/IgniteSetEndpoint.java
index b60b972..52b684f 100644
--- a/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/set/IgniteSetEndpoint.java
+++ b/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/set/IgniteSetEndpoint.java
@@ -32,8 +32,8 @@ import org.apache.camel.util.PropertiesHelper;
import org.apache.ignite.configuration.CollectionConfiguration;
/**
- * The Ignite Sets endpoint is one of camel-ignite endpoints which allows you to interact with
- * <a href="https://apacheignite.readme.io/docs/queue-and-set">Ignite Set data structures</a>.
+ * Interact with <a href="https://apacheignite.readme.io/docs/queue-and-set">Ignite Set data structures</a>.
+ *
* This endpoint only supports producers.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "ignite-set", title = "Ignite Sets", syntax = "ignite-set:name", label = "nosql,cache", producerOnly = true)
diff --git a/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanEndpoint.java b/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanEndpoint.java
index ea20afd..88443cb 100644
--- a/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanEndpoint.java
+++ b/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanEndpoint.java
@@ -26,7 +26,7 @@ import org.apache.camel.spi.UriPath;
import org.apache.camel.support.DefaultEndpoint;
/**
- * For reading/writing from/to Infinispan distributed key/value store and data grid.
+ * Read and write from/to Infinispan distributed key/value store and data grid.
*/
@UriEndpoint(firstVersion = "2.13.0", scheme = "infinispan", title = "Infinispan", syntax = "infinispan:cacheName", label = "cache,datagrid,clustering")
public class InfinispanEndpoint extends DefaultEndpoint {
diff --git a/components/camel-influxdb/src/main/java/org/apache/camel/component/influxdb/InfluxDbEndpoint.java b/components/camel-influxdb/src/main/java/org/apache/camel/component/influxdb/InfluxDbEndpoint.java
index 1de308b..8f9565d 100644
--- a/components/camel-influxdb/src/main/java/org/apache/camel/component/influxdb/InfluxDbEndpoint.java
+++ b/components/camel-influxdb/src/main/java/org/apache/camel/component/influxdb/InfluxDbEndpoint.java
@@ -30,7 +30,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The influxdb component allows you to interact with <a href="https://influxdata.com/time-series-platform/influxdb/">InfluxDB</a>, a time series database.
+ * Interact with <a href="https://influxdata.com/time-series-platform/influxdb/">InfluxDB</a>, a time series database.
*/
@UriEndpoint(firstVersion = "2.18.0", scheme = "influxdb", title = "InfluxDB", syntax = "influxdb:connectionBean", label = "database", producerOnly = true)
public class InfluxDbEndpoint extends DefaultEndpoint {
@@ -52,7 +52,7 @@ public class InfluxDbEndpoint extends DefaultEndpoint {
private String operation = InfluxDbOperations.INSERT;
@UriParam
private String query;
-
+
public InfluxDbEndpoint(String uri, InfluxDbComponent component) {
super(uri, component);
}
@@ -66,7 +66,7 @@ public class InfluxDbEndpoint extends DefaultEndpoint {
public Consumer createConsumer(Processor processor) throws Exception {
throw new UnsupportedOperationException("You cannot receive messages from this endpoint");
}
-
+
public InfluxDB getInfluxDB() {
return influxDB;
}
diff --git a/components/camel-iota/src/main/java/org/apache/camel/component/iota/IOTAEndpoint.java b/components/camel-iota/src/main/java/org/apache/camel/component/iota/IOTAEndpoint.java
index b35ae39..4b487cc 100644
--- a/components/camel-iota/src/main/java/org/apache/camel/component/iota/IOTAEndpoint.java
+++ b/components/camel-iota/src/main/java/org/apache/camel/component/iota/IOTAEndpoint.java
@@ -29,7 +29,7 @@ import org.apache.camel.support.DefaultEndpoint;
import org.iota.jota.IotaAPI;
/**
- * Component for integrate IOTA DLT
+ * Manage financial transactions using IOTA distributed ledger.
*/
@UriEndpoint(firstVersion = "2.23.0", scheme = "iota", title = "IOTA", syntax = "iota:name", label = "ledger", producerOnly = true)
public class IOTAEndpoint extends DefaultEndpoint {
diff --git a/components/camel-ipfs/src/main/java/org/apache/camel/component/ipfs/IPFSEndpoint.java b/components/camel-ipfs/src/main/java/org/apache/camel/component/ipfs/IPFSEndpoint.java
index 349a442..e20a726 100644
--- a/components/camel-ipfs/src/main/java/org/apache/camel/component/ipfs/IPFSEndpoint.java
+++ b/components/camel-ipfs/src/main/java/org/apache/camel/component/ipfs/IPFSEndpoint.java
@@ -25,7 +25,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.support.DefaultEndpoint;
/**
- * The camel-ipfs component provides access to the Interplanetary File System (IPFS).
+ * Access the Interplanetary File System (IPFS).
*/
@UriEndpoint(firstVersion = "2.23.0", scheme = "ipfs", title = "IPFS",
syntax = "ipfs:ipfsCmd", producerOnly = true, label = "file,ipfs")
diff --git a/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcEndpoint.java b/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcEndpoint.java
index 302e6c4..d9617ba 100644
--- a/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcEndpoint.java
+++ b/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcEndpoint.java
@@ -32,14 +32,14 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The irc component implements an <a href="https://en.wikipedia.org/wiki/Internet_Relay_Chat">IRC</a> (Internet Relay Chat) transport.
+ * Send and receive messages to/from and IRC chat.
*/
@UriEndpoint(
- firstVersion = "1.1.0",
- scheme = "irc",
- title = "IRC",
+ firstVersion = "1.1.0",
+ scheme = "irc",
+ title = "IRC",
syntax = "irc:hostname:port",
- alternativeSyntax = "irc:username:password@hostname:port",
+ alternativeSyntax = "irc:username:password@hostname:port",
label = "chat")
public class IrcEndpoint extends DefaultEndpoint {
diff --git a/components/camel-ironmq/src/main/java/org/apache/camel/component/ironmq/IronMQEndpoint.java b/components/camel-ironmq/src/main/java/org/apache/camel/component/ironmq/IronMQEndpoint.java
index 56fdd2f..acc7c34 100644
--- a/components/camel-ironmq/src/main/java/org/apache/camel/component/ironmq/IronMQEndpoint.java
+++ b/components/camel-ironmq/src/main/java/org/apache/camel/component/ironmq/IronMQEndpoint.java
@@ -34,7 +34,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The ironmq provides integration with <a href="https://www.iron.io/">IronMQ</a> an elastic and durable hosted message queue as a service.
+ * Send and receive messages to/from <a href="https://www.iron.io/">IronMQ</a> an elastic and durable hosted message queue as a service.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "ironmq", syntax = "ironmq:queueName", title = "IronMQ", label = "cloud,messaging")
public class IronMQEndpoint extends ScheduledPollEndpoint {
@@ -112,7 +112,7 @@ public class IronMQEndpoint extends ScheduledPollEndpoint {
/**
* Provide the possibility to override this method for an mock
* implementation
- *
+ *
* @return Client
*/
Client createClient() {
diff --git a/components/camel-jbpm/src/main/java/org/apache/camel/component/jbpm/JBPMEndpoint.java b/components/camel-jbpm/src/main/java/org/apache/camel/component/jbpm/JBPMEndpoint.java
index 14d8d9a..aa10b3c 100644
--- a/components/camel-jbpm/src/main/java/org/apache/camel/component/jbpm/JBPMEndpoint.java
+++ b/components/camel-jbpm/src/main/java/org/apache/camel/component/jbpm/JBPMEndpoint.java
@@ -35,8 +35,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The jbpm component provides integration with jBPM (Business Process
- * Management).
+ * Interact with jBPM workflow engine over REST.
*/
@UriEndpoint(firstVersion = "2.6.0", scheme = "jbpm", title = "JBPM", syntax = "jbpm:connectionURL", label = "process")
public class JBPMEndpoint extends DefaultEndpoint {
diff --git a/components/camel-jcache/src/main/java/org/apache/camel/component/jcache/JCacheEndpoint.java b/components/camel-jcache/src/main/java/org/apache/camel/component/jcache/JCacheEndpoint.java
index 0c8aeee..3d83db8 100644
--- a/components/camel-jcache/src/main/java/org/apache/camel/component/jcache/JCacheEndpoint.java
+++ b/components/camel-jcache/src/main/java/org/apache/camel/component/jcache/JCacheEndpoint.java
@@ -26,7 +26,7 @@ import org.apache.camel.spi.UriPath;
import org.apache.camel.support.DefaultEndpoint;
/**
- * The jcache component enables you to perform caching operations using JSR107/JCache as cache implementation.
+ * Perform caching operations against JSR107/JCache.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "jcache", title = "JCache", syntax = "jcache:cacheName", label = "cache,datagrid,clustering")
public class JCacheEndpoint extends DefaultEndpoint {
diff --git a/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsEndpoint.java b/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsEndpoint.java
index c5a272b..f7b0b06 100644
--- a/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsEndpoint.java
+++ b/components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsEndpoint.java
@@ -21,7 +21,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.support.DefaultEndpoint;
/**
- * For interacting with cloud compute & blobstore service via jclouds.
+ * Interact with jclouds compute & blobstore service.
*/
@UriEndpoint(firstVersion = "2.9.0", scheme = "jclouds", title = "JClouds", syntax = "jclouds:command:providerId", label = "api,cloud")
public abstract class JcloudsEndpoint extends DefaultEndpoint {
diff --git a/components/camel-jcr/src/main/java/org/apache/camel/component/jcr/JcrEndpoint.java b/components/camel-jcr/src/main/java/org/apache/camel/component/jcr/JcrEndpoint.java
index 5dec4a3..d53b7c8 100644
--- a/components/camel-jcr/src/main/java/org/apache/camel/component/jcr/JcrEndpoint.java
+++ b/components/camel-jcr/src/main/java/org/apache/camel/component/jcr/JcrEndpoint.java
@@ -36,7 +36,7 @@ import org.apache.camel.util.ObjectHelper;
import org.apache.camel.util.StringHelper;
/**
- * The jcr component allows you to add/read nodes to/from a JCR compliant content repository.
+ * Read and write nodes to/from a JCR compliant content repository.
*/
@UriEndpoint(firstVersion = "1.3.0", scheme = "jcr", title = "JCR", syntax = "jcr:host/base", alternativeSyntax = "jcr:username:password@host/base",
label = "cms,database")
@@ -125,7 +125,7 @@ public class JcrEndpoint extends DefaultEndpoint {
/**
* Get the {@link Repository}
- *
+ *
* @return the repository
*/
protected Repository getRepository() {
@@ -134,7 +134,7 @@ public class JcrEndpoint extends DefaultEndpoint {
/**
* Get the {@link Credentials} for establishing the JCR repository connection
- *
+ *
* @return the credentials
*/
protected Credentials getCredentials() {
@@ -143,7 +143,7 @@ public class JcrEndpoint extends DefaultEndpoint {
/**
* Get the base node when accessing the repository
- *
+ *
* @return the base node
*/
protected String getBase() {
@@ -179,7 +179,7 @@ public class JcrEndpoint extends DefaultEndpoint {
/**
* <code>eventTypes</code> (a combination of one or more event types encoded
* as a bit mask value such as javax.jcr.observation.Event.NODE_ADDED, javax.jcr.observation.Event.NODE_REMOVED, etc.).
- *
+ *
* @return eventTypes
* @see {@link javax.jcr.observation.Event}
* @see {@link javax.jcr.observation.ObservationManager#addEventListener(javax.jcr.observation.EventListener, int, String, boolean, String[], String[], boolean)}
@@ -248,7 +248,7 @@ public class JcrEndpoint extends DefaultEndpoint {
/**
* Interval in milliseconds to wait before the first session live checking.
* The default value is 3000 ms.
- *
+ *
* @return sessionLiveCheckIntervalOnStart
*/
public long getSessionLiveCheckIntervalOnStart() {
@@ -278,7 +278,7 @@ public class JcrEndpoint extends DefaultEndpoint {
this.sessionLiveCheckInterval = sessionLiveCheckInterval;
}
-
+
/**
* The workspace to access. If it's not specified then the default one will be used
*/
diff --git a/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcEndpoint.java b/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcEndpoint.java
index 20758f8..15bfb0c 100644
--- a/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcEndpoint.java
+++ b/components/camel-jdbc/src/main/java/org/apache/camel/component/jdbc/JdbcEndpoint.java
@@ -31,7 +31,7 @@ import org.apache.camel.spi.UriPath;
import org.apache.camel.support.DefaultEndpoint;
/**
- * The jdbc component enables you to access databases through JDBC, where SQL queries are sent in the message body.
+ * Access databases through SQL and JDBC.
*/
@UriEndpoint(firstVersion = "1.2.0", scheme = "jdbc", title = "JDBC", syntax = "jdbc:dataSourceName", producerOnly = true, label = "database,sql")
public class JdbcEndpoint extends DefaultEndpoint {
diff --git a/components/camel-jetty/src/main/java/org/apache/camel/component/jetty9/JettyHttpEndpoint9.java b/components/camel-jetty/src/main/java/org/apache/camel/component/jetty9/JettyHttpEndpoint9.java
index beaac56..730b497 100644
--- a/components/camel-jetty/src/main/java/org/apache/camel/component/jetty9/JettyHttpEndpoint9.java
+++ b/components/camel-jetty/src/main/java/org/apache/camel/component/jetty9/JettyHttpEndpoint9.java
@@ -28,7 +28,7 @@ import org.apache.camel.spi.Metadata;
import org.apache.camel.spi.UriEndpoint;
/**
- * To use Jetty as a HTTP server as consumer for Camel routes.
+ * Expose HTTP endpoints using Jetty 9.
*/
@UriEndpoint(firstVersion = "1.2.0", scheme = "jetty", extendsScheme = "http", title = "Jetty", syntax = "jetty:httpUri", label = "http", consumerOnly = true, lenientProperties = true)
@Metadata(excludeProperties = "authMethod,authMethodPriority,authUsername,authPassword,authDomain,authHost"
diff --git a/components/camel-jgroups-raft/src/main/java/org/apache/camel/component/jgroups/raft/JGroupsRaftEndpoint.java b/components/camel-jgroups-raft/src/main/java/org/apache/camel/component/jgroups/raft/JGroupsRaftEndpoint.java
index 0640397..d492f40 100644
--- a/components/camel-jgroups-raft/src/main/java/org/apache/camel/component/jgroups/raft/JGroupsRaftEndpoint.java
+++ b/components/camel-jgroups-raft/src/main/java/org/apache/camel/component/jgroups/raft/JGroupsRaftEndpoint.java
@@ -36,7 +36,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The jgroups component provides exchange of messages between Camel and JGroups clusters.
+ * Exchange messages with JGroups-raft clusters.
*/
@UriEndpoint(firstVersion = "2.24.0", scheme = "jgroups-raft", title = "JGroups raft", syntax = "jgroup-raft:clusterName", label = "clustering,messaging")
public class JGroupsRaftEndpoint extends DefaultEndpoint {
diff --git a/components/camel-jgroups/src/main/java/org/apache/camel/component/jgroups/JGroupsEndpoint.java b/components/camel-jgroups/src/main/java/org/apache/camel/component/jgroups/JGroupsEndpoint.java
index 60406b9..17c1cbd 100644
--- a/components/camel-jgroups/src/main/java/org/apache/camel/component/jgroups/JGroupsEndpoint.java
+++ b/components/camel-jgroups/src/main/java/org/apache/camel/component/jgroups/JGroupsEndpoint.java
@@ -35,7 +35,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The jgroups component provides exchange of messages between Camel and JGroups clusters.
+ * Exchange messages with JGroups clusters.
*/
@UriEndpoint(firstVersion = "2.13.0", scheme = "jgroups", title = "JGroups", syntax = "jgroups:clusterName", label = "clustering,messaging")
public class JGroupsEndpoint extends DefaultEndpoint {
diff --git a/components/camel-jing/src/main/java/org/apache/camel/component/validator/jing/JingEndpoint.java b/components/camel-jing/src/main/java/org/apache/camel/component/validator/jing/JingEndpoint.java
index 6ab986d..19d1463 100644
--- a/components/camel-jing/src/main/java/org/apache/camel/component/validator/jing/JingEndpoint.java
+++ b/components/camel-jing/src/main/java/org/apache/camel/component/validator/jing/JingEndpoint.java
@@ -36,7 +36,7 @@ import org.apache.camel.support.ResourceHelper;
import org.apache.camel.util.StringHelper;
/**
- * Validates the payload of a message using RelaxNG Syntax using Jing library.
+ * Validate XML against a RelaxNG schema (XML Syntax or Compact Syntax) using Jing library.
*/
@UriEndpoint(firstVersion = "1.1.0", scheme = "jing", title = "Jing", syntax = "jing:resourceUri", producerOnly = true, label = "validation")
public class JingEndpoint extends DefaultEndpoint {
diff --git a/components/camel-jira/src/main/java/org/apache/camel/component/jira/JiraEndpoint.java b/components/camel-jira/src/main/java/org/apache/camel/component/jira/JiraEndpoint.java
index d67bf19..7985056 100644
--- a/components/camel-jira/src/main/java/org/apache/camel/component/jira/JiraEndpoint.java
+++ b/components/camel-jira/src/main/java/org/apache/camel/component/jira/JiraEndpoint.java
@@ -50,7 +50,7 @@ import org.slf4j.LoggerFactory;
import static org.apache.camel.component.jira.JiraConstants.JIRA_REST_CLIENT_FACTORY;
/**
- * The jira component interacts with the JIRA issue tracker.
+ * Interact with JIRA issue tracker.
* <p>
* The endpoint encapsulates portions of the JIRA API, relying on the jira-rest-java-client SDK. Available endpoint URIs include:
* <p>
diff --git a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
index b1f07a7..0c00553 100644
--- a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
+++ b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
@@ -65,7 +65,7 @@ import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.util.ErrorHandler;
/**
- * The jms component allows messages to be sent to (or consumed from) a JMS Queue or Topic.
+ * Sent and receive messages to/from a JMS Queue or Topic.
*
* This component uses Spring JMS and supports JMS 1.1 and 2.0 API.
*/
@@ -683,7 +683,7 @@ public class JmsEndpoint extends DefaultEndpoint implements AsyncEndpoint, Heade
public boolean isAllowReplyManagerQuickStop() {
return getConfiguration().isAllowReplyManagerQuickStop();
}
-
+
@ManagedAttribute
public boolean isAlwaysCopyMessage() {
return getConfiguration().isAlwaysCopyMessage();
@@ -778,7 +778,7 @@ public class JmsEndpoint extends DefaultEndpoint implements AsyncEndpoint, Heade
public void setAllowReplyManagerQuickStop(boolean allowReplyManagerQuickStop) {
getConfiguration().setAllowReplyManagerQuickStop(allowReplyManagerQuickStop);
}
-
+
@ManagedAttribute
public void setAcknowledgementMode(int consumerAcknowledgementMode) {
getConfiguration().setAcknowledgementMode(consumerAcknowledgementMode);
diff --git a/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXEndpoint.java b/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXEndpoint.java
index 1dda0e8..9d4dcd4 100644
--- a/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXEndpoint.java
+++ b/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXEndpoint.java
@@ -35,7 +35,7 @@ import org.apache.camel.support.DefaultEndpoint;
import org.apache.camel.util.ObjectHelper;
/**
- * The jmx component allows to receive JMX notifications.
+ * Receive JMX notifications.
*
* Endpoint that describes a connection to an mbean.
* <p/>
@@ -165,7 +165,7 @@ public class JMXEndpoint extends DefaultEndpoint {
*/
@UriParam(label = "consumer,string")
private String stringToCompare;
-
+
/**
* Format for the message body. Either "xml" or "raw". If xml, the notification is serialized to xml. If raw, then the raw java object is set as the body.
*/
@@ -195,21 +195,21 @@ public class JMXEndpoint extends DefaultEndpoint {
*/
@UriParam(label = "advanced")
private Object handback;
-
+
/**
* If true the consumer will throw an exception if unable to establish the JMX connection upon startup. If false, the consumer will attempt
* to establish the JMX connection every 'x' seconds until the connection is made -- where 'x' is the configured reconnectionDelay
*/
@UriParam(label = "advanced", defaultValue = "true")
private boolean testConnectionOnStartup = true;
-
+
/**
* If true the consumer will attempt to reconnect to the JMX server when any connection failure occurs. The consumer will attempt
* to re-establish the JMX connection every 'x' seconds until the connection is made-- where 'x' is the configured reconnectionDelay
*/
@UriParam(label = "advanced")
private boolean reconnectOnConnectionFailure;
-
+
/**
* The number of seconds to wait before attempting to retry establishment of the initial connection or attempt to reconnect a lost connection
*/
@@ -241,11 +241,11 @@ public class JMXEndpoint extends DefaultEndpoint {
public Consumer createConsumer(Processor aProcessor) throws Exception {
// validate that all of the endpoint is configured properly
if (getMonitorType() != null) {
-
+
if (!isPlatformServer()) {
throw new IllegalArgumentException(ERR_PLATFORM_SERVER);
}
-
+
if (ObjectHelper.isEmpty(getObservedAttribute())) {
throw new IllegalArgumentException(ERR_OBSERVED_ATTRIBUTE);
}
@@ -502,27 +502,27 @@ public class JMXEndpoint extends DefaultEndpoint {
public void setStringToCompare(String aStringToCompare) {
stringToCompare = aStringToCompare;
}
-
+
public boolean isTestConnectionOnStartup() {
return this.testConnectionOnStartup;
}
-
+
public void setTestConnectionOnStartup(boolean testConnectionOnStartup) {
this.testConnectionOnStartup = testConnectionOnStartup;
}
-
+
public boolean isReconnectOnConnectionFailure() {
return this.reconnectOnConnectionFailure;
}
-
+
public void setReconnectOnConnectionFailure(boolean reconnectOnConnectionFailure) {
this.reconnectOnConnectionFailure = reconnectOnConnectionFailure;
- }
-
+ }
+
public int getReconnectDelay() {
return this.reconnectDelay;
- }
-
+ }
+
public void setReconnectDelay(int reconnectDelay) {
this.reconnectDelay = reconnectDelay;
}
diff --git a/components/camel-jolt/src/main/java/org/apache/camel/component/jolt/JoltEndpoint.java b/components/camel-jolt/src/main/java/org/apache/camel/component/jolt/JoltEndpoint.java
index 146f71c..df2838f 100644
--- a/components/camel-jolt/src/main/java/org/apache/camel/component/jolt/JoltEndpoint.java
+++ b/components/camel-jolt/src/main/java/org/apache/camel/component/jolt/JoltEndpoint.java
@@ -37,7 +37,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.util.ObjectHelper;
/**
- * The jolt component allows you to process a JSON messages using an JOLT specification (such as JSON-JSON transformation).
+ * JSON to JSON transformation using JOLT.
*/
@UriEndpoint(firstVersion = "2.16.0", scheme = "jolt", title = "JOLT", syntax = "jolt:resourceUri", producerOnly = true, label = "transformation")
public class JoltEndpoint extends ResourceEndpoint {
diff --git a/components/camel-jooq/src/main/java/org/apache/camel/component/jooq/JooqEndpoint.java b/components/camel-jooq/src/main/java/org/apache/camel/component/jooq/JooqEndpoint.java
index 0d99bde..f507320 100644
--- a/components/camel-jooq/src/main/java/org/apache/camel/component/jooq/JooqEndpoint.java
+++ b/components/camel-jooq/src/main/java/org/apache/camel/component/jooq/JooqEndpoint.java
@@ -29,6 +29,9 @@ import org.apache.camel.support.ScheduledPollEndpoint;
import org.jooq.Query;
import org.jooq.ResultQuery;
+/**
+ * Store and retrieve Java objects from an SQL database using JOOQ.
+ */
@UriEndpoint(firstVersion = "3.0.0", scheme = "jooq", syntax = "jooq:entityType", title = "JOOQ", label = "database")
public class JooqEndpoint extends ScheduledPollEndpoint {
diff --git a/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java b/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java
index 255407e..fb2e57a 100644
--- a/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java
+++ b/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java
@@ -47,7 +47,7 @@ import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.support.TransactionTemplate;
/**
- * The jpa component enables you to store and retrieve Java objects from databases using JPA.
+ * Store and retrieve Java objects from databases using Java Persistence API (JPA).
*/
@UriEndpoint(firstVersion = "1.0.0", scheme = "jpa", title = "JPA", syntax = "jpa:entityType", label = "database,sql")
public class JpaEndpoint extends ScheduledPollEndpoint {
@@ -318,7 +318,7 @@ public class JpaEndpoint extends ScheduledPollEndpoint {
public void setMaxMessagesPerPoll(int maxMessagesPerPoll) {
this.maxMessagesPerPoll = maxMessagesPerPoll;
}
-
+
public boolean isUsePersist() {
return usePersist;
}
diff --git a/components/camel-jsch/src/main/java/org/apache/camel/component/scp/ScpEndpoint.java b/components/camel-jsch/src/main/java/org/apache/camel/component/scp/ScpEndpoint.java
index 37f5f42..f51a5f2 100644
--- a/components/camel-jsch/src/main/java/org/apache/camel/component/scp/ScpEndpoint.java
+++ b/components/camel-jsch/src/main/java/org/apache/camel/component/scp/ScpEndpoint.java
@@ -28,7 +28,7 @@ import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
/**
- * To copy files using the secure copy protocol (SCP).
+ * Copy files to/from remote hosts using the secure copy protocol (SCP).
*/
@UriEndpoint(firstVersion = "2.10.0", scheme = "scp", extendsScheme = "ftp", title = "SCP",
syntax = "scp:host:port/directoryName", producerOnly = true, label = "file")
@@ -82,7 +82,7 @@ public class ScpEndpoint extends RemoteFileEndpoint<ScpFile> {
public String getScheme() {
return "scp";
}
-
+
@Override
public Expression getTempFileName() {
// creation of temporary files not supported by the scp: protocol
diff --git a/components/camel-jslt/src/main/java/org/apache/camel/component/jslt/JsltEndpoint.java b/components/camel-jslt/src/main/java/org/apache/camel/component/jslt/JsltEndpoint.java
index 9143f8e..ce323c2 100644
--- a/components/camel-jslt/src/main/java/org/apache/camel/component/jslt/JsltEndpoint.java
+++ b/components/camel-jslt/src/main/java/org/apache/camel/component/jslt/JsltEndpoint.java
@@ -34,7 +34,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.util.ObjectHelper;
/**
- * The jslt component allows you to process a JSON messages using an JSLT transformations.
+ * Query or transform JSON payloads using an JSLT.
*
* @author JiriOndrusek
*/
diff --git a/components/camel-json-validator/src/main/java/org/apache/camel/component/jsonvalidator/JsonValidatorEndpoint.java b/components/camel-json-validator/src/main/java/org/apache/camel/component/jsonvalidator/JsonValidatorEndpoint.java
index 9adc096..862b8dd 100644
--- a/components/camel-json-validator/src/main/java/org/apache/camel/component/jsonvalidator/JsonValidatorEndpoint.java
+++ b/components/camel-json-validator/src/main/java/org/apache/camel/component/jsonvalidator/JsonValidatorEndpoint.java
@@ -34,7 +34,7 @@ import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
/**
- * Validates the payload of a message using NetworkNT JSON Schema library.
+ * Validate JSON payloads using NetworkNT JSON Schema.
*/
@ManagedResource(description = "Managed JsonValidatorEndpoint")
@UriEndpoint(scheme = "json-validator", firstVersion = "2.20.0", title = "JSON Schema Validator", syntax = "json-validator:resourceUri",
@@ -63,12 +63,12 @@ public class JsonValidatorEndpoint extends ResourceEndpoint {
this.schema = null;
super.clearContentCache();
}
-
+
@Override
public ExchangePattern getExchangePattern() {
return ExchangePattern.InOut;
}
-
+
@Override
protected void onExchange(Exchange exchange) throws Exception {
StreamCache cache = null;
@@ -135,7 +135,7 @@ public class JsonValidatorEndpoint extends ResourceEndpoint {
}
}
}
-
+
private Object getContentToValidate(Exchange exchange) {
if (shouldUseHeader()) {
return exchange.getIn().getHeader(headerName);
@@ -147,10 +147,10 @@ public class JsonValidatorEndpoint extends ResourceEndpoint {
private boolean shouldUseHeader() {
return headerName != null;
}
-
+
/**
* Synchronized method to create a schema if is does not already exist.
- *
+ *
* @return The currently loaded schema
*/
private JsonSchema getOrCreateSchema() throws Exception {
@@ -166,7 +166,7 @@ public class JsonValidatorEndpoint extends ResourceEndpoint {
protected String createEndpointUri() {
return "json-validator:" + getResourceUri();
}
-
+
public JsonValidatorErrorHandler getErrorHandler() {
return errorHandler;
}
@@ -179,11 +179,11 @@ public class JsonValidatorEndpoint extends ResourceEndpoint {
public void setErrorHandler(JsonValidatorErrorHandler errorHandler) {
this.errorHandler = errorHandler;
}
-
+
public JsonSchemaLoader getSchemaLoader() {
return schemaLoader;
}
-
+
/**
* To use a custom schema loader allowing for adding custom format validation. The default implementation will create a schema loader with draft v4 support.
*/
diff --git a/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400Endpoint.java b/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400Endpoint.java
index 7fb2c0e..eb78e6b4 100644
--- a/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400Endpoint.java
+++ b/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400Endpoint.java
@@ -35,7 +35,7 @@ import org.apache.camel.util.ObjectHelper;
import org.apache.camel.util.URISupport;
/**
- * The jt400 component allows you to exchanges messages with an AS/400 system using data queues or program call.
+ * Exchanges messages with an AS/400 system using data queues or program call.
*/
@UriEndpoint(firstVersion = "1.5.0", scheme = "jt400", title = "JT400", syntax = "jt400:userID:password/systemName/objectPath.type", label = "messaging")
public class Jt400Endpoint extends ScheduledPollEndpoint implements MultipleConsumersSupport {
@@ -49,7 +49,7 @@ public class Jt400Endpoint extends ScheduledPollEndpoint implements MultipleCons
/**
* Creates a new AS/400 data queue endpoint using a default connection pool
* provided by the component.
- *
+ *
* @throws NullPointerException if {@code component} is null
*/
protected Jt400Endpoint(String endpointUri, Jt400Component component) throws CamelException {
@@ -98,16 +98,16 @@ public class Jt400Endpoint extends ScheduledPollEndpoint implements MultipleCons
* Obtains an {@code AS400} object that connects to this endpoint. Since
* these objects represent limited resources, clients have the
* responsibility of {@link #releaseSystem(AS400) releasing them} when done.
- *
+ *
* @return an {@code AS400} object that connects to this endpoint
*/
protected AS400 getSystem() {
return configuration.getConnection();
}
-
+
/**
* Releases a previously obtained {@code AS400} object from use.
- *
+ *
* @param system a previously obtained {@code AS400} object
*/
protected void releaseSystem(AS400 system) {
@@ -117,7 +117,7 @@ public class Jt400Endpoint extends ScheduledPollEndpoint implements MultipleCons
/**
* Returns the fully qualified integrated file system path name of the data
* queue of this endpoint.
- *
+ *
* @return the fully qualified integrated file system path name of the data
* queue of this endpoint
*/
diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java
index 8da1e86..c1bbc4b 100644
--- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java
+++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java
@@ -42,8 +42,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The kafka component allows messages to be sent to (or consumed from) Apache
- * Kafka brokers.
+ * Sent and receive messages to/from an Apache Kafka broker.
*/
@UriEndpoint(firstVersion = "2.13.0", scheme = "kafka", title = "Kafka", syntax = "kafka:topic", label = "messaging")
public class KafkaEndpoint extends DefaultEndpoint implements MultipleConsumersSupport {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/config_maps/KubernetesConfigMapsEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/config_maps/KubernetesConfigMapsEndpoint.java
index d65ee50..983b15d 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/config_maps/KubernetesConfigMapsEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/config_maps/KubernetesConfigMapsEndpoint.java
@@ -24,8 +24,7 @@ import org.apache.camel.component.kubernetes.KubernetesConfiguration;
import org.apache.camel.spi.UriEndpoint;
/**
- * The Kubernetes Configmaps component provides a producer to execute kubernetes
- * configmap operations.
+ * Perform operations on Kubernetes ConfigMaps and get notified on ConfigMaps changes.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-config-maps", title = "Kubernetes ConfigMap", syntax = "kubernetes-config-maps:masterUrl", producerOnly = true, label = "container,cloud,paas")
public class KubernetesConfigMapsEndpoint extends AbstractKubernetesEndpoint {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsEndpoint.java
index 68e4725..447cf80 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/deployments/KubernetesDeploymentsEndpoint.java
@@ -24,8 +24,7 @@ import org.apache.camel.component.kubernetes.KubernetesConfiguration;
import org.apache.camel.spi.UriEndpoint;
/**
- * The Kubernetes Nodes component provides a producer to execute kubernetes node
- * operations and a consumer to consume node events.
+ * Perform operations on Kubernetes Deployments and get notified on Deployment changes.
*/
@UriEndpoint(firstVersion = "2.20.0", scheme = "kubernetes-deployments", title = "Kubernetes Deployments", syntax = "kubernetes-deployments:masterUrl", label = "container,cloud,paas")
public class KubernetesDeploymentsEndpoint extends AbstractKubernetesEndpoint {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/hpa/KubernetesHPAEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/hpa/KubernetesHPAEndpoint.java
index 32368d3..a196332 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/hpa/KubernetesHPAEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/hpa/KubernetesHPAEndpoint.java
@@ -24,8 +24,7 @@ import org.apache.camel.component.kubernetes.KubernetesConfiguration;
import org.apache.camel.spi.UriEndpoint;
/**
- * The Kubernetes HPA component provides a producer to execute kubernetes hpa
- * operations and a consumer to consume HPA events.
+ * Perform operations on Kubernetes Horizontal Pod Autoscalers (HPA) and get notified on HPA changes.
*/
@UriEndpoint(firstVersion = "2.23.0", scheme = "kubernetes-hpa", title = "Kubernetes HPA", syntax = "kubernetes-hpa:masterUrl", label = "container,cloud,paas")
public class KubernetesHPAEndpoint extends AbstractKubernetesEndpoint {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/job/KubernetesJobEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/job/KubernetesJobEndpoint.java
index 0cc3e5f..3a20442 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/job/KubernetesJobEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/job/KubernetesJobEndpoint.java
@@ -24,8 +24,7 @@ import org.apache.camel.component.kubernetes.KubernetesConfiguration;
import org.apache.camel.spi.UriEndpoint;
/**
- * The Kubernetes Jobs component provides a producer to execute kubernetes job
- * operations
+ * Perform operations on Kubernetes Jobs.
*/
@UriEndpoint(firstVersion = "2.23.0", scheme = "kubernetes-job", title = "Kubernetes Job", syntax = "kubernetes-job:masterUrl", label = "container,cloud,paas")
public class KubernetesJobEndpoint extends AbstractKubernetesEndpoint {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/namespaces/KubernetesNamespacesEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/namespaces/KubernetesNamespacesEndpoint.java
index 162cb1a..26e462c 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/namespaces/KubernetesNamespacesEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/namespaces/KubernetesNamespacesEndpoint.java
@@ -24,8 +24,7 @@ import org.apache.camel.component.kubernetes.KubernetesConfiguration;
import org.apache.camel.spi.UriEndpoint;
/**
- * The Kubernetes Namespaces component provides a producer to execute kubernetes
- * namespace operations and a consumer to consume namespace events.
+ * Perform operations on Kubernetes Namespaces and get notified on Namespace changes.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-namespaces", title = "Kubernetes Namespaces", syntax = "kubernetes-namespaces:masterUrl", label = "container,cloud,paas")
public class KubernetesNamespacesEndpoint extends AbstractKubernetesEndpoint {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesEndpoint.java
index c4a5da4..9db0a92 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/nodes/KubernetesNodesEndpoint.java
@@ -24,8 +24,7 @@ import org.apache.camel.component.kubernetes.KubernetesConfiguration;
import org.apache.camel.spi.UriEndpoint;
/**
- * The Kubernetes Nodes component provides a producer to execute kubernetes node
- * operations and a consumer to consume node events.
+ * Perform operations on Kubernetes Nodes and get notified on Node changes.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-nodes", title = "Kubernetes Nodes", syntax = "kubernetes-nodes:masterUrl", label = "container,cloud,paas")
public class KubernetesNodesEndpoint extends AbstractKubernetesEndpoint {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes/KubernetesPersistentVolumesEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes/KubernetesPersistentVolumesEndpoint.java
index 62ad11e..e45e32b 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes/KubernetesPersistentVolumesEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes/KubernetesPersistentVolumesEndpoint.java
@@ -24,8 +24,7 @@ import org.apache.camel.component.kubernetes.KubernetesConfiguration;
import org.apache.camel.spi.UriEndpoint;
/**
- * The Kubernetes Persistent Volumes component provides a producer to execute
- * kubernetes persistent volume operations.
+ * Perform operations on Kubernetes Persistent Volumes and get notified on Persistent Volume changes.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-persistent-volumes", title = "Kubernetes Persistent Volume", syntax = "kubernetes-persistent-volumes:masterUrl", producerOnly = true, label = "container,cloud,paas")
public class KubernetesPersistentVolumesEndpoint extends AbstractKubernetesEndpoint {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes_claims/KubernetesPersistentVolumesClaimsEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes_claims/KubernetesPersistentVolumesClaimsEndpoint.java
index 8688583..f4c0836 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes_claims/KubernetesPersistentVolumesClaimsEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/persistent_volumes_claims/KubernetesPersistentVolumesClaimsEndpoint.java
@@ -24,8 +24,7 @@ import org.apache.camel.component.kubernetes.KubernetesConfiguration;
import org.apache.camel.spi.UriEndpoint;
/**
- * The Kubernetes Persistent Volumes Claims component provides a producer to
- * execute kubernetes persistent volume claim operations.
+ * Perform operations on Kubernetes Persistent Volumes Claims and get notified on Persistent Volumes Claim changes.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-persistent-volumes-claims", title = "Kubernetes Persistent Volume Claim", syntax = "kubernetes-persistent-volumes-claims:masterUrl", producerOnly = true, label = "container,cloud,paas")
public class KubernetesPersistentVolumesClaimsEndpoint extends AbstractKubernetesEndpoint {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsEndpoint.java
index 4ee6408..8bbe8fc 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/pods/KubernetesPodsEndpoint.java
@@ -24,8 +24,7 @@ import org.apache.camel.component.kubernetes.KubernetesConfiguration;
import org.apache.camel.spi.UriEndpoint;
/**
- * The Kubernetes Pods component provides a producer to execute kubernetes pod
- * operations and a consumer to consume pod events.
+ * Perform operations on Kubernetes Pods and get notified on Pod changes.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-pods", title = "Kubernetes Pods", syntax = "kubernetes-pods:masterUrl", label = "container,cloud,paas")
public class KubernetesPodsEndpoint extends AbstractKubernetesEndpoint {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersEndpoint.java
index a4e6b25..1a678e8 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/replication_controllers/KubernetesReplicationControllersEndpoint.java
@@ -24,9 +24,7 @@ import org.apache.camel.component.kubernetes.KubernetesConfiguration;
import org.apache.camel.spi.UriEndpoint;
/**
- * The Kubernetes Replication Controllers component provides a producer to
- * execute kubernetes replication controller operations and a consumer to
- * consume replication controller events.
+ * Perform operations on Kubernetes Replication Controllers and get notified on Replication Controllers changes.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-replication-controllers", title = "Kubernetes Replication Controller", syntax = "kubernetes-replication-controllers:masterUrl", label = "container,cloud,paas")
public class KubernetesReplicationControllersEndpoint extends AbstractKubernetesEndpoint {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/resources_quota/KubernetesResourcesQuotaEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/resources_quota/KubernetesResourcesQuotaEndpoint.java
index ef29ac7..40b5e00 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/resources_quota/KubernetesResourcesQuotaEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/resources_quota/KubernetesResourcesQuotaEndpoint.java
@@ -24,8 +24,7 @@ import org.apache.camel.component.kubernetes.KubernetesConfiguration;
import org.apache.camel.spi.UriEndpoint;
/**
- * The Kubernetes Resources Quota component provides a producer to execute
- * kubernetes resources quota operations.
+ * Perform operations on Kubernetes Resources Quotas.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-resources-quota", title = "Kubernetes Resources Quota", syntax = "kubernetes-resources-quota:masterUrl", producerOnly = true, label = "container,cloud,paas")
public class KubernetesResourcesQuotaEndpoint extends AbstractKubernetesEndpoint {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/secrets/KubernetesSecretsEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/secrets/KubernetesSecretsEndpoint.java
index c0afea3..17e0b27 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/secrets/KubernetesSecretsEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/secrets/KubernetesSecretsEndpoint.java
@@ -24,8 +24,7 @@ import org.apache.camel.component.kubernetes.KubernetesConfiguration;
import org.apache.camel.spi.UriEndpoint;
/**
- * The Kubernetes Secrets component provides a producer to execute kubernetes
- * secret operations.
+ * Perform operations on Kubernetes Secrets.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-secrets", title = "Kubernetes Secrets", syntax = "kubernetes-secrets:masterUrl", producerOnly = true, label = "container,cloud,paas")
public class KubernetesSecretsEndpoint extends AbstractKubernetesEndpoint {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/service_accounts/KubernetesServiceAccountsEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/service_accounts/KubernetesServiceAccountsEndpoint.java
index eb8813b..b9d2ba5 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/service_accounts/KubernetesServiceAccountsEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/service_accounts/KubernetesServiceAccountsEndpoint.java
@@ -24,8 +24,7 @@ import org.apache.camel.component.kubernetes.KubernetesConfiguration;
import org.apache.camel.spi.UriEndpoint;
/**
- * The Kubernetes Service Accounts component provides a producer to execute
- * service account operations.
+ * Perform operations on Kubernetes Service Accounts.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-service-accounts", title = "Kubernetes Service Account", syntax = "kubernetes-service-accounts:masterUrl", producerOnly = true, label = "container,cloud,paas")
public class KubernetesServiceAccountsEndpoint extends AbstractKubernetesEndpoint {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesEndpoint.java
index bd3dd08..3babe49 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/services/KubernetesServicesEndpoint.java
@@ -24,8 +24,7 @@ import org.apache.camel.component.kubernetes.KubernetesConfiguration;
import org.apache.camel.spi.UriEndpoint;
/**
- * The Kubernetes Services component provides a producer to execute
- * service operations and a consumer to consume service events.
+ * Perform operations on Kubernetes Services and get notified on Service changes.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "kubernetes-services", title = "Kubernetes Services", syntax = "kubernetes-services:masterUrl", label = "container,cloud,paas")
public class KubernetesServicesEndpoint extends AbstractKubernetesEndpoint {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/build_configs/OpenshiftBuildConfigsEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/build_configs/OpenshiftBuildConfigsEndpoint.java
index c2132a4..add8579 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/build_configs/OpenshiftBuildConfigsEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/build_configs/OpenshiftBuildConfigsEndpoint.java
@@ -24,8 +24,7 @@ import org.apache.camel.component.kubernetes.KubernetesConfiguration;
import org.apache.camel.spi.UriEndpoint;
/**
- * The Kubernetes Build Config component provides a producer to execute
- * kubernetes build config operations.
+ * Perform operations on OpenShift Build Configs.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "openshift-build-configs", title = "Openshift Build Config", syntax = "openshift-build-configs:masterUrl", producerOnly = true, label = "container,cloud,paas")
public class OpenshiftBuildConfigsEndpoint extends AbstractKubernetesEndpoint {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/builds/OpenshiftBuildsEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/builds/OpenshiftBuildsEndpoint.java
index 3b9b6b5..e6620b1 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/builds/OpenshiftBuildsEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/openshift/builds/OpenshiftBuildsEndpoint.java
@@ -24,8 +24,7 @@ import org.apache.camel.component.kubernetes.KubernetesConfiguration;
import org.apache.camel.spi.UriEndpoint;
/**
- * The Openshift Builds component provides a producer to execute openshift build
- * operations.
+ * Perform operations on OpenShift Builds.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "openshift-builds", title = "Openshift Builds", syntax = "openshift-builds:masterUrl", producerOnly = true, label = "container,cloud,paas")
public class OpenshiftBuildsEndpoint extends AbstractKubernetesEndpoint {
diff --git a/components/camel-kudu/src/main/java/org/apache/camel/component/kudu/KuduEndpoint.java b/components/camel-kudu/src/main/java/org/apache/camel/component/kudu/KuduEndpoint.java
index d857471..9ccde31 100644
--- a/components/camel-kudu/src/main/java/org/apache/camel/component/kudu/KuduEndpoint.java
+++ b/components/camel-kudu/src/main/java/org/apache/camel/component/kudu/KuduEndpoint.java
@@ -31,8 +31,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * Represents a Kudu endpoint. A kudu endpoint allows you to interact with
- * <a href="https://kudu.apache.org/">Apache Kudu</a>, a free and open source
+ * Interact with <a href="https://kudu.apache.org/">Apache Kudu</a>, a free and open source
* column-oriented data store of the Apache Hadoop ecosystem.
*/
@UriEndpoint(firstVersion = "3.0",
diff --git a/components/camel-language/src/main/java/org/apache/camel/component/language/LanguageEndpoint.java b/components/camel-language/src/main/java/org/apache/camel/component/language/LanguageEndpoint.java
index f914f8b..756558c 100644
--- a/components/camel-language/src/main/java/org/apache/camel/component/language/LanguageEndpoint.java
+++ b/components/camel-language/src/main/java/org/apache/camel/component/language/LanguageEndpoint.java
@@ -40,7 +40,7 @@ import org.apache.camel.util.IOHelper;
import org.apache.camel.util.ObjectHelper;
/**
- * The language component allows you to send a message to an endpoint which executes a script by any of the supported Languages in Camel.
+ * Execute scripts in any of the languages supported by Camel.
*
* By having a component to execute language scripts, it allows more dynamic routing capabilities.
* For example by using the Routing Slip or Dynamic Router EIPs you can send messages to language endpoints
diff --git a/components/camel-ldap/src/main/java/org/apache/camel/component/ldap/LdapEndpoint.java b/components/camel-ldap/src/main/java/org/apache/camel/component/ldap/LdapEndpoint.java
index 23752ba..a5b6c7c 100644
--- a/components/camel-ldap/src/main/java/org/apache/camel/component/ldap/LdapEndpoint.java
+++ b/components/camel-ldap/src/main/java/org/apache/camel/component/ldap/LdapEndpoint.java
@@ -32,7 +32,7 @@ import org.apache.camel.spi.UriPath;
import org.apache.camel.support.DefaultEndpoint;
/**
- * The ldap component allows you to perform searches in LDAP servers using filters as the message payload.
+ * Perform searches on LDAP servers.
*/
@UriEndpoint(firstVersion = "1.5.0", scheme = "ldap", title = "LDAP", syntax = "ldap:dirContextName", producerOnly = true, label = "ldap")
public class LdapEndpoint extends DefaultEndpoint {
diff --git a/components/camel-ldif/src/main/java/org/apache/camel/component/ldif/LdifEndpoint.java b/components/camel-ldif/src/main/java/org/apache/camel/component/ldif/LdifEndpoint.java
index 66e51d2..ff504cf 100644
--- a/components/camel-ldif/src/main/java/org/apache/camel/component/ldif/LdifEndpoint.java
+++ b/components/camel-ldif/src/main/java/org/apache/camel/component/ldif/LdifEndpoint.java
@@ -27,7 +27,7 @@ import org.apache.camel.spi.UriPath;
import org.apache.camel.support.DefaultEndpoint;
/**
- * The ldif component allows you to do updates on an LDAP server from a LDIF body content.
+ * Perform updates on an LDAP server from an LDIF body content.
*/
@UriEndpoint(firstVersion = "2.20.0", scheme = "ldif", title = "LDIF", syntax = "ldif:ldapConnectionName", producerOnly = true, label = "ldap")
public class LdifEndpoint extends DefaultEndpoint {
diff --git a/components/camel-log/src/main/java/org/apache/camel/component/log/LogEndpoint.java b/components/camel-log/src/main/java/org/apache/camel/component/log/LogEndpoint.java
index a9e33de..72dedc7 100644
--- a/components/camel-log/src/main/java/org/apache/camel/component/log/LogEndpoint.java
+++ b/components/camel-log/src/main/java/org/apache/camel/component/log/LogEndpoint.java
@@ -37,7 +37,7 @@ import org.apache.camel.support.service.ServiceHelper;
import org.slf4j.Logger;
/**
- * The log component logs message exchanges to the underlying logging mechanism.
+ * Log messages to the underlying logging mechanism.
*
* Camel uses sfl4j which allows you to configure logging to the actual logging system.
*/
diff --git a/components/camel-lucene/src/main/java/org/apache/camel/component/lucene/LuceneEndpoint.java b/components/camel-lucene/src/main/java/org/apache/camel/component/lucene/LuceneEndpoint.java
index d48a3c8..b6bdba1 100644
--- a/components/camel-lucene/src/main/java/org/apache/camel/component/lucene/LuceneEndpoint.java
+++ b/components/camel-lucene/src/main/java/org/apache/camel/component/lucene/LuceneEndpoint.java
@@ -25,7 +25,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.support.DefaultEndpoint;
/**
- * To insert or query from Apache Lucene databases.
+ * Perform inserts or queries against Apache Lucene databases.
*/
@UriEndpoint(firstVersion = "2.2.0", scheme = "lucene", title = "Lucene", syntax = "lucene:host:operation", producerOnly = true, label = "database,search")
public class LuceneEndpoint extends DefaultEndpoint {
@@ -62,7 +62,7 @@ public class LuceneEndpoint extends DefaultEndpoint {
}
return new LuceneIndexProducer(this, this.config, indexer);
}
-
+
public LuceneConfiguration getConfig() {
return config;
}
diff --git a/components/camel-lumberjack/src/main/java/org/apache/camel/component/lumberjack/LumberjackEndpoint.java b/components/camel-lumberjack/src/main/java/org/apache/camel/component/lumberjack/LumberjackEndpoint.java
index 52222fe..0868371 100644
--- a/components/camel-lumberjack/src/main/java/org/apache/camel/component/lumberjack/LumberjackEndpoint.java
+++ b/components/camel-lumberjack/src/main/java/org/apache/camel/component/lumberjack/LumberjackEndpoint.java
@@ -31,7 +31,7 @@ import org.apache.camel.support.DefaultEndpoint;
import org.apache.camel.support.jsse.SSLContextParameters;
/**
- * The lumberjack retrieves logs sent over the network using the Lumberjack protocol.
+ * Receive logs messages using the Lumberjack protocol.
*/
@UriEndpoint(firstVersion = "2.18.0", scheme = "lumberjack", title = "Lumberjack", syntax = "lumberjack:host:port", consumerOnly = true, label = "log")
public class LumberjackEndpoint extends DefaultEndpoint {
diff --git a/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailEndpoint.java b/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailEndpoint.java
index 61210b3..eb940b5 100644
--- a/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailEndpoint.java
+++ b/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailEndpoint.java
@@ -32,7 +32,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.support.ScheduledPollEndpoint;
/**
- * To send or receive emails using imap/pop3 or smtp protocols.
+ * Send and receive emails using imap, pop3 and smtp protocols.
*/
@UriEndpoint(firstVersion = "1.0.0", scheme = "imap,imaps,pop3,pop3s,smtp,smtps", title = "IMAP,IMAPS,POP3,POP3S,SMTP,SMTPS",
syntax = "imap:host:port", alternativeSyntax = "imap:username:password@host:port",
diff --git a/components/camel-master/src/main/java/org/apache/camel/component/master/MasterEndpoint.java b/components/camel-master/src/main/java/org/apache/camel/component/master/MasterEndpoint.java
index 99bc52c..4eaee5e 100644
--- a/components/camel-master/src/main/java/org/apache/camel/component/master/MasterEndpoint.java
+++ b/components/camel-master/src/main/java/org/apache/camel/component/master/MasterEndpoint.java
@@ -31,8 +31,7 @@ import org.apache.camel.spi.UriPath;
import org.apache.camel.support.DefaultEndpoint;
/**
- * Represents an endpoint which only becomes active when the {@link CamelClusterView}
- * has the leadership.
+ * Have only a single consumer in a cluster consuming from a given endpoint; with automatic failover if the JVM dies.
*/
@ManagedResource(description = "Managed Master Endpoint")
@UriEndpoint(
diff --git a/components/camel-metrics/src/main/java/org/apache/camel/component/metrics/MetricsEndpoint.java b/components/camel-metrics/src/main/java/org/apache/camel/component/metrics/MetricsEndpoint.java
index b7bef80..ac2c3bc 100644
--- a/components/camel-metrics/src/main/java/org/apache/camel/component/metrics/MetricsEndpoint.java
+++ b/components/camel-metrics/src/main/java/org/apache/camel/component/metrics/MetricsEndpoint.java
@@ -29,7 +29,7 @@ import org.apache.camel.spi.UriPath;
import org.apache.camel.support.DefaultEndpoint;
/**
- * To collect various metrics directly from Camel routes using the DropWizard metrics library.
+ * Collect various metrics directly from Camel routes using the DropWizard metrics library.
*/
@UriEndpoint(firstVersion = "2.14.0", scheme = "metrics", title = "Metrics", syntax = "metrics:metricsType:metricsName", producerOnly = true, label = "monitoring")
public class MetricsEndpoint extends DefaultEndpoint {
diff --git a/components/camel-micrometer/src/main/java/org/apache/camel/component/micrometer/MicrometerEndpoint.java b/components/camel-micrometer/src/main/java/org/apache/camel/component/micrometer/MicrometerEndpoint.java
index b34567f..fa10ad1 100644
--- a/components/camel-micrometer/src/main/java/org/apache/camel/component/micrometer/MicrometerEndpoint.java
+++ b/components/camel-micrometer/src/main/java/org/apache/camel/component/micrometer/MicrometerEndpoint.java
@@ -31,7 +31,7 @@ import org.apache.camel.spi.UriPath;
import org.apache.camel.support.DefaultEndpoint;
/**
- * To collect various metrics directly from Camel routes using the Micrometer library.
+ * Collect various metrics directly from Camel routes using the Micrometer library.
*/
@UriEndpoint(firstVersion = "2.22.0", scheme = "micrometer", title = "Micrometer", syntax = "micrometer:metricsType:metricsName", producerOnly = true, label = "monitoring")
public class MicrometerEndpoint extends DefaultEndpoint {
diff --git a/components/camel-microprofile-metrics/src/main/java/org/apache/camel/component/microprofile/metrics/MicroProfileMetricsEndpoint.java b/components/camel-microprofile-metrics/src/main/java/org/apache/camel/component/microprofile/metrics/MicroProfileMetricsEndpoint.java
index 16afacc..a7e9f67 100644
--- a/components/camel-microprofile-metrics/src/main/java/org/apache/camel/component/microprofile/metrics/MicroProfileMetricsEndpoint.java
+++ b/components/camel-microprofile-metrics/src/main/java/org/apache/camel/component/microprofile/metrics/MicroProfileMetricsEndpoint.java
@@ -28,6 +28,9 @@ import org.apache.camel.support.DefaultEndpoint;
import org.eclipse.microprofile.metrics.MetricRegistry;
import org.eclipse.microprofile.metrics.MetricType;
+/**
+ * Expose metrics from Camel routes.
+ */
@UriEndpoint(firstVersion = "3.0.0", scheme = "microprofile-metrics", title = "MicroProfile Metrics", syntax = "microprofile-metrics:metricType:metricName", producerOnly = true, label = "monitoring")
public class MicroProfileMetricsEndpoint extends DefaultEndpoint {
diff --git a/components/camel-milo/src/main/java/org/apache/camel/component/milo/client/MiloClientEndpoint.java b/components/camel-milo/src/main/java/org/apache/camel/component/milo/client/MiloClientEndpoint.java
index 40db1ed..beb7c4c 100644
--- a/components/camel-milo/src/main/java/org/apache/camel/component/milo/client/MiloClientEndpoint.java
+++ b/components/camel-milo/src/main/java/org/apache/camel/component/milo/client/MiloClientEndpoint.java
@@ -29,8 +29,7 @@ import org.apache.camel.support.DefaultEndpoint;
import org.eclipse.milo.opcua.stack.core.types.builtin.ExpandedNodeId;
/**
- * Connect to OPC UA servers using the binary protocol for acquiring telemetry
- * data
+ * Connect to OPC UA servers using the binary protocol for acquiring telemetry data.
*/
@UriEndpoint(firstVersion = "2.19.0", scheme = "milo-client", syntax = "milo-client:endpointUri", title = "OPC UA Client", label = "iot")
public class MiloClientEndpoint extends DefaultEndpoint {
diff --git a/components/camel-milo/src/main/java/org/apache/camel/component/milo/server/MiloServerEndpoint.java b/components/camel-milo/src/main/java/org/apache/camel/component/milo/server/MiloServerEndpoint.java
index ddb2777..19c4054 100644
--- a/components/camel-milo/src/main/java/org/apache/camel/component/milo/server/MiloServerEndpoint.java
+++ b/components/camel-milo/src/main/java/org/apache/camel/component/milo/server/MiloServerEndpoint.java
@@ -27,7 +27,7 @@ import org.apache.camel.spi.UriPath;
import org.apache.camel.support.DefaultEndpoint;
/**
- * Make telemetry data available as an OPC UA server
+ * Make telemetry data available as an OPC UA server.
*/
@UriEndpoint(firstVersion = "2.19.0", scheme = "milo-server", syntax = "milo-server:itemId", title = "OPC UA Server", label = "iot")
public class MiloServerEndpoint extends DefaultEndpoint {
diff --git a/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaEndpoint.java b/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaEndpoint.java
index fade4a1..bf9cadb 100644
--- a/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaEndpoint.java
+++ b/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaEndpoint.java
@@ -29,7 +29,7 @@ import org.apache.camel.util.ObjectHelper;
import org.apache.mina.core.session.IoSession;
/**
- * Socket level networking using TCP or UDP with the Apache Mina 2.x library.
+ * Socket level networking using TCP or UDP with Apache Mina 2.x.
*/
@UriEndpoint(firstVersion = "2.10.0", scheme = "mina", title = "Mina", syntax = "mina:protocol:host:port", label = "networking,tcp,udp")
public class MinaEndpoint extends DefaultEndpoint implements MultipleConsumersSupport {
diff --git a/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpEndpoint.java b/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpEndpoint.java
index f219ffc..bd079ba 100644
--- a/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpEndpoint.java
+++ b/components/camel-mllp/src/main/java/org/apache/camel/component/mllp/MllpEndpoint.java
@@ -37,7 +37,7 @@ import org.apache.camel.support.DefaultEndpoint;
import org.slf4j.Logger;
/**
- * Provides functionality required by Healthcare providers to communicate with other systems using the MLLP protocol.
+ * Communicate with external systems using the MLLP protocol.
*
* <p/>
* NOTE: MLLP payloads are not logged unless the logging level is set to DEBUG or TRACE to avoid introducing PHI into the log files. Logging of PHI can be globally disabled by setting the
diff --git a/components/camel-mock/src/main/java/org/apache/camel/component/mock/MockEndpoint.java b/components/camel-mock/src/main/java/org/apache/camel/component/mock/MockEndpoint.java
index 9ac9223..0e09f34 100644
--- a/components/camel-mock/src/main/java/org/apache/camel/component/mock/MockEndpoint.java
+++ b/components/camel-mock/src/main/java/org/apache/camel/component/mock/MockEndpoint.java
@@ -65,7 +65,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The mock component is used for testing routes and mediation rules using mocks.
+ * Test routes and mediation rules using mocks.
* <p/>
* A Mock endpoint which provides a literate, fluent API for testing routes
* using a <a href="http://jmock.org/">JMock style</a> API.
@@ -101,7 +101,7 @@ public class MockEndpoint extends DefaultEndpoint implements BrowsableEndpoint,
// must be volatile so changes is visible between the thread which performs the assertions
// and the threads which process the exchanges when routing messages in Camel
protected volatile Processor reporter;
-
+
private volatile Processor defaultProcessor;
private volatile Map<Integer, Processor> processors;
private volatile List<Exchange> receivedExchanges;
@@ -346,10 +346,10 @@ public class MockEndpoint extends DefaultEndpoint implements BrowsableEndpoint,
public void whenAnyExchangeReceived(Processor processor) {
this.defaultProcessor = processor;
}
-
+
/**
* Set the expression which value will be set to the message body
- * @param expression which is use to set the message body
+ * @param expression which is use to set the message body
*/
public void returnReplyBody(Expression expression) {
this.defaultProcessor = exchange -> {
@@ -357,11 +357,11 @@ public class MockEndpoint extends DefaultEndpoint implements BrowsableEndpoint,
exchange.getMessage().setBody(exp);
};
}
-
+
/**
* Set the expression which value will be set to the message header
* @param headerName that will be set value
- * @param expression which is use to set the message header
+ * @param expression which is use to set the message header
*/
public void returnReplyHeader(String headerName, Expression expression) {
this.defaultProcessor = exchange -> {
@@ -369,7 +369,7 @@ public class MockEndpoint extends DefaultEndpoint implements BrowsableEndpoint,
exchange.getMessage().setHeader(headerName, exp);
};
}
-
+
/**
* Validates that all the available expectations on this endpoint are
@@ -459,7 +459,7 @@ public class MockEndpoint extends DefaultEndpoint implements BrowsableEndpoint,
}
}
if (failed) {
- // fail() throws the AssertionError to indicate the test failed.
+ // fail() throws the AssertionError to indicate the test failed.
fail("Expected assertion failure but test succeeded!");
}
}
@@ -484,12 +484,12 @@ public class MockEndpoint extends DefaultEndpoint implements BrowsableEndpoint,
LOG.info("Caught expected failure: " + e.getMessage());
}
}
- if (failed) {
- // fail() throws the AssertionError to indicate the test failed.
+ if (failed) {
+ // fail() throws the AssertionError to indicate the test failed.
fail("Expected assertion failure but test succeeded!");
}
- }
-
+ }
+
/**
* Specifies the expected number of message exchanges that should be
* received by this endpoint
@@ -513,7 +513,7 @@ public class MockEndpoint extends DefaultEndpoint implements BrowsableEndpoint,
* Sets a grace period after which the mock endpoint will re-assert
* to ensure the preliminary assertion is still valid.
* <p/>
- * This is used for example to assert that <b>exactly</b> a number of messages
+ * This is used for example to assert that <b>exactly</b> a number of messages
* arrives. For example if {@link #expectedMessageCount(int)} was set to 5, then
* the assertion is satisfied when 5 or more message arrives. To ensure that
* exactly 5 messages arrives, then you would need to wait a little period
@@ -730,7 +730,7 @@ public class MockEndpoint extends DefaultEndpoint implements BrowsableEndpoint,
List<Object> valueList = new ArrayList<>();
valueList.addAll(Arrays.asList(values));
expectedPropertyValuesReceivedInAnyOrder(name, valueList);
- }
+ }
/**
* Adds an expectation that the given body values are received by this
@@ -1338,7 +1338,7 @@ public class MockEndpoint extends DefaultEndpoint implements BrowsableEndpoint,
*
* @param expectedCount the number of message exchanges that should be
* expected by this endpoint
- * @see #setAssertPeriod(long)
+ * @see #setAssertPeriod(long)
*/
public void setExpectedCount(int expectedCount) {
setExpectedMessageCount(expectedCount);
@@ -1406,7 +1406,7 @@ public class MockEndpoint extends DefaultEndpoint implements BrowsableEndpoint,
* <p/>
* You can configure both {@link #setRetainFirst(int)} and {@link #setRetainLast(int)} methods,
* to limit both the first and last received.
- *
+ *
* @param retainFirst to limit and only keep the first n'th received {@link Exchange}s, use
* <tt>0</tt> to not retain any messages, or <tt>-1</tt> to retain all.
* @see #setRetainLast(int)
@@ -1649,7 +1649,7 @@ public class MockEndpoint extends DefaultEndpoint implements BrowsableEndpoint,
/**
* Adds the received exchange.
- *
+ *
* @param copy a copy of the received exchange
*/
protected void addReceivedExchange(Exchange copy) {
diff --git a/components/camel-mongodb-gridfs/src/main/java/org/apache/camel/component/mongodb/gridfs/GridFsEndpoint.java b/components/camel-mongodb-gridfs/src/main/java/org/apache/camel/component/mongodb/gridfs/GridFsEndpoint.java
index 46f3d31..a75c459 100644
--- a/components/camel-mongodb-gridfs/src/main/java/org/apache/camel/component/mongodb/gridfs/GridFsEndpoint.java
+++ b/components/camel-mongodb-gridfs/src/main/java/org/apache/camel/component/mongodb/gridfs/GridFsEndpoint.java
@@ -35,7 +35,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * Component for working with MongoDB GridFS.
+ * Interact with MongoDB GridFS.
*/
@UriEndpoint(firstVersion = "2.18.0", scheme = "mongodb-gridfs", title = "MongoDB GridFS", syntax = "mongodb-gridfs:connectionBean", label = "database,nosql")
public class GridFsEndpoint extends DefaultEndpoint {
diff --git a/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java b/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java
index a87e7aa..19c4c9e 100644
--- a/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java
+++ b/components/camel-mongodb/src/main/java/org/apache/camel/component/mongodb/MongoDbEndpoint.java
@@ -55,7 +55,7 @@ import static org.apache.camel.component.mongodb.MongoDbOutputType.DocumentList;
import static org.apache.camel.component.mongodb.MongoDbOutputType.MongoIterable;
/**
- * Component for working with documents stored in MongoDB database.
+ * Perform operations on MongoDB documents and collections.
*/
@UriEndpoint(firstVersion = "2.19.0", scheme = "mongodb", title = "MongoDB", syntax = "mongodb:connectionBean",
label = "database,nosql")
diff --git a/components/camel-msv/src/main/java/org/apache/camel/component/validator/msv/MsvEndpoint.java b/components/camel-msv/src/main/java/org/apache/camel/component/validator/msv/MsvEndpoint.java
index ba6992a..05eebb5 100644
--- a/components/camel-msv/src/main/java/org/apache/camel/component/validator/msv/MsvEndpoint.java
+++ b/components/camel-msv/src/main/java/org/apache/camel/component/validator/msv/MsvEndpoint.java
@@ -25,7 +25,7 @@ import org.apache.camel.support.processor.validation.ValidatingProcessor;
import org.iso_relax.verifier.jaxp.validation.RELAXNGSchemaFactoryImpl;
/**
- * Validates the payload of a message using the MSV Library.
+ * Validate XML payloads using Multi-Schema Validator (MSV).
*/
@UriEndpoint(firstVersion = "1.1.0", scheme = "msv", title = "MSV", syntax = "msv:resourceUri", producerOnly = true, label = "validation")
public class MsvEndpoint extends ValidatorEndpoint {
diff --git a/components/camel-mustache/src/main/java/org/apache/camel/component/mustache/MustacheEndpoint.java b/components/camel-mustache/src/main/java/org/apache/camel/component/mustache/MustacheEndpoint.java
index 16cb62f..89c6c32 100644
--- a/components/camel-mustache/src/main/java/org/apache/camel/component/mustache/MustacheEndpoint.java
+++ b/components/camel-mustache/src/main/java/org/apache/camel/component/mustache/MustacheEndpoint.java
@@ -40,7 +40,7 @@ import static org.apache.camel.component.mustache.MustacheConstants.MUSTACHE_RES
import static org.apache.camel.component.mustache.MustacheConstants.MUSTACHE_TEMPLATE;
/**
- * Transforms the message using a Mustache template.
+ * Transform messages using a Mustache template.
*/
@UriEndpoint(firstVersion = "2.12.0", scheme = "mustache", title = "Mustache", syntax = "mustache:resourceUri", producerOnly = true, label = "transformation")
public class MustacheEndpoint extends ResourceEndpoint {
diff --git a/components/camel-mvel/src/main/java/org/apache/camel/component/mvel/MvelEndpoint.java b/components/camel-mvel/src/main/java/org/apache/camel/component/mvel/MvelEndpoint.java
index ef5d813..f41a15b 100644
--- a/components/camel-mvel/src/main/java/org/apache/camel/component/mvel/MvelEndpoint.java
+++ b/components/camel-mvel/src/main/java/org/apache/camel/component/mvel/MvelEndpoint.java
@@ -35,7 +35,7 @@ import org.mvel2.templates.TemplateCompiler;
import org.mvel2.templates.TemplateRuntime;
/**
- * Transforms the message using a MVEL template.
+ * Transform messages using an MVEL template.
*/
@UriEndpoint(firstVersion = "2.12.0", scheme = "mvel", title = "MVEL", syntax = "mvel:resourceUri", producerOnly = true, label = "transformation,script")
public class MvelEndpoint extends ResourceEndpoint {
diff --git a/components/camel-mybatis/src/main/java/org/apache/camel/component/mybatis/MyBatisBeanEndpoint.java b/components/camel-mybatis/src/main/java/org/apache/camel/component/mybatis/MyBatisBeanEndpoint.java
index 48a271f..bd15252 100644
--- a/components/camel-mybatis/src/main/java/org/apache/camel/component/mybatis/MyBatisBeanEndpoint.java
+++ b/components/camel-mybatis/src/main/java/org/apache/camel/component/mybatis/MyBatisBeanEndpoint.java
@@ -25,7 +25,7 @@ import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriPath;
/**
- * Performs a query, insert, update or delete in a relational database using MyBatis.
+ * Perform queries, inserts, updates or deletes in a relational database using MyBatis.
*/
@UriEndpoint(firstVersion = "2.22.0", scheme = "mybatis-bean", title = "MyBatis Bean", syntax = "mybatis-bean:beanName:methodName", producerOnly = true, label = "database,sql")
public class MyBatisBeanEndpoint extends BaseMyBatisEndpoint {
diff --git a/components/camel-nagios/src/main/java/org/apache/camel/component/nagios/NagiosEndpoint.java b/components/camel-nagios/src/main/java/org/apache/camel/component/nagios/NagiosEndpoint.java
index a00170a..f18bc6b 100644
--- a/components/camel-nagios/src/main/java/org/apache/camel/component/nagios/NagiosEndpoint.java
+++ b/components/camel-nagios/src/main/java/org/apache/camel/component/nagios/NagiosEndpoint.java
@@ -29,7 +29,7 @@ import org.apache.camel.support.DefaultEndpoint;
import org.apache.camel.util.ObjectHelper;
/**
- * To send passive checks to Nagios using JSendNSCA.
+ * Send passive checks to Nagios using JSendNSCA.
*/
@UriEndpoint(firstVersion = "2.3.0", scheme = "nagios", title = "Nagios", syntax = "nagios:host:port", producerOnly = true, label = "monitoring")
public class NagiosEndpoint extends DefaultEndpoint {
diff --git a/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsEndpoint.java b/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsEndpoint.java
index 8f74250..6cef10b 100644
--- a/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsEndpoint.java
+++ b/components/camel-nats/src/main/java/org/apache/camel/component/nats/NatsEndpoint.java
@@ -34,14 +34,14 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.support.DefaultEndpoint;
/**
- * The nats component allows you produce and consume messages from <a href="http://nats.io/">NATS</a>.
+ * Send and receive messages from <a href="http://nats.io/">NATS</a> messaging system.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "nats", title = "Nats", syntax = "nats:topic", label = "messaging")
public class NatsEndpoint extends DefaultEndpoint {
@UriParam
private NatsConfiguration configuration;
-
+
public NatsEndpoint(String uri, NatsComponent component, NatsConfiguration config) {
super(uri, component);
this.configuration = config;
@@ -58,15 +58,15 @@ public class NatsEndpoint extends DefaultEndpoint {
configureConsumer(consumer);
return consumer;
}
-
+
public ExecutorService createExecutor() {
return getCamelContext().getExecutorServiceManager().newFixedThreadPool(this, "NatsTopic[" + configuration.getTopic() + "]", configuration.getPoolSize());
}
-
+
public NatsConfiguration getConfiguration() {
return configuration;
}
-
+
public Connection getConnection() throws InterruptedException, IllegalArgumentException, GeneralSecurityException, IOException {
Builder builder = getConfiguration().createOptions();
if (getConfiguration().getSslContextParameters() != null && getConfiguration().isSecure()) {
diff --git a/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/NettyHttpEndpoint.java b/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/NettyHttpEndpoint.java
index b3f3492..6c985ff 100644
--- a/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/NettyHttpEndpoint.java
+++ b/components/camel-netty-http/src/main/java/org/apache/camel/component/netty/http/NettyHttpEndpoint.java
@@ -42,7 +42,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * Netty HTTP server and client using the Netty 4.x library.
+ * Netty HTTP server and client using the Netty 4.x.
*/
@UriEndpoint(firstVersion = "2.14.0", scheme = "netty-http", extendsScheme = "netty", title = "Netty HTTP",
syntax = "netty-http:protocol:host:port/path", label = "http", lenientProperties = true)
diff --git a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java
index 5f0fd97..b81bac0 100644
--- a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java
+++ b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java
@@ -38,7 +38,7 @@ import org.apache.camel.support.SynchronousDelegateProducer;
import org.apache.camel.util.ObjectHelper;
/**
- * Socket level networking using TCP or UDP with the Netty 4.x library.
+ * Socket level networking using TCP or UDP with the Netty 4.x.
*/
@UriEndpoint(firstVersion = "2.14.0", scheme = "netty", title = "Netty", syntax = "netty:protocol:host:port", label = "networking,tcp,udp")
public class NettyEndpoint extends DefaultEndpoint implements AsyncEndpoint {
diff --git a/components/camel-nitrite/src/main/java/org/apache/camel/component/nitrite/NitriteEndpoint.java b/components/camel-nitrite/src/main/java/org/apache/camel/component/nitrite/NitriteEndpoint.java
index 54b4e9f..df5d03c 100644
--- a/components/camel-nitrite/src/main/java/org/apache/camel/component/nitrite/NitriteEndpoint.java
+++ b/components/camel-nitrite/src/main/java/org/apache/camel/component/nitrite/NitriteEndpoint.java
@@ -28,7 +28,7 @@ import org.dizitart.no2.Nitrite;
import org.dizitart.no2.PersistentCollection;
/**
- * Used for integrating Camel with Nitrite databases.
+ * Access Nitrite databases.
*/
@UriEndpoint(firstVersion = "3.0.0", scheme = "nitrite", title = "Nitrite", syntax = "nitrite:database",
label = "database,nosql")
diff --git a/components/camel-nsq/src/main/java/org/apache/camel/component/nsq/NsqEndpoint.java b/components/camel-nsq/src/main/java/org/apache/camel/component/nsq/NsqEndpoint.java
index 829b191..9bc8c99 100644
--- a/components/camel-nsq/src/main/java/org/apache/camel/component/nsq/NsqEndpoint.java
+++ b/components/camel-nsq/src/main/java/org/apache/camel/component/nsq/NsqEndpoint.java
@@ -33,7 +33,7 @@ import org.apache.camel.support.DefaultEndpoint;
import org.apache.camel.util.ObjectHelper;
/**
- * Represents a nsq endpoint.
+ * Send and receive messages from NSQ realtime distributed messaging platform.
*/
@UriEndpoint(firstVersion = "2.23.0", scheme = "nsq", title = "NSQ", syntax = "nsq:topic", label = "messaging")
public class NsqEndpoint extends DefaultEndpoint {
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 67e34f4..7bbec71 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
@@ -36,7 +36,7 @@ import org.apache.camel.support.component.ApiMethod;
import org.apache.camel.support.component.ApiMethodPropertiesHelper;
/**
- * Communicates with OData 2.0 services using Apache Olingo.
+ * Communicate with OData 2.0 services using Apache Olingo.
*/
@UriEndpoint(firstVersion = "2.14.0", scheme = "olingo2", title = "Olingo2", syntax = "olingo2:apiName/methodName", label = "cloud")
public class Olingo2Endpoint extends AbstractApiEndpoint<Olingo2ApiName, Olingo2Configuration> {
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 71a1dc3..400f6fd 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
@@ -36,7 +36,7 @@ import org.apache.camel.support.component.ApiMethod;
import org.apache.camel.support.component.ApiMethodPropertiesHelper;
/**
- * Communicates with OData 4.0 services using Apache Olingo OData API.
+ * Communicate with OData 4.0 services using Apache Olingo OData API.
*/
@UriEndpoint(firstVersion = "2.19.0", scheme = "olingo4", title = "Olingo4", syntax = "olingo4:apiName/methodName", label = "cloud")
public class Olingo4Endpoint extends AbstractApiEndpoint<Olingo4ApiName, Olingo4Configuration> {
diff --git a/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/cinder/CinderEndpoint.java b/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/cinder/CinderEndpoint.java
index 55a9fd7..7172efa 100644
--- a/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/cinder/CinderEndpoint.java
+++ b/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/cinder/CinderEndpoint.java
@@ -27,7 +27,7 @@ import org.apache.camel.spi.UriPath;
import org.openstack4j.core.transport.Config;
/**
- * The openstack-cinder component allows messages to be sent to an OpenStack block storage services.
+ * Access data in OpenStack Cinder block storage.
*/
@UriEndpoint(firstVersion = "2.19.0", scheme = "openstack-cinder", title = "OpenStack Cinder", syntax = "openstack-cinder:host", label = "cloud,paas", producerOnly = true)
public class CinderEndpoint extends AbstractOpenstackEndpoint {
diff --git a/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/glance/GlanceEndpoint.java b/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/glance/GlanceEndpoint.java
index 3055335..53c6076 100644
--- a/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/glance/GlanceEndpoint.java
+++ b/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/glance/GlanceEndpoint.java
@@ -25,7 +25,7 @@ import org.apache.camel.spi.UriPath;
import org.openstack4j.core.transport.Config;
/**
- * The openstack-glance component allows messages to be sent to an OpenStack image services.
+ * Manage VM images and metadata definitions in OpenStack Glance.
*/
@UriEndpoint(firstVersion = "2.19.0", scheme = "openstack-glance", title = "OpenStack Glance", syntax = "openstack-glance:host", label = "cloud,paas", producerOnly = true)
public class GlanceEndpoint extends AbstractOpenstackEndpoint {
diff --git a/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/keystone/KeystoneEndpoint.java b/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/keystone/KeystoneEndpoint.java
index 2e973c0..b55aefa 100644
--- a/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/keystone/KeystoneEndpoint.java
+++ b/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/keystone/KeystoneEndpoint.java
@@ -30,7 +30,7 @@ import org.apache.camel.spi.UriPath;
import org.openstack4j.core.transport.Config;
/**
- * The openstack-keystone component allows messages to be sent to an OpenStack identity services.
+ * Access OpenStack Keystone for API client authentication, service discovery and distributed multi-tenant authorization.
*/
@UriEndpoint(firstVersion = "2.19.0", scheme = "openstack-keystone", title = "OpenStack Keystone", syntax = "openstack-keystone:host", label = "cloud,paas", producerOnly = true)
public class KeystoneEndpoint extends AbstractOpenstackEndpoint {
diff --git a/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/neutron/NeutronEndpoint.java b/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/neutron/NeutronEndpoint.java
index 54a6b07..e65b8ab 100644
--- a/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/neutron/NeutronEndpoint.java
+++ b/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/neutron/NeutronEndpoint.java
@@ -29,7 +29,7 @@ import org.apache.camel.spi.UriPath;
import org.openstack4j.core.transport.Config;
/**
- * The openstack-neutron component allows messages to be sent to an OpenStack network services.
+ * Access OpenStack Neutron for network services.
*/
@UriEndpoint(firstVersion = "2.19.0", scheme = "openstack-neutron", title = "OpenStack Neutron", syntax = "openstack-neutron:host", label = "cloud,paas", producerOnly = true)
public class NeutronEndpoint extends AbstractOpenstackEndpoint {
diff --git a/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/nova/NovaEndpoint.java b/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/nova/NovaEndpoint.java
index 12d2690..9c7142a 100644
--- a/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/nova/NovaEndpoint.java
+++ b/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/nova/NovaEndpoint.java
@@ -28,7 +28,7 @@ import org.apache.camel.spi.UriPath;
import org.openstack4j.core.transport.Config;
/**
- * The openstack-nova component allows messages to be sent to an OpenStack compute services.
+ * Access OpenStack to manage compute resources.
*/
@UriEndpoint(firstVersion = "2.19.0", scheme = "openstack-nova", title = "OpenStack Nova", syntax = "openstack-nova:host", label = "cloud,paas", producerOnly = true)
public class NovaEndpoint extends AbstractOpenstackEndpoint {
diff --git a/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/swift/SwiftEndpoint.java b/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/swift/SwiftEndpoint.java
index f2b942b..2ba18cb 100644
--- a/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/swift/SwiftEndpoint.java
+++ b/components/camel-openstack/src/main/java/org/apache/camel/component/openstack/swift/SwiftEndpoint.java
@@ -27,7 +27,7 @@ import org.apache.camel.spi.UriPath;
import org.openstack4j.core.transport.Config;
/**
- * The openstack-swift component allows messages to be sent to an OpenStack object storage services.
+ * Access OpenStack Swift object/blob store.
*/
@UriEndpoint(firstVersion = "2.19.0", scheme = "openstack-swift", title = "OpenStack Swift", syntax = "openstack-swift:host", label = "cloud,paas", producerOnly = true)
public class SwiftEndpoint extends AbstractOpenstackEndpoint {
diff --git a/components/camel-optaplanner/src/main/java/org/apache/camel/component/optaplanner/OptaPlannerEndpoint.java b/components/camel-optaplanner/src/main/java/org/apache/camel/component/optaplanner/OptaPlannerEndpoint.java
index 894898f..2701bea 100644
--- a/components/camel-optaplanner/src/main/java/org/apache/camel/component/optaplanner/OptaPlannerEndpoint.java
+++ b/components/camel-optaplanner/src/main/java/org/apache/camel/component/optaplanner/OptaPlannerEndpoint.java
@@ -30,7 +30,7 @@ import org.optaplanner.core.api.solver.Solver;
import org.optaplanner.core.api.solver.SolverFactory;
/**
- * Solves the planning problem contained in a message with OptaPlanner.
+ * Solve planning problems with OptaPlanner.
*/
@UriEndpoint(firstVersion = "2.13.0", scheme = "optaplanner", title = "OptaPlanner", syntax = "optaplanner:configFile", label = "engine,planning")
public class OptaPlannerEndpoint extends DefaultEndpoint {
diff --git a/components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoEndpoint.java b/components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoEndpoint.java
index 8994e18..1156fc5 100644
--- a/components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoEndpoint.java
+++ b/components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoEndpoint.java
@@ -34,7 +34,7 @@ import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
import org.eclipse.paho.client.mqttv3.persist.MqttDefaultFilePersistence;
/**
- * Component for communicating with MQTT message brokers using Eclipse Paho MQTT Client.
+ * Communicate with MQTT message brokers using Eclipse Paho MQTT Client.
*/
@UriEndpoint(firstVersion = "2.16.0", scheme = "paho", title = "Paho", label = "messaging,iot", syntax = "paho:topic")
public class PahoEndpoint extends DefaultEndpoint {
diff --git a/components/camel-pdf/src/main/java/org/apache/camel/component/pdf/PdfEndpoint.java b/components/camel-pdf/src/main/java/org/apache/camel/component/pdf/PdfEndpoint.java
index db6a230..9087c44 100644
--- a/components/camel-pdf/src/main/java/org/apache/camel/component/pdf/PdfEndpoint.java
+++ b/components/camel-pdf/src/main/java/org/apache/camel/component/pdf/PdfEndpoint.java
@@ -25,7 +25,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.support.DefaultEndpoint;
/**
- * The pdf components provides the ability to create, modify or extract content from PDF documents.
+ * Create, modify or extract content from PDF documents.
*/
@UriEndpoint(firstVersion = "2.16.0", scheme = "pdf", title = "PDF", syntax = "pdf:operation", producerOnly = true, label = "document,transformation,printing")
public class PdfEndpoint extends DefaultEndpoint {
diff --git a/components/camel-pg-replication-slot/src/main/java/org/apache/camel/component/pg/replication/slot/PgReplicationSlotEndpoint.java b/components/camel-pg-replication-slot/src/main/java/org/apache/camel/component/pg/replication/slot/PgReplicationSlotEndpoint.java
index 6858b17..4996f1d 100644
--- a/components/camel-pg-replication-slot/src/main/java/org/apache/camel/component/pg/replication/slot/PgReplicationSlotEndpoint.java
+++ b/components/camel-pg-replication-slot/src/main/java/org/apache/camel/component/pg/replication/slot/PgReplicationSlotEndpoint.java
@@ -39,7 +39,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * Consumer endpoint to receive from PostgreSQL Replication Slot.
+ * Poll for PostgreSQL Write-Ahead Log (WAL) records using Streaming Replication Slots.
*/
@UriEndpoint(firstVersion = "3.0.0", scheme = "pg-replication-slot", title = "PostgresSQL Replication Slot",
syntax = "pg-replication-slot:host:port/database/slot:outputPlugin", label = "database,sql", consumerOnly = true)
diff --git a/components/camel-pgevent/src/main/java/org/apache/camel/component/pgevent/PgEventEndpoint.java b/components/camel-pgevent/src/main/java/org/apache/camel/component/pgevent/PgEventEndpoint.java
index 80916c9..426d802 100644
--- a/components/camel-pgevent/src/main/java/org/apache/camel/component/pgevent/PgEventEndpoint.java
+++ b/components/camel-pgevent/src/main/java/org/apache/camel/component/pgevent/PgEventEndpoint.java
@@ -35,7 +35,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The pgevent component allows for producing/consuming PostgreSQL events related to the listen/notify commands.
+ * Send and receive PostgreSQL events via LISTEN and NOTIFY commands.
* <p/>
* This requires using PostgreSQL 8.3 or newer.
*/
diff --git a/components/camel-platform-http/src/main/java/org/apache/camel/component/platform/http/PlatformHttpEndpoint.java b/components/camel-platform-http/src/main/java/org/apache/camel/component/platform/http/PlatformHttpEndpoint.java
index b3b721a..dc2c730 100644
--- a/components/camel-platform-http/src/main/java/org/apache/camel/component/platform/http/PlatformHttpEndpoint.java
+++ b/components/camel-platform-http/src/main/java/org/apache/camel/component/platform/http/PlatformHttpEndpoint.java
@@ -32,6 +32,9 @@ import org.apache.camel.support.DefaultConsumer;
import org.apache.camel.support.DefaultEndpoint;
import org.apache.camel.support.service.ServiceHelper;
+/**
+ * Expose HTTP endpoints using the HTTP server available in the current platform.
+ */
@UriEndpoint(firstVersion = "3.0.0", scheme = "platform-http", title = "Platform HTTP", syntax = "platform-http:path", label = "http", consumerOnly = true)
public class PlatformHttpEndpoint extends DefaultEndpoint implements AsyncEndpoint, HeaderFilterStrategyAware {
diff --git a/components/camel-printer/src/main/java/org/apache/camel/component/printer/PrinterEndpoint.java b/components/camel-printer/src/main/java/org/apache/camel/component/printer/PrinterEndpoint.java
index 2b1e3cb..fd47bfc 100644
--- a/components/camel-printer/src/main/java/org/apache/camel/component/printer/PrinterEndpoint.java
+++ b/components/camel-printer/src/main/java/org/apache/camel/component/printer/PrinterEndpoint.java
@@ -25,7 +25,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.support.DefaultEndpoint;
/**
- * The printer component is used for sending messages to printers as print jobs.
+ * Send print jobs to printers.
*
* Obviously the payload has to be a formatted piece of payload in order for the component to appropriately print it.
* The objective is to be able to direct specific payloads as jobs to a line printer in a camel flow.
@@ -35,7 +35,7 @@ import org.apache.camel.support.DefaultEndpoint;
*/
@UriEndpoint(firstVersion = "2.1.0", scheme = "lpr", title = "Printer", syntax = "lpr:hostname:port/printername", producerOnly = true, label = "printing")
public class PrinterEndpoint extends DefaultEndpoint {
-
+
public static final String JOB_NAME = "PrinterJobName";
@UriParam
@@ -65,6 +65,6 @@ public class PrinterEndpoint extends DefaultEndpoint {
public void setConfig(PrinterConfiguration config) {
this.config = config;
- }
+ }
}
diff --git a/components/camel-pubnub/src/main/java/org/apache/camel/component/pubnub/PubNubEndpoint.java b/components/camel-pubnub/src/main/java/org/apache/camel/component/pubnub/PubNubEndpoint.java
index 45ccc7c..84f256d 100644
--- a/components/camel-pubnub/src/main/java/org/apache/camel/component/pubnub/PubNubEndpoint.java
+++ b/components/camel-pubnub/src/main/java/org/apache/camel/component/pubnub/PubNubEndpoint.java
@@ -27,7 +27,7 @@ import org.apache.camel.support.DefaultEndpoint;
import org.apache.camel.util.ObjectHelper;
/**
- * To send and receive messages to PubNub data stream network for connected devices.
+ * Send and receive messages to/from PubNub data stream network for connected devices.
*/
@UriEndpoint(firstVersion = "2.19.0", scheme = "pubnub", title = "PubNub", syntax = "pubnub:channel",
label = "cloud,iot,messaging")
diff --git a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarEndpoint.java b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarEndpoint.java
index d93781d..e0ae982 100644
--- a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarEndpoint.java
+++ b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarEndpoint.java
@@ -27,6 +27,9 @@ import org.apache.camel.support.DefaultEndpoint;
import org.apache.camel.util.ObjectHelper;
import org.apache.pulsar.client.api.PulsarClient;
+/**
+ * Send and receive messages from/to Apache Pulsar messaging system.
+ */
@UriEndpoint(scheme = "pulsar", firstVersion = "2.24.0", title = "Pulsar", syntax = "pulsar:persistence://tenant/namespace/topic", label = "messaging")
public class PulsarEndpoint extends DefaultEndpoint {
diff --git a/components/camel-quartz/src/main/java/org/apache/camel/component/quartz/QuartzEndpoint.java b/components/camel-quartz/src/main/java/org/apache/camel/component/quartz/QuartzEndpoint.java
index 923fc19..c802b65 100644
--- a/components/camel-quartz/src/main/java/org/apache/camel/component/quartz/QuartzEndpoint.java
+++ b/components/camel-quartz/src/main/java/org/apache/camel/component/quartz/QuartzEndpoint.java
@@ -54,7 +54,7 @@ import static org.quartz.CronScheduleBuilder.cronSchedule;
import static org.quartz.SimpleScheduleBuilder.simpleSchedule;
/**
- * Provides a scheduled delivery of messages using the Quartz 2.x scheduler.
+ * Schedule sending of messages using the Quartz 2.x scheduler.
*/
@UriEndpoint(firstVersion = "2.12.0", scheme = "quartz", title = "Quartz", syntax = "quartz:groupName/triggerName", consumerOnly = true, label = "scheduling")
public class QuartzEndpoint extends DefaultEndpoint {
diff --git a/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEndpoint.java b/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEndpoint.java
index 4b57cd0..f1061d5 100644
--- a/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEndpoint.java
+++ b/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEndpoint.java
@@ -38,7 +38,7 @@ import quickfix.Message;
import quickfix.SessionID;
/**
- * The quickfix component allows to send Financial Interchange (FIX) messages to the QuickFix engine.
+ * Open a Financial Interchange (FIX) session using an embedded QuickFix/J engine.
*/
@UriEndpoint(firstVersion = "2.1.0", scheme = "quickfix", title = "QuickFix", syntax = "quickfix:configurationName", label = "messaging")
public class QuickfixjEndpoint extends DefaultEndpoint implements QuickfixjEventListener, MultipleConsumersSupport {
@@ -141,7 +141,7 @@ public class QuickfixjEndpoint extends DefaultEndpoint implements QuickfixjEvent
&& isMatching(this.sessionID.getSenderSubID(), sessionID.getSenderSubID())
&& isMatching(this.sessionID.getSenderLocationID(), sessionID.getSenderLocationID())
&& isMatching(this.sessionID.getTargetCompID(), sessionID.getTargetCompID())
- && isMatching(this.sessionID.getTargetSubID(), sessionID.getTargetSubID())
+ && isMatching(this.sessionID.getTargetSubID(), sessionID.getTargetSubID())
&& isMatching(this.sessionID.getTargetLocationID(), sessionID.getTargetLocationID());
}
@@ -184,7 +184,7 @@ public class QuickfixjEndpoint extends DefaultEndpoint implements QuickfixjEvent
public QuickfixjEngine getEngine() {
return engine;
}
-
+
@Override
protected void doStop() throws Exception {
// clear list of consumers
diff --git a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java
index 4f9a76e..7171757 100644
--- a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java
+++ b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQEndpoint.java
@@ -50,8 +50,7 @@ import static org.apache.camel.component.rabbitmq.RabbitMQComponent.EXCHANGE_ARG
import static org.apache.camel.component.rabbitmq.RabbitMQComponent.QUEUE_ARG_PREFIX;
/**
- * The rabbitmq component allows you produce and consume messages from
- * <a href="http://www.rabbitmq.com/">RabbitMQ</a> instances.
+ * Send and receive messages from <a href="http://www.rabbitmq.com/">RabbitMQ</a> instances.
*/
@UriEndpoint(firstVersion = "2.12.0", scheme = "rabbitmq", title = "RabbitMQ", syntax = "rabbitmq:exchangeName", label = "messaging")
public class RabbitMQEndpoint extends DefaultEndpoint implements AsyncEndpoint {
diff --git a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsEndpoint.java b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsEndpoint.java
index 34c77d3..b7c8da5 100644
--- a/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsEndpoint.java
+++ b/components/camel-reactive-streams/src/main/java/org/apache/camel/component/reactive/streams/ReactiveStreamsEndpoint.java
@@ -28,7 +28,7 @@ import org.apache.camel.spi.UriPath;
import org.apache.camel.support.DefaultEndpoint;
/**
- * Reactive Camel using reactive streams
+ * Exchange messages with reactive stream processing libraries compatible with the reactive streams standard.
*/
@UriEndpoint(firstVersion = "2.19.0", scheme = "reactive-streams", title = "Reactive Streams", syntax = "reactive-streams:stream",
label = "reactive,streams")
diff --git a/components/camel-ref/src/main/java/org/apache/camel/component/ref/RefEndpoint.java b/components/camel-ref/src/main/java/org/apache/camel/component/ref/RefEndpoint.java
index a04e35b..6d35cad 100644
--- a/components/camel-ref/src/main/java/org/apache/camel/component/ref/RefEndpoint.java
+++ b/components/camel-ref/src/main/java/org/apache/camel/component/ref/RefEndpoint.java
@@ -29,7 +29,7 @@ import org.apache.camel.support.CamelContextHelper;
import org.apache.camel.support.DefaultEndpoint;
/**
- * The ref component is used for lookup of existing endpoints bound in the Registry.
+ * Route messages to an endpoint looked up dynamically by name in the Camel Registry.
*/
@UriEndpoint(firstVersion = "1.2.0", scheme = "ref", title = "Ref", syntax = "ref:name", label = "core,endpoint")
public class RefEndpoint extends DefaultEndpoint implements DelegateEndpoint {
diff --git a/components/camel-rest-openapi/src/main/java/org/apache/camel/component/rest/openapi/RestOpenApiEndpoint.java b/components/camel-rest-openapi/src/main/java/org/apache/camel/component/rest/openapi/RestOpenApiEndpoint.java
index 4263621..2cc087e 100644
--- a/components/camel-rest-openapi/src/main/java/org/apache/camel/component/rest/openapi/RestOpenApiEndpoint.java
+++ b/components/camel-rest-openapi/src/main/java/org/apache/camel/component/rest/openapi/RestOpenApiEndpoint.java
@@ -86,7 +86,8 @@ import static org.apache.camel.util.StringHelper.before;
import static org.apache.camel.util.StringHelper.notEmpty;
/**
- * An awesome REST endpoint backed by OpenApi specifications.
+ * Configure REST producers based on an OpenAPI specification document delegating to a component implementing the
+ * RestProducerFactory interface.
*/
@UriEndpoint(firstVersion = "3.1.0", scheme = "rest-openapi", title = "REST OpenApi",
syntax = "rest-openapi:specificationUri#operationId", label = "rest,openapi,http", producerOnly = true)
diff --git a/components/camel-rest-swagger/src/main/java/org/apache/camel/component/rest/swagger/RestSwaggerEndpoint.java b/components/camel-rest-swagger/src/main/java/org/apache/camel/component/rest/swagger/RestSwaggerEndpoint.java
index 8883adb..d6a5311 100644
--- a/components/camel-rest-swagger/src/main/java/org/apache/camel/component/rest/swagger/RestSwaggerEndpoint.java
+++ b/components/camel-rest-swagger/src/main/java/org/apache/camel/component/rest/swagger/RestSwaggerEndpoint.java
@@ -76,7 +76,8 @@ import static org.apache.camel.util.ObjectHelper.notNull;
import static org.apache.camel.util.StringHelper.*;
/**
- * An awesome REST endpoint backed by Swagger specifications.
+ * Configure REST producers based on a Swagger (OpenAPI) specification document delegating to a component implementing the
+ * RestProducerFactory interface.
*/
@UriEndpoint(firstVersion = "2.19.0", scheme = "rest-swagger", title = "REST Swagger",
syntax = "rest-swagger:specificationUri#operationId", label = "rest,swagger,http", producerOnly = true)
diff --git a/components/camel-rest/src/main/java/org/apache/camel/component/rest/RestApiEndpoint.java b/components/camel-rest/src/main/java/org/apache/camel/component/rest/RestApiEndpoint.java
index 73b5009..a486685 100644
--- a/components/camel-rest/src/main/java/org/apache/camel/component/rest/RestApiEndpoint.java
+++ b/components/camel-rest/src/main/java/org/apache/camel/component/rest/RestApiEndpoint.java
@@ -40,7 +40,7 @@ import org.apache.camel.util.HostUtils;
import org.apache.camel.util.ObjectHelper;
/**
- * The rest-api component is used for providing Swagger API of the REST services which has been defined using the rest-dsl in Camel.
+ * Expose OpenAPI Specification of the REST services defined using Camel REST DSL.
*/
@UriEndpoint(firstVersion = "2.16.0", scheme = "rest-api", title = "REST API", syntax = "rest-api:path/contextIdPattern",
consumerOnly = true, label = "core,rest", lenientProperties = true)
diff --git a/components/camel-rest/src/main/java/org/apache/camel/component/rest/RestEndpoint.java b/components/camel-rest/src/main/java/org/apache/camel/component/rest/RestEndpoint.java
index 0dfbe67..a87fd50 100644
--- a/components/camel-rest/src/main/java/org/apache/camel/component/rest/RestEndpoint.java
+++ b/components/camel-rest/src/main/java/org/apache/camel/component/rest/RestEndpoint.java
@@ -46,7 +46,7 @@ import org.slf4j.LoggerFactory;
import static org.apache.camel.support.RestProducerFactoryHelper.setupComponent;
/**
- * The rest component is used for either hosting REST services (consumer) or calling external REST services (producer).
+ * Expose REST services or call external REST services.
*/
@UriEndpoint(firstVersion = "2.14.0", scheme = "rest", title = "REST", syntax = "rest:method:path:uriTemplate", label = "core,rest", lenientProperties = true)
public class RestEndpoint extends DefaultEndpoint {
diff --git a/components/camel-robotframework/src/main/java/org/apache/camel/component/robotframework/RobotFrameworkEndpoint.java b/components/camel-robotframework/src/main/java/org/apache/camel/component/robotframework/RobotFrameworkEndpoint.java
index 417fee3..6e18f4e 100644
--- a/components/camel-robotframework/src/main/java/org/apache/camel/component/robotframework/RobotFrameworkEndpoint.java
+++ b/components/camel-robotframework/src/main/java/org/apache/camel/component/robotframework/RobotFrameworkEndpoint.java
@@ -29,7 +29,7 @@ import org.apache.camel.util.ObjectHelper;
import org.robotframework.RobotFramework;
/**
- * Represents a RobotFramework endpoint.
+ * Pass camel exchanges to acceptence test written in Robot DSL.
*/
@UriEndpoint(firstVersion = "3.0.0", scheme = "robotframework", title = "Robot Framework", syntax = "robotframework:resourceUri", label = "testing")
public class RobotFrameworkEndpoint extends ResourceEndpoint {
@@ -120,7 +120,7 @@ public class RobotFrameworkEndpoint extends ResourceEndpoint {
String path = getResourceUri();
ObjectHelper.notNull(path, "resourceUri");
log.debug("RobotFrameworkEndpoint resourceUri:{}", path);
-
+
String newResourceUri = exchange.getIn().getHeader(RobotFrameworkCamelConstants.CAMEL_ROBOT_RESOURCE_URI, String.class);
if (newResourceUri != null) {
exchange.getIn().removeHeader(RobotFrameworkCamelConstants.CAMEL_ROBOT_RESOURCE_URI);
@@ -138,7 +138,7 @@ public class RobotFrameworkEndpoint extends ResourceEndpoint {
// run robot framework
int camelRobotReturnCode = RobotFramework.run(generatedArguments.toArray());
-
+
exchange.getIn().setHeader(RobotFrameworkCamelConstants.CAMEL_ROBOT_RETURN_CODE, camelRobotReturnCode);
}
}
diff --git a/components/camel-rss/src/main/java/org/apache/camel/component/rss/RssEndpoint.java b/components/camel-rss/src/main/java/org/apache/camel/component/rss/RssEndpoint.java
index 7f8d807..db3d054 100644
--- a/components/camel-rss/src/main/java/org/apache/camel/component/rss/RssEndpoint.java
+++ b/components/camel-rss/src/main/java/org/apache/camel/component/rss/RssEndpoint.java
@@ -32,7 +32,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The rss component is used for consuming RSS feeds.
+ * Poll RSS feeds.
*/
@UriEndpoint(firstVersion = "2.0.0", scheme = "rss", extendsScheme = "atom", title = "RSS",
syntax = "rss:feedUri", consumerOnly = true, label = "rss", lenientProperties = true)
diff --git a/components/camel-saga/src/main/java/org/apache/camel/component/saga/SagaEndpoint.java b/components/camel-saga/src/main/java/org/apache/camel/component/saga/SagaEndpoint.java
index 6f79300..523906c 100644
--- a/components/camel-saga/src/main/java/org/apache/camel/component/saga/SagaEndpoint.java
+++ b/components/camel-saga/src/main/java/org/apache/camel/component/saga/SagaEndpoint.java
@@ -26,7 +26,7 @@ import org.apache.camel.support.DefaultEndpoint;
import org.apache.camel.util.ObjectHelper;
/**
- * The saga component provides access to advanced options for managing the flow in the Saga EIP.
+ * Execute custom actions within a route using the Saga EIP.
*/
@UriEndpoint(firstVersion = "2.21.0", scheme = "saga", title = "Saga", syntax = "saga:action", producerOnly = true, label = "core,endpoint")
public class SagaEndpoint extends DefaultEndpoint {
diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceEndpoint.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceEndpoint.java
index 3b936f6..21821c8 100644
--- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceEndpoint.java
+++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceEndpoint.java
@@ -31,8 +31,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The salesforce component is used for integrating Camel with the massive
- * Salesforce API.
+ * Communicate with Salesforce using Java DTOs.
*/
@UriEndpoint(firstVersion = "2.12.0", scheme = "salesforce", title = "Salesforce", syntax = "salesforce:operationName:topicName", label = "api,cloud,crm")
public class SalesforceEndpoint extends DefaultEndpoint {
diff --git a/components/camel-sap-netweaver/src/main/java/org/apache/camel/component/sap/netweaver/NetWeaverEndpoint.java b/components/camel-sap-netweaver/src/main/java/org/apache/camel/component/sap/netweaver/NetWeaverEndpoint.java
index 7011bbd..343ba5c 100644
--- a/components/camel-sap-netweaver/src/main/java/org/apache/camel/component/sap/netweaver/NetWeaverEndpoint.java
+++ b/components/camel-sap-netweaver/src/main/java/org/apache/camel/component/sap/netweaver/NetWeaverEndpoint.java
@@ -27,7 +27,7 @@ import org.apache.camel.spi.UriPath;
import org.apache.camel.support.DefaultEndpoint;
/**
- * The sap-netweaver component integrates with the SAP NetWeaver Gateway using HTTP transports.
+ * Send requests to SAP NetWeaver Gateway using HTTP.
*/
@UriEndpoint(firstVersion = "2.12.0", scheme = "sap-netweaver", title = "SAP NetWeaver", syntax = "sap-netweaver:url", producerOnly = true, label = "sap")
public class NetWeaverEndpoint extends DefaultEndpoint {
diff --git a/components/camel-saxon/src/main/java/org/apache/camel/component/xquery/XQueryEndpoint.java b/components/camel-saxon/src/main/java/org/apache/camel/component/xquery/XQueryEndpoint.java
index 7220be3..824c068 100644
--- a/components/camel-saxon/src/main/java/org/apache/camel/component/xquery/XQueryEndpoint.java
+++ b/components/camel-saxon/src/main/java/org/apache/camel/component/xquery/XQueryEndpoint.java
@@ -36,7 +36,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * Transforms the message using a XQuery template using Saxon.
+ * Query and/or transform XML payloads using XQuery and Saxon.
*/
@UriEndpoint(firstVersion = "1.0.0", scheme = "xquery", title = "XQuery", syntax = "xquery:resourceUri", label = "transformation")
public class XQueryEndpoint extends ProcessorEndpoint {
diff --git a/components/camel-scheduler/src/main/java/org/apache/camel/component/scheduler/SchedulerEndpoint.java b/components/camel-scheduler/src/main/java/org/apache/camel/component/scheduler/SchedulerEndpoint.java
index c51ef85..c085c7a 100644
--- a/components/camel-scheduler/src/main/java/org/apache/camel/component/scheduler/SchedulerEndpoint.java
+++ b/components/camel-scheduler/src/main/java/org/apache/camel/component/scheduler/SchedulerEndpoint.java
@@ -28,7 +28,7 @@ import org.apache.camel.spi.UriPath;
import org.apache.camel.support.ScheduledPollEndpoint;
/**
- * The scheduler component is used for generating message exchanges when a scheduler fires.
+ * Generate messages in specified intervals using <code>java.util.concurrent.ScheduledExecutorService</code>.
*
* This component is similar to the timer component, but it offers more functionality in terms of scheduling.
* Also this component uses JDK ScheduledExecutorService. Where as the timer uses a JDK Timer.
diff --git a/components/camel-schematron/src/main/java/org/apache/camel/component/schematron/SchematronEndpoint.java b/components/camel-schematron/src/main/java/org/apache/camel/component/schematron/SchematronEndpoint.java
index 3689388..f65c661 100644
--- a/components/camel-schematron/src/main/java/org/apache/camel/component/schematron/SchematronEndpoint.java
+++ b/components/camel-schematron/src/main/java/org/apache/camel/component/schematron/SchematronEndpoint.java
@@ -45,7 +45,7 @@ import static org.apache.camel.component.schematron.constant.Constants.LINE_NUMB
import static org.apache.camel.component.schematron.constant.Constants.SAXON_TRANSFORMER_FACTORY_CLASS_NAME;
/**
- * Validates the payload of a message using the Schematron Library.
+ * Validate XML payload using the Schematron Library.
*/
@UriEndpoint(firstVersion = "2.15.0", scheme = "schematron", title = "Schematron", syntax = "schematron:path", producerOnly = true, label = "validation")
public class SchematronEndpoint extends DefaultEndpoint {
diff --git a/components/camel-service/src/main/java/org/apache/camel/component/service/ServiceEndpoint.java b/components/camel-service/src/main/java/org/apache/camel/component/service/ServiceEndpoint.java
index 993853f..d6d0b93 100644
--- a/components/camel-service/src/main/java/org/apache/camel/component/service/ServiceEndpoint.java
+++ b/components/camel-service/src/main/java/org/apache/camel/component/service/ServiceEndpoint.java
@@ -37,7 +37,7 @@ import org.apache.camel.spi.UriPath;
import org.apache.camel.support.DefaultEndpoint;
/**
- * Represents an endpoint which is registered to a Service Registry such as Consul, Etcd.
+ * Register a Camel endpoint to a Service Registry (such as Consul, Etcd) and delegate to it.
*/
@ManagedResource(description = "Managed Service Endpoint")
@UriEndpoint(
@@ -98,7 +98,7 @@ public class ServiceEndpoint extends DefaultEndpoint implements DelegateEndpoint
@Override
public boolean isLenientProperties() {
return true;
- }
+ }
private ServiceDefinition computeServiceDefinition(CamelContext context, Endpoint delegateEndpoint) {
Map<String, String> parameters = new HashMap<>();
diff --git a/components/camel-servicenow/camel-servicenow-component/src/main/java/org/apache/camel/component/servicenow/ServiceNowEndpoint.java b/components/camel-servicenow/camel-servicenow-component/src/main/java/org/apache/camel/component/servicenow/ServiceNowEndpoint.java
index 590fd34..87957a5 100644
--- a/components/camel-servicenow/camel-servicenow-component/src/main/java/org/apache/camel/component/servicenow/ServiceNowEndpoint.java
+++ b/components/camel-servicenow/camel-servicenow-component/src/main/java/org/apache/camel/component/servicenow/ServiceNowEndpoint.java
@@ -28,7 +28,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The servicenow component is used to integrate Camel with <a href="http://www.servicenow.com/">ServiceNow</a> cloud services.
+ * Interact with <a href="http://www.servicenow.com/">ServiceNow</a> via its REST API.
*/
@UriEndpoint(firstVersion = "2.18.0", scheme = "servicenow", title = "ServiceNow", syntax = "servicenow:instanceName", producerOnly = true, label = "api,cloud,management")
public class ServiceNowEndpoint extends DefaultEndpoint {
diff --git a/components/camel-servlet/src/main/java/org/apache/camel/component/servlet/ServletEndpoint.java b/components/camel-servlet/src/main/java/org/apache/camel/component/servlet/ServletEndpoint.java
index 5a740f4..b000a3e 100644
--- a/components/camel-servlet/src/main/java/org/apache/camel/component/servlet/ServletEndpoint.java
+++ b/components/camel-servlet/src/main/java/org/apache/camel/component/servlet/ServletEndpoint.java
@@ -32,7 +32,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriPath;
/**
- * To use a HTTP Servlet as entry for Camel routes when running in a servlet container.
+ * Serve HTTP requests by a Servlet.
*/
@UriEndpoint(firstVersion = "2.0.0", scheme = "servlet", extendsScheme = "http", title = "Servlet",
syntax = "servlet:contextPath", consumerOnly = true, label = "http")
diff --git a/components/camel-sip/src/main/java/org/apache/camel/component/sip/SipEndpoint.java b/components/camel-sip/src/main/java/org/apache/camel/component/sip/SipEndpoint.java
index 9df22b0..2331464 100644
--- a/components/camel-sip/src/main/java/org/apache/camel/component/sip/SipEndpoint.java
+++ b/components/camel-sip/src/main/java/org/apache/camel/component/sip/SipEndpoint.java
@@ -25,7 +25,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.support.DefaultEndpoint;
/**
- * To send and receive messages using the SIP protocol (used in telco and mobile).
+ * Send and receive messages using the SIP protocol (used in telecommunications).
*/
@UriEndpoint(firstVersion = "2.5.0", scheme = "sip,sips", title = "SIP", syntax = "sip:uri", label = "mobile")
public class SipEndpoint extends DefaultEndpoint {
@@ -54,7 +54,7 @@ public class SipEndpoint extends DefaultEndpoint {
public Producer createProducer() throws Exception {
return new SipPublisher(this, configuration);
}
-
+
public SipConfiguration getConfiguration() {
return configuration;
}
diff --git a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsEndpoint.java b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsEndpoint.java
index 6ce8854..90c2ae4 100644
--- a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsEndpoint.java
+++ b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsEndpoint.java
@@ -58,7 +58,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The sjms component (simple jms) allows messages to be sent to (or consumed from) a JMS Queue or Topic (uses JMS 1.x API).
+ * Send and receive messages to/from a JMS Queue or Topic using plain JMS 1.x API.
*
* This component uses plain JMS API where as the jms component uses Spring JMS.
*/
@@ -570,8 +570,8 @@ public class SjmsEndpoint extends DefaultEndpoint implements AsyncEndpoint, Mult
/**
* Sets the reply to destination name used for InOut producer endpoints.
- * The type of the reply to destination can be determined by the starting
- * prefix (topic: or queue:) in its name.
+ * The type of the reply to destination can be determined by the starting
+ * prefix (topic: or queue:) in its name.
*/
public void setNamedReplyTo(String namedReplyTo) {
this.namedReplyTo = namedReplyTo;
diff --git a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/batch/SjmsBatchEndpoint.java b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/batch/SjmsBatchEndpoint.java
index 3c8536a..ed79517 100644
--- a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/batch/SjmsBatchEndpoint.java
+++ b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/batch/SjmsBatchEndpoint.java
@@ -44,7 +44,7 @@ import org.apache.camel.spi.UriPath;
import org.apache.camel.support.DefaultEndpoint;
/**
- * The sjms-batch component is a specialized for highly performant, transactional batch consumption from a JMS queue.
+ * Highly performant and transactional batch consumption of messages from a JMS queue.
*/
@UriEndpoint(firstVersion = "2.16.0", scheme = "sjms-batch", title = "Simple JMS Batch", syntax = "sjms-batch:destinationName",
label = "messaging", consumerOnly = true)
diff --git a/components/camel-sjms2/src/main/java/org/apache/camel/component/sjms2/Sjms2Endpoint.java b/components/camel-sjms2/src/main/java/org/apache/camel/component/sjms2/Sjms2Endpoint.java
index 8c62cc1..bb19be1 100644
--- a/components/camel-sjms2/src/main/java/org/apache/camel/component/sjms2/Sjms2Endpoint.java
+++ b/components/camel-sjms2/src/main/java/org/apache/camel/component/sjms2/Sjms2Endpoint.java
@@ -24,7 +24,7 @@ import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
/**
- * The sjms2 component (simple jms) allows messages to be sent to (or consumed from) a JMS Queue or Topic (uses JMS 2.x API).
+ * Send and receive messages to/from a JMS Queue or Topic using plain JMS 2.x API.
*
* This component uses plain JMS 2.x API where as the jms component uses Spring JMS.
*/
diff --git a/components/camel-slack/src/main/java/org/apache/camel/component/slack/SlackEndpoint.java b/components/camel-slack/src/main/java/org/apache/camel/component/slack/SlackEndpoint.java
index 77922f0..89bc10f 100644
--- a/components/camel-slack/src/main/java/org/apache/camel/component/slack/SlackEndpoint.java
+++ b/components/camel-slack/src/main/java/org/apache/camel/component/slack/SlackEndpoint.java
@@ -33,7 +33,7 @@ import org.apache.camel.util.ObjectHelper;
import org.apache.camel.util.json.JsonObject;
/**
- * The slack component allows you to send messages to Slack.
+ * Send and receive messages to/from Slack.
*/
@UriEndpoint(firstVersion = "2.16.0", scheme = "slack", title = "Slack", syntax = "slack:channel", label = "social")
public class SlackEndpoint extends ScheduledPollEndpoint {
@@ -168,7 +168,7 @@ public class SlackEndpoint extends ScheduledPollEndpoint {
public String getServerUrl() {
return serverUrl;
}
-
+
/**
* The Server URL of the Slack instance
*/
diff --git a/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppEndpoint.java b/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppEndpoint.java
index 9345997..f431883 100644
--- a/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppEndpoint.java
+++ b/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppEndpoint.java
@@ -30,7 +30,7 @@ import org.jsmpp.bean.DataSm;
import org.jsmpp.bean.DeliverSm;
/**
- * To send and receive SMS using a SMSC (Short Message Service Center).
+ * Send and receive SMS messages using a SMSC (Short Message Service Center).
*/
@UriEndpoint(firstVersion = "2.2.0", scheme = "smpp,smpps", title = "SMPP", syntax = "smpp:host:port",
label = "mobile", lenientProperties = true)
@@ -49,7 +49,7 @@ public class SmppEndpoint extends DefaultEndpoint {
protected String createEndpointUri() {
return getConnectionString();
}
-
+
@Override
public boolean isLenientProperties() {
return true;
@@ -76,7 +76,7 @@ public class SmppEndpoint extends DefaultEndpoint {
public Exchange createOnAcceptAlertNotificationExchange(AlertNotification alertNotification) {
return createOnAcceptAlertNotificationExchange(getExchangePattern(), alertNotification);
}
-
+
/**
* Create a new exchange for communicating with this endpoint from a SMSC
* with the specified {@link ExchangePattern} such as whether its going
@@ -103,7 +103,7 @@ public class SmppEndpoint extends DefaultEndpoint {
public Exchange createOnAcceptDeliverSmExchange(DeliverSm deliverSm) throws Exception {
return createOnAcceptDeliverSmExchange(getExchangePattern(), deliverSm);
}
-
+
/**
* Create a new exchange for communicating with this endpoint from a SMSC
* with the specified {@link ExchangePattern} such as whether its going
@@ -120,7 +120,7 @@ public class SmppEndpoint extends DefaultEndpoint {
exchange.setIn(getBinding().createSmppMessage(getCamelContext(), deliverSm));
return exchange;
}
-
+
/**
* Create a new exchange for communicating with this endpoint from a SMSC
*
@@ -131,7 +131,7 @@ public class SmppEndpoint extends DefaultEndpoint {
public Exchange createOnAcceptDataSm(DataSm dataSm, String smppMessageId) {
return createOnAcceptDataSm(getExchangePattern(), dataSm, smppMessageId);
}
-
+
/**
* Create a new exchange for communicating with this endpoint from a SMSC
* with the specified {@link ExchangePattern} such as whether its going
@@ -152,7 +152,7 @@ public class SmppEndpoint extends DefaultEndpoint {
/**
* Returns the connection string for the current connection which has the form:
* smpp://<user>@<host>:<port>
- *
+ *
* @return the connection string
*/
public String getConnectionString() {
@@ -164,7 +164,7 @@ public class SmppEndpoint extends DefaultEndpoint {
/**
* Returns the smpp configuration
- *
+ *
* @return the configuration
*/
public SmppConfiguration getConfiguration() {
diff --git a/components/camel-snmp/src/main/java/org/apache/camel/component/snmp/SnmpEndpoint.java b/components/camel-snmp/src/main/java/org/apache/camel/component/snmp/SnmpEndpoint.java
index 3c8340e..5bbd9d0 100644
--- a/components/camel-snmp/src/main/java/org/apache/camel/component/snmp/SnmpEndpoint.java
+++ b/components/camel-snmp/src/main/java/org/apache/camel/component/snmp/SnmpEndpoint.java
@@ -35,7 +35,7 @@ import org.snmp4j.mp.SnmpConstants;
import org.snmp4j.security.SecurityLevel;
/**
- * The snmp component gives you the ability to poll SNMP capable devices or receiving traps.
+ * Receive traps and poll SNMP (Simple Network Management Protocol) capable devices.
*/
@UriEndpoint(firstVersion = "2.1.0", scheme = "snmp", title = "SNMP", syntax = "snmp:host:port", label = "monitoring")
public class SnmpEndpoint extends DefaultPollingEndpoint {
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 7949926..b005fbd 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
@@ -34,7 +34,7 @@ import org.apache.solr.client.solrj.impl.ConcurrentUpdateSolrClient;
import org.apache.solr.client.solrj.impl.HttpSolrClient;
/**
- * The solr component allows you to interface with an Apache Lucene Solr server.
+ * Perform operations against Apache Lucene Solr.
*/
@UriEndpoint(firstVersion = "2.9.0", scheme = "solr,solrs,solrCloud", title = "Solr", syntax = "solr:url", producerOnly = true, label = "monitoring,search")
public class SolrEndpoint extends DefaultEndpoint {
@@ -142,7 +142,7 @@ public class SolrEndpoint extends DefaultEndpoint {
}
if (connectionTimeout != null) {
solrServerBuilder.withConnectionTimeout(connectionTimeout);
- }
+ }
HttpSolrClient solrServer = solrServerBuilder.build();
// set the properties on the solr server
diff --git a/components/camel-soroush/src/main/java/org/apache/camel/component/soroushbot/component/SoroushBotEndpoint.java b/components/camel-soroush/src/main/java/org/apache/camel/component/soroushbot/component/SoroushBotEndpoint.java
index 030d241..a637cca 100644
--- a/components/camel-soroush/src/main/java/org/apache/camel/component/soroushbot/component/SoroushBotEndpoint.java
+++ b/components/camel-soroush/src/main/java/org/apache/camel/component/soroushbot/component/SoroushBotEndpoint.java
@@ -53,7 +53,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * To integrate with the Soroush chat bot.
+ * Send and receive messages as a Soroush chat bot.
*/
@UriEndpoint(firstVersion = "3.0", scheme = "soroush", title = "Soroush", syntax = "soroush:action", label = "chat")
public class SoroushBotEndpoint extends DefaultEndpoint {
diff --git a/components/camel-spark/src/main/java/org/apache/camel/component/spark/SparkEndpoint.java b/components/camel-spark/src/main/java/org/apache/camel/component/spark/SparkEndpoint.java
index 83689a9..5b76a64 100644
--- a/components/camel-spark/src/main/java/org/apache/camel/component/spark/SparkEndpoint.java
+++ b/components/camel-spark/src/main/java/org/apache/camel/component/spark/SparkEndpoint.java
@@ -32,7 +32,7 @@ import org.slf4j.Logger;
import static org.slf4j.LoggerFactory.getLogger;
/**
- * The spark component can be used to send RDD or DataFrame jobs to Apache Spark cluster.
+ * Send RDD or DataFrame jobs to Apache Spark clusters.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "spark", title = "Spark", syntax = "spark:endpointType",
producerOnly = true, label = "bigdata,iot")
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 b6d83f3..2498aa6 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
@@ -33,7 +33,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The splunk component allows to publish or search for events in Splunk.
+ * Publish or search for events in Splunk.
*/
@UriEndpoint(firstVersion = "2.13.0", scheme = "splunk", title = "Splunk", syntax = "splunk:name", label = "log,monitoring")
public class SplunkEndpoint extends ScheduledPollEndpoint {
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 e15553e..453e1eb 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
@@ -33,7 +33,7 @@ import org.springframework.batch.core.configuration.JobRegistry;
import org.springframework.batch.core.launch.JobLauncher;
/**
- * The spring-batch component allows to send messages to Spring Batch for further processing.
+ * Send messages to Spring Batch for further processing.
*/
@UriEndpoint(firstVersion = "2.10.0", scheme = "spring-batch", title = "Spring Batch", syntax = "spring-batch:jobName", producerOnly = true, label = "spring,batch,scheduling")
public class SpringBatchEndpoint extends DefaultEndpoint {
@@ -58,7 +58,7 @@ public class SpringBatchEndpoint extends DefaultEndpoint {
private JobLauncher defaultResolvedJobLauncher;
private Map<String, JobLauncher> allResolvedJobLaunchers;
private Job job;
-
+
@UriParam
private JobRegistry jobRegistry;
@@ -90,7 +90,7 @@ public class SpringBatchEndpoint extends DefaultEndpoint {
if (jobLauncher == null) {
jobLauncher = resolveJobLauncher();
- }
+ }
if (job == null && jobName != null && !jobFromHeader) {
if (jobRegistry != null) {
job = jobRegistry.getJob(jobName);
@@ -174,10 +174,10 @@ public class SpringBatchEndpoint extends DefaultEndpoint {
/**
* Explicitly specifies a JobRegistry to be used.
- */
+ */
public void setJobRegistry(JobRegistry jobRegistry) {
this.jobRegistry = jobRegistry;
}
-
+
}
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 5b1e554..88fe0b6 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
@@ -28,7 +28,7 @@ import org.apache.camel.support.DefaultEndpoint;
import org.springframework.messaging.MessageChannel;
/**
- * Bridges Camel with Spring Integration.
+ * Bridge Camel with Spring Integration.
*/
@UriEndpoint(firstVersion = "1.4.0", scheme = "spring-integration", title = "Spring Integration", syntax = "spring-integration:defaultChannel",
label = "spring,eventbus")
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 9d30942..803f703 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
@@ -29,7 +29,7 @@ import org.apache.camel.support.DefaultEndpoint;
import org.springframework.ldap.core.LdapTemplate;
/**
- * The spring-ldap component allows you to perform searches in LDAP servers using filters as the message payload.
+ * Perform searches in LDAP servers using filters as the message payload.
*/
@UriEndpoint(firstVersion = "2.11.0", scheme = "spring-ldap", title = "Spring LDAP", syntax = "spring-ldap:templateName", producerOnly = true, label = "spring,ldap")
public class SpringLdapEndpoint extends DefaultEndpoint {
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 38ffcd6..f65b8b5 100644
--- 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
@@ -24,7 +24,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.support.DefaultEndpoint;
/**
- * The spring-redis component allows sending and receiving messages from Redis.
+ * Send and receive messages from Redis.
*/
@UriEndpoint(firstVersion = "2.11.0", scheme = "spring-redis", title = "Spring Redis", syntax = "spring-redist:host:port", label = "spring,nosql")
public class RedisEndpoint extends DefaultEndpoint {
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 5d47ab1..e9f2717 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
@@ -25,7 +25,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.support.DefaultEndpoint;
/**
- * The spring-ws component is used for SOAP WebServices using Spring WebServices.
+ * Access external web services as a client or expose your own web services.
*/
@UriEndpoint(firstVersion = "2.6.0", scheme = "spring-ws", title = "Spring WebService",
syntax = "spring-ws:type:lookupKey:webServiceEndpointUri",
diff --git a/components/camel-spring/src/main/java/org/apache/camel/component/event/EventEndpoint.java b/components/camel-spring/src/main/java/org/apache/camel/component/event/EventEndpoint.java
index 3290ddd..9e50cb7 100644
--- a/components/camel-spring/src/main/java/org/apache/camel/component/event/EventEndpoint.java
+++ b/components/camel-spring/src/main/java/org/apache/camel/component/event/EventEndpoint.java
@@ -34,7 +34,7 @@ import org.springframework.context.ApplicationEvent;
import static org.apache.camel.RuntimeCamelException.wrapRuntimeCamelException;
/**
- * The spring-event component allows to listen for Spring Application Events.
+ * Listen for Spring Application Events.
*/
@UriEndpoint(firstVersion = "1.4.0", scheme = "spring-event", title = "Spring Event", syntax = "spring-event:name", label = "spring,eventbus")
public class EventEndpoint extends DefaultEndpoint implements ApplicationContextAware {
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 5bd74cd..3fb832a 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
@@ -27,7 +27,7 @@ import org.apache.camel.util.UnsafeUriCharactersEncoder;
import org.springframework.jdbc.core.JdbcTemplate;
/**
- * The sql component allows you to work with databases using JDBC SQL queries.
+ * Perform SQL queries using Spring JDBC.
*/
@UriEndpoint(firstVersion = "1.4.0", scheme = "sql", title = "SQL", syntax = "sql:query", label = "database,sql")
public class SqlEndpoint extends DefaultSqlEndpoint {
diff --git a/components/camel-sql/src/main/java/org/apache/camel/component/sql/stored/SqlStoredEndpoint.java b/components/camel-sql/src/main/java/org/apache/camel/component/sql/stored/SqlStoredEndpoint.java
index 78cb08b..9bd71b9 100644
--- a/components/camel-sql/src/main/java/org/apache/camel/component/sql/stored/SqlStoredEndpoint.java
+++ b/components/camel-sql/src/main/java/org/apache/camel/component/sql/stored/SqlStoredEndpoint.java
@@ -31,7 +31,7 @@ import org.apache.camel.util.UnsafeUriCharactersEncoder;
import org.springframework.jdbc.core.JdbcTemplate;
/**
- * The sql component allows you to work with databases using JDBC Stored Procedure queries.
+ * Perform SQL queries as a JDBC Stored Procedures using Spring JDBC.
*/
@UriEndpoint(firstVersion = "2.17.0", scheme = "sql-stored", title = "SQL Stored Procedure", syntax = "sql-stored:template", producerOnly = true, label = "database,sql")
public class SqlStoredEndpoint extends DefaultEndpoint {
diff --git a/components/camel-ssh/src/main/java/org/apache/camel/component/ssh/SshEndpoint.java b/components/camel-ssh/src/main/java/org/apache/camel/component/ssh/SshEndpoint.java
index b0d8fae..7a017ec 100644
--- a/components/camel-ssh/src/main/java/org/apache/camel/component/ssh/SshEndpoint.java
+++ b/components/camel-ssh/src/main/java/org/apache/camel/component/ssh/SshEndpoint.java
@@ -27,8 +27,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The ssh component enables access to SSH servers such that you can send an SSH
- * command, and process the response.
+ * Execute commands on remote hosts using SSH.
*/
@UriEndpoint(firstVersion = "2.10.0", scheme = "ssh", title = "SSH", syntax = "ssh:host:port", alternativeSyntax = "ssh:username:password@host:port", label = "file")
public class SshEndpoint extends ScheduledPollEndpoint {
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 d29be15..97ea563 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
@@ -27,7 +27,7 @@ import org.apache.camel.support.EndpointHelper;
import org.apache.camel.support.ProcessorEndpoint;
/**
- * The stax component allows messages to be process through a SAX ContentHandler.
+ * Process XML payloads by a SAX ContentHandler.
*/
@UriEndpoint(firstVersion = "2.9.0", scheme = "stax", title = "StAX", syntax = "stax:contentHandlerClass", producerOnly = true, label = "transformation")
public class StAXEndpoint extends ProcessorEndpoint {
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 922933d..2d9978a 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
@@ -54,7 +54,7 @@ import static org.fusesource.stomp.client.Constants.SUBSCRIBE;
import static org.fusesource.stomp.client.Constants.UNSUBSCRIBE;
/**
- * The stomp component is used for communicating with Stomp compliant message brokers.
+ * Send and rececive messages to/from STOMP (Simple Text Oriented Messaging Protocol) compliant message brokers.
*/
@UriEndpoint(firstVersion = "2.12.0", scheme = "stomp", title = "Stomp", syntax = "stomp:destination", label = "messaging")
public class StompEndpoint extends DefaultEndpoint implements AsyncEndpoint, HeaderFilterStrategyAware {
@@ -183,11 +183,11 @@ public class StompEndpoint extends DefaultEndpoint implements AsyncEndpoint, Hea
}
private void populateCamelMessageHeadersToStompFrames(final Exchange exchange, final StompFrame frame) {
- Set<Map.Entry<String, Object>> entries = exchange.getIn().getHeaders().entrySet();
+ Set<Map.Entry<String, Object>> entries = exchange.getIn().getHeaders().entrySet();
for (Map.Entry<String, Object> entry : entries) {
String headerName = entry.getKey();
Object headerValue = entry.getValue();
- if (!headerName.toLowerCase().startsWith("camel")
+ if (!headerName.toLowerCase().startsWith("camel")
&& !headerFilterStrategy.applyFilterToCamelHeaders(headerName, headerValue, exchange)) {
if (headerValue != null) {
frame.addHeader(new AsciiBuffer(headerName), StompFrame.encodeHeader(headerValue.toString()));
@@ -235,7 +235,7 @@ public class StompEndpoint extends DefaultEndpoint implements AsyncEndpoint, Hea
AsciiBuffer getNextId() {
return connection.nextId();
}
-
+
@Override
public HeaderFilterStrategy getHeaderFilterStrategy() {
if (headerFilterStrategy == null) {
diff --git a/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamEndpoint.java b/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamEndpoint.java
index 9b86694..6f6ed84 100644
--- a/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamEndpoint.java
+++ b/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamEndpoint.java
@@ -32,7 +32,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The stream: component provides access to the system-in, system-out and system-err streams as well as allowing streaming of file.
+ * Read from system-in and write to system-out and system-err streams.
*/
@UriEndpoint(firstVersion = "1.3.0", scheme = "stream", title = "Stream", syntax = "stream:kind", label = "file,system")
public class StreamEndpoint extends DefaultEndpoint {
@@ -194,7 +194,7 @@ public class StreamEndpoint extends DefaultEndpoint {
public void setScanStream(boolean scanStream) {
this.scanStream = scanStream;
}
-
+
public GroupStrategy getGroupStrategy() {
return groupStrategy;
}
@@ -265,7 +265,7 @@ public class StreamEndpoint extends DefaultEndpoint {
public void setGroupLines(int groupLines) {
this.groupLines = groupLines;
}
-
+
public int getAutoCloseCount() {
return autoCloseCount;
}
@@ -305,7 +305,7 @@ public class StreamEndpoint extends DefaultEndpoint {
protected void doStart() throws Exception {
charset = loadCharset();
}
-
+
Charset loadCharset() {
if (encoding == null) {
encoding = Charset.defaultCharset().name();
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 91f8a1b..4a5e9de 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
@@ -32,7 +32,7 @@ import org.stringtemplate.v4.ST;
import org.stringtemplate.v4.STGroup;
/**
- * Transforms the message using a String template.
+ * Transform messages using StringTemplate engine.
*/
@UriEndpoint(firstVersion = "1.2.0", scheme = "string-template", title = "String Template", syntax = "string-template:resourceUri", producerOnly = true, label = "transformation")
public class StringTemplateEndpoint extends ResourceEndpoint {
@@ -79,7 +79,7 @@ public class StringTemplateEndpoint extends ResourceEndpoint {
@Override
protected void onExchange(Exchange exchange) throws Exception {
StringWriter buffer = new StringWriter();
-
+
@SuppressWarnings("unchecked")
Map<String, Object> variableMap = exchange.getIn().getHeader(StringTemplateConstants.STRINGTEMPLATE_VARIABLE_MAP, Map.class);
if (variableMap == null) {
diff --git a/components/camel-stub/src/main/java/org/apache/camel/component/stub/StubEndpoint.java b/components/camel-stub/src/main/java/org/apache/camel/component/stub/StubEndpoint.java
index b049775..eb1c3d7 100644
--- a/components/camel-stub/src/main/java/org/apache/camel/component/stub/StubEndpoint.java
+++ b/components/camel-stub/src/main/java/org/apache/camel/component/stub/StubEndpoint.java
@@ -27,7 +27,7 @@ import org.apache.camel.component.vm.VmEndpoint;
import org.apache.camel.spi.UriEndpoint;
/**
- * The stub component provides a simple way to stub out any physical endpoints while in development or testing.
+ * Stub out any physical endpoints while in development or testing.
*
* For example to run a route without needing to actually connect to a specific SMTP or HTTP endpoint.
* Just add stub: in front of any endpoint URI to stub out the endpoint.
diff --git a/components/camel-telegram/src/main/java/org/apache/camel/component/telegram/TelegramEndpoint.java b/components/camel-telegram/src/main/java/org/apache/camel/component/telegram/TelegramEndpoint.java
index 59bfe5d..ebd0a22 100644
--- a/components/camel-telegram/src/main/java/org/apache/camel/component/telegram/TelegramEndpoint.java
+++ b/components/camel-telegram/src/main/java/org/apache/camel/component/telegram/TelegramEndpoint.java
@@ -44,7 +44,7 @@ import org.slf4j.LoggerFactory;
import static org.apache.camel.component.telegram.util.TelegramMessageHelper.populateExchange;
/**
- * The telegram component provides access to the <a href="https://core.telegram.org/bots/api">Telegram Bot API</a>.
+ * Send and receive messages acting as a Telegram Bot <a href="https://core.telegram.org/bots/api">Telegram Bot API</a>.
*/
@UriEndpoint(firstVersion = "2.18.0", scheme = "telegram", title = "Telegram", syntax = "telegram:type", label = "chat")
public class TelegramEndpoint extends ScheduledPollEndpoint implements WebhookCapableEndpoint {
diff --git a/components/camel-thrift/src/main/java/org/apache/camel/component/thrift/ThriftEndpoint.java b/components/camel-thrift/src/main/java/org/apache/camel/component/thrift/ThriftEndpoint.java
index 35e6c5f..0cd55de 100644
--- a/components/camel-thrift/src/main/java/org/apache/camel/component/thrift/ThriftEndpoint.java
+++ b/components/camel-thrift/src/main/java/org/apache/camel/component/thrift/ThriftEndpoint.java
@@ -25,21 +25,20 @@ import org.apache.camel.support.DefaultEndpoint;
import org.apache.camel.support.SynchronousDelegateProducer;
/**
- * The Thrift component allows to call and expose remote procedures (RPC) with
- * Apache Thrift data format and serialization mechanism
+ * Call and expose remote procedures (RPC) with Apache Thrift data format and serialization mechanism.
*/
@UriEndpoint(firstVersion = "2.20.0", scheme = "thrift", title = "Thrift", syntax = "thrift:host:port/service", label = "rpc")
public class ThriftEndpoint extends DefaultEndpoint {
@UriParam
private ThriftConfiguration configuration;
-
+
private String serviceName;
private String servicePackage;
public ThriftEndpoint(String uri, ThriftComponent component, ThriftConfiguration config) throws Exception {
super(uri, component);
this.configuration = config;
-
+
// Extract service and package names from the full service name
serviceName = ThriftUtils.extractServiceName(configuration.getService());
servicePackage = ThriftUtils.extractServicePackage(configuration.getService());
diff --git a/components/camel-tika/src/main/java/org/apache/camel/component/tika/TikaEndpoint.java b/components/camel-tika/src/main/java/org/apache/camel/component/tika/TikaEndpoint.java
index 9f0e70a..7ebd2a5 100644
--- a/components/camel-tika/src/main/java/org/apache/camel/component/tika/TikaEndpoint.java
+++ b/components/camel-tika/src/main/java/org/apache/camel/component/tika/TikaEndpoint.java
@@ -24,6 +24,9 @@ import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriParam;
import org.apache.camel.support.DefaultEndpoint;
+/**
+ * Parse documents and extract metadata and text using Apache Tika.
+ */
@UriEndpoint(firstVersion = "2.19.0", scheme = "tika", title = "Tika", syntax = "tika:operation", producerOnly = true, label = "document,transformation")
public class TikaEndpoint extends DefaultEndpoint {
diff --git a/components/camel-timer/src/main/java/org/apache/camel/component/timer/TimerEndpoint.java b/components/camel-timer/src/main/java/org/apache/camel/component/timer/TimerEndpoint.java
index 72a0685..abedbb5 100644
--- a/components/camel-timer/src/main/java/org/apache/camel/component/timer/TimerEndpoint.java
+++ b/components/camel-timer/src/main/java/org/apache/camel/component/timer/TimerEndpoint.java
@@ -34,7 +34,7 @@ import org.apache.camel.spi.UriPath;
import org.apache.camel.support.DefaultEndpoint;
/**
- * The timer component is used for generating message exchanges when a timer fires.
+ * Generate messages in specified intervals using <code>java.util.Timer</code>.
*
* This component is similar to the scheduler component, but has much less functionality.
*/
@@ -69,7 +69,7 @@ public class TimerEndpoint extends DefaultEndpoint implements MultipleConsumersS
super(uri, component);
this.timerName = timerName;
}
-
+
protected TimerEndpoint(String endpointUri, Component component) {
super(endpointUri, component);
}
diff --git a/components/camel-twilio/src/main/java/org/apache/camel/component/twilio/TwilioEndpoint.java b/components/camel-twilio/src/main/java/org/apache/camel/component/twilio/TwilioEndpoint.java
index 82dc354..c9a12ab 100644
--- a/components/camel-twilio/src/main/java/org/apache/camel/component/twilio/TwilioEndpoint.java
+++ b/components/camel-twilio/src/main/java/org/apache/camel/component/twilio/TwilioEndpoint.java
@@ -39,7 +39,7 @@ import org.apache.camel.support.component.ApiMethod;
import org.apache.camel.support.component.ApiMethodPropertiesHelper;
/**
- * The Twilio component allows you to interact with the Twilio REST APIs using Twilio Java SDK.
+ * Interact with Twilio REST APIs using Twilio Java SDK.
*/
@UriEndpoint(firstVersion = "2.20.0", scheme = "twilio", title = "Twilio", syntax = "twilio:apiName/methodName",
label = "api,messaging,cloud")
diff --git a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/directmessage/TwitterDirectMessageEndpoint.java b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/directmessage/TwitterDirectMessageEndpoint.java
index ec2f499..cea1112 100644
--- a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/directmessage/TwitterDirectMessageEndpoint.java
+++ b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/directmessage/TwitterDirectMessageEndpoint.java
@@ -27,7 +27,7 @@ import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriPath;
/**
- * The Twitter Direct Message Component consumes/produces user's direct messages.
+ * Send and receive Twitter direct messages.
*/
@UriEndpoint(firstVersion = "2.10.0", scheme = "twitter-directmessage", title = "Twitter Direct Message", syntax = "twitter-directmessage:user",
label = "api,social")
diff --git a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/search/TwitterSearchEndpoint.java b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/search/TwitterSearchEndpoint.java
index a172cc5..1244002 100644
--- a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/search/TwitterSearchEndpoint.java
+++ b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/search/TwitterSearchEndpoint.java
@@ -27,7 +27,7 @@ import org.apache.camel.spi.UriEndpoint;
import org.apache.camel.spi.UriPath;
/**
- * The Twitter Search component consumes search results.
+ * Access Twitter Search.
*/
@UriEndpoint(firstVersion = "2.10.0", scheme = "twitter-search", title = "Twitter Search", syntax = "twitter-search:keywords",
label = "api,social")
diff --git a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/timeline/TwitterTimelineEndpoint.java b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/timeline/TwitterTimelineEndpoint.java
index 6b8540f..55b3bea 100644
--- a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/timeline/TwitterTimelineEndpoint.java
+++ b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/timeline/TwitterTimelineEndpoint.java
@@ -30,7 +30,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriPath;
/**
- * The Twitter Timeline component consumes twitter timeline or update the status of specific user.
+ * Send tweets and receive tweets from user's timeline.
*/
@UriEndpoint(firstVersion = "2.10.0", scheme = "twitter-timeline", title = "Twitter Timeline", syntax = "twitter-timeline:timelineType",
label = "api,social")
diff --git a/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowEndpoint.java b/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowEndpoint.java
index 4ccfe9f..c8ef3bc 100644
--- a/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowEndpoint.java
+++ b/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowEndpoint.java
@@ -58,7 +58,7 @@ import org.xnio.OptionMap;
import org.xnio.Options;
/**
- * The undertow component provides HTTP and WebSocket based endpoints for consuming and producing HTTP/WebSocket requests.
+ * Expose HTTP and WebSocket endpoints and access external HTTP/WebSocket servers.
*/
@UriEndpoint(firstVersion = "2.16.0", scheme = "undertow", title = "Undertow", syntax = "undertow:httpURI",
label = "http,websocket", lenientProperties = true)
@@ -287,12 +287,12 @@ public class UndertowEndpoint extends DefaultEndpoint implements AsyncEndpoint,
}
/**
- * If enabled and an Exchange failed processing on the consumer side and if the caused Exception
- * was send back serialized in the response as a application/x-java-serialized-object content type.
- * On the producer side the exception will be deserialized and thrown as is instead of the HttpOperationFailedException. The caused exception is required to be serialized.
- * This is by default turned off. If you enable this
+ * If enabled and an Exchange failed processing on the consumer side and if the caused Exception
+ * was send back serialized in the response as a application/x-java-serialized-object content type.
+ * On the producer side the exception will be deserialized and thrown as is instead of the HttpOperationFailedException. The caused exception is required to be serialized.
+ * This is by default turned off. If you enable this
* then be aware that Java will deserialize the incoming data from the request to Java and that can be a potential security risk.
- *
+ *
*/
public void setTransferException(Boolean transferException) {
this.transferException = transferException;
diff --git a/components/camel-validator/src/main/java/org/apache/camel/component/validator/ValidatorEndpoint.java b/components/camel-validator/src/main/java/org/apache/camel/component/validator/ValidatorEndpoint.java
index 8615116..b65a027 100644
--- a/components/camel-validator/src/main/java/org/apache/camel/component/validator/ValidatorEndpoint.java
+++ b/components/camel-validator/src/main/java/org/apache/camel/component/validator/ValidatorEndpoint.java
@@ -38,7 +38,7 @@ import org.apache.camel.support.processor.validation.ValidatingProcessor;
import org.apache.camel.support.processor.validation.ValidatorErrorHandler;
/**
- * Validates the payload of a message using XML Schema and JAXP Validation.
+ * Validate the payload using XML Schema and JAXP Validation.
*/
@ManagedResource(description = "Managed ValidatorEndpoint")
@UriEndpoint(firstVersion = "1.1.0", scheme = "validator", title = "Validator", syntax = "validator:resourceUri", producerOnly = true, label = "core,validation")
@@ -101,7 +101,7 @@ public class ValidatorEndpoint extends DefaultEndpoint {
schemaReader.setResourceResolver(resourceResolver);
} else if (resourceResolverFactory != null) {
resourceResolver = resourceResolverFactory.createResourceResolver(getCamelContext(), resourceUri);
- // set the created resource resolver to the resourceResolver variable, so that it can
+ // set the created resource resolver to the resourceResolver variable, so that it can
// be accessed by the endpoint
schemaReader.setResourceResolver(resourceResolver);
} else {
@@ -109,7 +109,7 @@ public class ValidatorEndpoint extends DefaultEndpoint {
}
schemaReader.setSchemaLanguage(getSchemaLanguage());
schemaReader.setSchemaFactory(getSchemaFactory());
-
+
// force loading of schema at create time otherwise concurrent
// processing could cause thread safe issues for the
// javax.xml.validation.SchemaFactory
@@ -211,9 +211,9 @@ public class ValidatorEndpoint extends DefaultEndpoint {
return resourceResolverFactory;
}
- /** For creating a resource resolver which depends on the endpoint resource URI.
- * Must not be used in combination with method {@link #setResourceResolver(LSResourceResolver)}.
- * If not set then {@link DefaultValidatorResourceResolverFactory} is used
+ /** For creating a resource resolver which depends on the endpoint resource URI.
+ * Must not be used in combination with method {@link #setResourceResolver(LSResourceResolver)}.
+ * If not set then {@link DefaultValidatorResourceResolverFactory} is used
*/
public void setResourceResolverFactory(ValidatorResourceResolverFactory resourceResolverFactory) {
this.resourceResolverFactory = resourceResolverFactory;
diff --git a/components/camel-velocity/src/main/java/org/apache/camel/component/velocity/VelocityEndpoint.java b/components/camel-velocity/src/main/java/org/apache/camel/component/velocity/VelocityEndpoint.java
index 5d6c21b..78905d5 100644
--- a/components/camel-velocity/src/main/java/org/apache/camel/component/velocity/VelocityEndpoint.java
+++ b/components/camel-velocity/src/main/java/org/apache/camel/component/velocity/VelocityEndpoint.java
@@ -42,7 +42,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * Transforms the message using a Velocity template.
+ * Transform messages using a Velocity template.
*/
@UriEndpoint(firstVersion = "1.2.0", scheme = "velocity", title = "Velocity", syntax = "velocity:resourceUri", producerOnly = true, label = "transformation")
public class VelocityEndpoint extends ResourceEndpoint {
@@ -88,8 +88,8 @@ public class VelocityEndpoint extends ResourceEndpoint {
properties.setProperty("class.resource.loader.class", CamelVelocityClasspathResourceLoader.class.getName());
final Logger velocityLogger = LoggerFactory.getLogger("org.apache.camel.maven.Velocity");
properties.setProperty(RuntimeConstants.RUNTIME_LOG_NAME, velocityLogger.getName());
-
-
+
+
// load the velocity properties from property file which may overrides the default ones
if (ObjectHelper.isNotEmpty(getPropertiesFile())) {
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 626b6d4..e36e1db 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
@@ -30,7 +30,7 @@ import org.apache.camel.spi.UriPath;
import org.apache.camel.support.DefaultEndpoint;
/**
- * The vertx component is used for sending and receive messages from a vertx event bus.
+ * Send and receive messages to/from Vert.x Event Bus.
*/
@UriEndpoint(firstVersion = "2.12.0", scheme = "vertx", title = "Vert.x", syntax = "vertx:address", label = "eventbus,reactive")
public class VertxEndpoint extends DefaultEndpoint implements AsyncEndpoint, MultipleConsumersSupport {
diff --git a/components/camel-vm/src/main/java/org/apache/camel/component/vm/VmEndpoint.java b/components/camel-vm/src/main/java/org/apache/camel/component/vm/VmEndpoint.java
index 5d75dc8..41ddcaf 100644
--- a/components/camel-vm/src/main/java/org/apache/camel/component/vm/VmEndpoint.java
+++ b/components/camel-vm/src/main/java/org/apache/camel/component/vm/VmEndpoint.java
@@ -26,7 +26,7 @@ import org.apache.camel.component.seda.SedaEndpoint;
import org.apache.camel.spi.UriEndpoint;
/**
- * The vm component provides asynchronous call to another endpoint from the same CamelContext.
+ * Call another endpoint in the same CamelContext asynchronously.
*/
@UriEndpoint(firstVersion = "1.1.0", scheme = "vm", title = "VM", syntax = "vm:name", label = "core,endpoint")
public class VmEndpoint extends SedaEndpoint {
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 31ea003..d62423b 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
@@ -24,7 +24,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.support.DefaultPollingEndpoint;
/**
- * Polls the weather information from Open Weather Map.
+ * Poll the weather information from Open Weather Map.
*/
@UriEndpoint(firstVersion = "2.12.0", scheme = "weather", title = "Weather", syntax = "weather:name", label = "api")
public class WeatherEndpoint extends DefaultPollingEndpoint {
diff --git a/components/camel-web3j/src/main/java/org/apache/camel/component/web3j/Web3jEndpoint.java b/components/camel-web3j/src/main/java/org/apache/camel/component/web3j/Web3jEndpoint.java
index ad542d9..7dda7e1 100644
--- a/components/camel-web3j/src/main/java/org/apache/camel/component/web3j/Web3jEndpoint.java
+++ b/components/camel-web3j/src/main/java/org/apache/camel/component/web3j/Web3jEndpoint.java
@@ -40,7 +40,7 @@ import org.web3j.protocol.ipc.WindowsIpcService;
import org.web3j.quorum.Quorum;
/**
- * The web3j component uses the Web3j client API and allows you to add/read nodes to/from a web3j compliant content repositories.
+ * Interact with Ethereum nodes using web3j client API.
*/
@UriEndpoint(firstVersion = "2.22.0", scheme = "web3j", title = "Web3j Ethereum Blockchain", syntax = "web3j:nodeAddress",
label = "bitcoin,blockchain")
diff --git a/components/camel-webhook/src/main/java/org/apache/camel/component/webhook/WebhookEndpoint.java b/components/camel-webhook/src/main/java/org/apache/camel/component/webhook/WebhookEndpoint.java
index e4c7d6c..bc1a438 100644
--- a/components/camel-webhook/src/main/java/org/apache/camel/component/webhook/WebhookEndpoint.java
+++ b/components/camel-webhook/src/main/java/org/apache/camel/component/webhook/WebhookEndpoint.java
@@ -31,8 +31,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * The webhook component allows other Camel components that can receive push notifications to expose
- * webhook endpoints and automatically register them with their own webhook provider.
+ * Expose webhook endpoints to receive push notifications for other Camel components.
*/
@UriEndpoint(firstVersion = "3.0.0", scheme = "webhook", title = "Webhook", syntax = "webhook:endpointUri", consumerOnly = true, label = "cloud", lenientProperties = true)
public class WebhookEndpoint extends DefaultEndpoint implements DelegateEndpoint, AfterPropertiesConfigured {
diff --git a/components/camel-websocket-jsr356/src/main/java/org/apache/camel/websocket/jsr356/JSR356Endpoint.java b/components/camel-websocket-jsr356/src/main/java/org/apache/camel/websocket/jsr356/JSR356Endpoint.java
index d9aee29d..1fa83d6 100644
--- a/components/camel-websocket-jsr356/src/main/java/org/apache/camel/websocket/jsr356/JSR356Endpoint.java
+++ b/components/camel-websocket-jsr356/src/main/java/org/apache/camel/websocket/jsr356/JSR356Endpoint.java
@@ -26,6 +26,9 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriPath;
import org.apache.camel.support.DefaultEndpoint;
+/**
+ * Expose websocket endpoints using JSR356.
+ */
@UriEndpoint(firstVersion = "2.23.0", scheme = "websocket-jsr356", title = "Javax Websocket", syntax = "websocket-jsr356:uri", label = "http")
public class JSR356Endpoint extends DefaultEndpoint {
@UriPath(description = "If a schemeless URI path is provided, a ServerEndpoint is deployed under that path. "
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 204e4d1..679005e 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
@@ -34,9 +34,7 @@ import org.apache.camel.util.ObjectHelper;
import org.eclipse.jetty.server.Handler;
/**
- * The websocket component provides websocket endpoints with Jetty for communicating with clients using websocket.
- *
- * This component uses Jetty as the websocket implementation.
+ * Expose websocket endpoints using Jetty.
*/
@UriEndpoint(firstVersion = "2.10.0", scheme = "websocket", title = "Jetty Websocket", syntax = "websocket:host:port/resourceUri", label = "websocket")
public class WebsocketEndpoint extends DefaultEndpoint {
diff --git a/components/camel-weka/src/main/java/org/apache/camel/component/weka/WekaEndpoint.java b/components/camel-weka/src/main/java/org/apache/camel/component/weka/WekaEndpoint.java
index f223db5..78f464e 100644
--- a/components/camel-weka/src/main/java/org/apache/camel/component/weka/WekaEndpoint.java
+++ b/components/camel-weka/src/main/java/org/apache/camel/component/weka/WekaEndpoint.java
@@ -25,7 +25,7 @@ import org.apache.camel.support.DefaultEndpoint;
import weka.core.Version;
/**
- * The camel-weka component provides Data Mining functionality through Weka.
+ * Perform machine learning tasks using Weka.
*/
@UriEndpoint(firstVersion = "3.1.0", scheme = "weka", title = "Weka", syntax = "weka:command", producerOnly = true, label = "Datamining")
public class WekaEndpoint extends DefaultEndpoint {
diff --git a/components/camel-wordpress/src/main/java/org/apache/camel/component/wordpress/WordpressEndpoint.java b/components/camel-wordpress/src/main/java/org/apache/camel/component/wordpress/WordpressEndpoint.java
index b7260ff..a8fb0ac 100644
--- a/components/camel-wordpress/src/main/java/org/apache/camel/component/wordpress/WordpressEndpoint.java
+++ b/components/camel-wordpress/src/main/java/org/apache/camel/component/wordpress/WordpressEndpoint.java
@@ -42,7 +42,7 @@ import org.apache.camel.util.ObjectHelper;
import org.apache.camel.util.PropertiesHelper;
/**
- * Integrates Camel with Wordpress.
+ * Manage posts and users using Wordpress API.
*/
@UriEndpoint(firstVersion = "2.21.0", scheme = "wordpress", title = "Wordpress", syntax = "wordpress:operation", label = "cms")
public class WordpressEndpoint extends DefaultEndpoint {
diff --git a/components/camel-workday/src/main/java/org/apache/camel/component/workday/WorkdayEndpoint.java b/components/camel-workday/src/main/java/org/apache/camel/component/workday/WorkdayEndpoint.java
index 8cb5bd7..4ec6e0e 100644
--- a/components/camel-workday/src/main/java/org/apache/camel/component/workday/WorkdayEndpoint.java
+++ b/components/camel-workday/src/main/java/org/apache/camel/component/workday/WorkdayEndpoint.java
@@ -24,7 +24,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.support.DefaultEndpoint;
/**
- * Represents a Workday endpoint.
+ * Detect and parse documents using Workday.
*/
@UriEndpoint(firstVersion = "3.1.0", scheme = "workday", title = "Workday", syntax = "workday:entity:path", producerOnly = true, label = "hcm")
public class WorkdayEndpoint extends DefaultEndpoint {
diff --git a/components/camel-xchange/src/main/java/org/apache/camel/component/xchange/XChangeEndpoint.java b/components/camel-xchange/src/main/java/org/apache/camel/component/xchange/XChangeEndpoint.java
index b6454f4..b0aab9c 100644
--- a/components/camel-xchange/src/main/java/org/apache/camel/component/xchange/XChangeEndpoint.java
+++ b/components/camel-xchange/src/main/java/org/apache/camel/component/xchange/XChangeEndpoint.java
@@ -45,7 +45,7 @@ import org.knowm.xchange.service.trade.params.TradeHistoryParams;
import org.knowm.xchange.utils.Assert;
/**
- * The camel-xchange component provide access to many bitcoin and altcoin exchanges for trading and accessing market data.
+ * Access market data and trade on Bitcoin and Altcoin exchanges.
*/
@UriEndpoint(firstVersion = "2.21.0", scheme = "xchange", title = "XChange", syntax = "xchange:name", producerOnly = true, label = "bitcoin,blockchain")
public class XChangeEndpoint extends DefaultEndpoint {
@@ -72,7 +72,7 @@ public class XChangeEndpoint extends DefaultEndpoint {
@Override
public Producer createProducer() throws Exception {
Producer producer = null;
-
+
XChangeService service = getConfiguration().getService();
if (XChangeService.account == service) {
producer = new XChangeAccountProducer(this);
@@ -81,7 +81,7 @@ public class XChangeEndpoint extends DefaultEndpoint {
} else if (XChangeService.metadata == service) {
producer = new XChangeMetaDataProducer(this);
}
-
+
Assert.notNull(producer, "Unsupported service: " + service);
return producer;
}
@@ -106,18 +106,18 @@ public class XChangeEndpoint extends DefaultEndpoint {
ExchangeMetaData metaData = xchange.getExchangeMetaData();
return metaData.getCurrencies().keySet().stream().sorted().collect(Collectors.toList());
}
-
+
public CurrencyMetaData getCurrencyMetaData(Currency curr) {
Assert.notNull(curr, "Null currency");
ExchangeMetaData metaData = xchange.getExchangeMetaData();
return metaData.getCurrencies().get(curr);
}
-
+
public List<CurrencyPair> getCurrencyPairs() {
ExchangeMetaData metaData = xchange.getExchangeMetaData();
return metaData.getCurrencyPairs().keySet().stream().sorted().collect(Collectors.toList());
}
-
+
public CurrencyPairMetaData getCurrencyPairMetaData(CurrencyPair pair) {
Assert.notNull(pair, "Null currency");
ExchangeMetaData metaData = xchange.getExchangeMetaData();
@@ -133,7 +133,7 @@ public class XChangeEndpoint extends DefaultEndpoint {
if (metaData != null) {
int scale = metaData.getScale();
double total = aux.getTotal().doubleValue();
- double scaledTotal = total * Math.pow(10, scale / 2);
+ double scaledTotal = total * Math.pow(10, scale / 2);
if (1 <= scaledTotal) {
balances.add(aux);
}
diff --git a/components/camel-xj/src/main/java/org/apache/camel/component/xj/XJEndpoint.java b/components/camel-xj/src/main/java/org/apache/camel/component/xj/XJEndpoint.java
index 2a6a3ca..197eaa5 100644
--- a/components/camel-xj/src/main/java/org/apache/camel/component/xj/XJEndpoint.java
+++ b/components/camel-xj/src/main/java/org/apache/camel/component/xj/XJEndpoint.java
@@ -29,7 +29,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.util.ObjectHelper;
/**
- * Transforms json/xml message back and forth using a XSLT.
+ * Transform JSON and XML message using a XSLT.
*/
@ManagedResource(description = "Managed XJEndpoint")
@UriEndpoint(firstVersion = "3.0.0", scheme = "xj", title = "XJ", syntax = "xj:resourceUri", producerOnly = true, label = "transformation")
diff --git a/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/XmlSignerEndpoint.java b/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/XmlSignerEndpoint.java
index 7634aa5..46352c8 100644
--- a/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/XmlSignerEndpoint.java
+++ b/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/XmlSignerEndpoint.java
@@ -28,7 +28,7 @@ import org.apache.camel.spi.UriPath;
import org.apache.camel.support.DefaultEndpoint;
/**
- * Used to sign exchanges using the XML signature specification.
+ * Sign XML payloads using the XML signature specification.
*/
@UriEndpoint(firstVersion = "2.12.0", scheme = "xmlsecurity-sign", title = "XML Security Sign",
syntax = "xmlsecurity-sign:name", producerOnly = true, label = "security,transformation")
diff --git a/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/XmlVerifierEndpoint.java b/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/XmlVerifierEndpoint.java
index e9e3dc6..5442c5b 100644
--- a/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/XmlVerifierEndpoint.java
+++ b/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/XmlVerifierEndpoint.java
@@ -28,7 +28,7 @@ import org.apache.camel.spi.UriPath;
import org.apache.camel.support.DefaultEndpoint;
/**
- * Used to verify exchanges using the XML signature specification.
+ * Verify XML payloads using the XML signature specification.
*/
@UriEndpoint(firstVersion = "2.12.0", scheme = "xmlsecurity-verify", title = "XML Security Verify",
syntax = "xmlsecurity-verify:name", producerOnly = true, label = "security,transformation")
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 356fb6a..f39db19 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
@@ -55,7 +55,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * To send and receive messages from a XMPP (chat) server.
+ * Send and receive messages to/from an XMPP chat server.
*/
@UriEndpoint(firstVersion = "1.0", scheme = "xmpp", title = "XMPP", syntax = "xmpp:host:port/participant", alternativeSyntax = "xmpp:user:password@host:port/participant",
label = "chat,messaging")
diff --git a/components/camel-xslt-saxon/src/main/java/org/apache/camel/component/xslt/saxon/XsltSaxonEndpoint.java b/components/camel-xslt-saxon/src/main/java/org/apache/camel/component/xslt/saxon/XsltSaxonEndpoint.java
index e4e756b..ba3261f 100644
--- a/components/camel-xslt-saxon/src/main/java/org/apache/camel/component/xslt/saxon/XsltSaxonEndpoint.java
+++ b/components/camel-xslt-saxon/src/main/java/org/apache/camel/component/xslt/saxon/XsltSaxonEndpoint.java
@@ -51,7 +51,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * Transforms the message using a XSLT template using Saxon.
+ * Transform XML payloads using an XSLT template using Saxon.
*/
@ManagedResource(description = "Managed XsltSaxonEndpoint")
@UriEndpoint(firstVersion = "3.0.0", scheme = "xslt-saxon", title = "XSLT Saxon", syntax = "xslt-saxon:resourceUri", producerOnly = true, label = "core,transformation")
@@ -121,7 +121,7 @@ public class XsltSaxonEndpoint extends XsltEndpoint {
public void setSaxonConfigurationProperties(Map<String, Object> configurationProperties) {
this.saxonConfigurationProperties = configurationProperties;
}
-
+
public Map<String, Object> getSaxonReaderProperties() {
return saxonReaderProperties;
}
@@ -213,7 +213,7 @@ public class XsltSaxonEndpoint extends XsltEndpoint {
return xslt;
}
-
+
/**
* Loads the resource.
*
@@ -237,7 +237,7 @@ public class XsltSaxonEndpoint extends XsltEndpoint {
// now loaded so clear flag
setCacheCleared(false);
}
-
+
private Source createReaderForSource(Source source) {
try {
XMLReader xmlReader = XMLReaderFactory.createXMLReader();
@@ -246,7 +246,7 @@ public class XsltSaxonEndpoint extends XsltEndpoint {
Object value = entry.getValue();
try {
URI uri = new URI(key);
- if (value != null
+ if (value != null
&& (value.toString().equals("true") || (value.toString().equals("false")))) {
xmlReader.setFeature(uri.toString(), Boolean.valueOf(value.toString()));
} else if (value != null) {
@@ -255,7 +255,7 @@ public class XsltSaxonEndpoint extends XsltEndpoint {
} catch (URISyntaxException e) {
LOG.debug("{} isn't a valid URI, so ingore it", key);
}
- }
+ }
InputSource inputSource = SAXSource.sourceToInputSource(source);
return new SAXSource(xmlReader, inputSource);
} catch (SAXException e) {
diff --git a/components/camel-xslt/src/main/java/org/apache/camel/component/xslt/XsltEndpoint.java b/components/camel-xslt/src/main/java/org/apache/camel/component/xslt/XsltEndpoint.java
index 5c8cb88..f3737f6 100644
--- a/components/camel-xslt/src/main/java/org/apache/camel/component/xslt/XsltEndpoint.java
+++ b/components/camel-xslt/src/main/java/org/apache/camel/component/xslt/XsltEndpoint.java
@@ -47,7 +47,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * Transforms the message using a XSLT template.
+ * Transforms XML payload using an XSLT template.
*/
@ManagedResource(description = "Managed XsltEndpoint")
@UriEndpoint(firstVersion = "1.3.0", scheme = "xslt", title = "XSLT", syntax = "xslt:resourceUri", producerOnly = true, label = "core,transformation")
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 886c891..7a42a82 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
@@ -24,7 +24,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.support.ScheduledPollEndpoint;
/**
- * The yammer component allows you to interact with the Yammer enterprise social network.
+ * Interact with the Yammer enterprise social network.
*/
@UriEndpoint(firstVersion = "2.12.0", scheme = "yammer", title = "Yammer", syntax = "yammer:function", label = "social")
public class YammerEndpoint extends ScheduledPollEndpoint {
diff --git a/components/camel-zendesk/src/main/java/org/apache/camel/component/zendesk/ZendeskEndpoint.java b/components/camel-zendesk/src/main/java/org/apache/camel/component/zendesk/ZendeskEndpoint.java
index db3a949..5fa02a6 100644
--- a/components/camel-zendesk/src/main/java/org/apache/camel/component/zendesk/ZendeskEndpoint.java
+++ b/components/camel-zendesk/src/main/java/org/apache/camel/component/zendesk/ZendeskEndpoint.java
@@ -35,7 +35,7 @@ import org.apache.camel.util.IOHelper;
import org.zendesk.client.v2.Zendesk;
/**
- * Allows producing messages to manage Zendesk ticket, user, organization, etc.
+ * Manage Zendesk tickets, users, organizations, etc.
*/
@UriEndpoint(firstVersion = "2.19.0", scheme = "zendesk", title = "Zendesk", syntax = "zendesk:methodName",
consumerPrefix = "consumer", label = "api,support,cloud", lenientProperties = true)
diff --git a/components/camel-zookeeper-master/src/main/java/org/apache/camel/component/zookeepermaster/MasterEndpoint.java b/components/camel-zookeeper-master/src/main/java/org/apache/camel/component/zookeepermaster/MasterEndpoint.java
index 1473b05..f976875 100644
--- a/components/camel-zookeeper-master/src/main/java/org/apache/camel/component/zookeepermaster/MasterEndpoint.java
+++ b/components/camel-zookeeper-master/src/main/java/org/apache/camel/component/zookeepermaster/MasterEndpoint.java
@@ -29,7 +29,7 @@ import org.apache.camel.spi.UriPath;
import org.apache.camel.support.DefaultEndpoint;
/**
- * Represents an endpoint which only becomes active when it obtains the master lock
+ * Have only a single consumer in a cluster consuming from a given endpoint; with automatic failover if the JVM dies.
*/
@ManagedResource(description = "Managed ZooKeeper Master Endpoint")
@UriEndpoint(firstVersion = "2.19.0", scheme = "zookeeper-master", syntax = "zookeeper-master:groupName:consumerEndpointUri", consumerOnly = true,
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 4bb31fc..ca24e4b 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
@@ -29,7 +29,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.support.DefaultEndpoint;
/**
- * The zookeeper component allows interaction with a ZooKeeper cluster.
+ * Manage ZooKeeper clusters.
*/
@ManagedResource(description = "ZooKeeper Endpoint")
@UriEndpoint(firstVersion = "2.9.0", scheme = "zookeeper", title = "ZooKeeper", syntax = "zookeeper:serverUrls/path", label = "clustering")