You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by gn...@apache.org on 2019/06/17 19:09:44 UTC
[camel] branch master updated (bf12b0b -> 08d401c)
This is an automated email from the ASF dual-hosted git repository.
gnodet pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git.
from bf12b0b Regen
new 5c086e3 Use a dedicated method to cast
new 4f081d0 Use the CamelContext instead of the RouteContext
new 184ca6a Fix bad reference in javadoc
new fed5ab3 [CAMEL-8362] Fully integrate the endpoint dsl in the java dsl
new 08d401c Fix indentation for generated enums
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../java/org/apache/camel/spi/RouteContext.java | 9 -
.../camel/impl/engine/DefaultRouteContext.java | 15 -
.../camel/builder/EndpointConsumerBuilder.java | 4 +-
.../camel/builder/EndpointProducerBuilder.java | 7 +-
.../apache/camel/model/ProcessorDefinition.java | 703 ++++++++++++++++-----
.../org/apache/camel/model/RouteDefinition.java | 6 +
.../java/org/apache/camel/model/ToDefinition.java | 5 +
.../apache/camel/model/ToDynamicDefinition.java | 12 +
.../org/apache/camel/reifier/RouteReifier.java | 2 +-
.../java/org/apache/camel/reifier/SendReifier.java | 2 +-
.../org/apache/camel/reifier/ToDynamicReifier.java | 18 +-
.../org/apache/camel/reifier/WireTapReifier.java | 6 +-
core/camel-endpointdsl/pom.xml | 14 +
.../builder/endpoint/AbstractEndpointBuilder.java | 21 +-
.../builder/endpoint/EndpointBuilderFactory.java | 21 +
.../builder/endpoint/EndpointRouteBuilder.java | 30 +
.../endpoint/dsl/AMQPEndpointBuilderFactory.java | 20 +-
.../endpoint/dsl/AS2EndpointBuilderFactory.java | 146 ++---
.../dsl/ActiveMQEndpointBuilderFactory.java | 20 +-
.../dsl/AsteriskEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/AtmosEndpointBuilderFactory.java | 8 +-
.../dsl/AtomixMapEndpointBuilderFactory.java | 28 +-
.../dsl/AtomixMessagingEndpointBuilderFactory.java | 10 +-
.../dsl/AtomixMultiMapEndpointBuilderFactory.java | 20 +-
.../dsl/AtomixQueueEndpointBuilderFactory.java | 22 +-
.../dsl/AtomixSetEndpointBuilderFactory.java | 16 +-
.../dsl/AtomixValueEndpointBuilderFactory.java | 12 +-
.../endpoint/dsl/AvroEndpointBuilderFactory.java | 2 +-
.../dsl/BeanstalkEndpointBuilderFactory.java | 10 +-
.../dsl/BlobServiceEndpointBuilderFactory.java | 30 +-
.../endpoint/dsl/BoxEndpointBuilderFactory.java | 22 +-
.../dsl/BraintreeEndpointBuilderFactory.java | 32 +-
.../dsl/CaffeineCacheEndpointBuilderFactory.java | 2 +-
.../CaffeineLoadCacheEndpointBuilderFactory.java | 2 +-
.../dsl/CassandraEndpointBuilderFactory.java | 20 +-
.../endpoint/dsl/ClientEndpointBuilderFactory.java | 8 +-
.../dsl/CryptoCmsEndpointBuilderFactory.java | 6 +-
.../endpoint/dsl/CxfEndpointBuilderFactory.java | 8 +-
.../endpoint/dsl/CxfRsEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/DdbEndpointBuilderFactory.java | 18 +-
.../dsl/DdbStreamEndpointBuilderFactory.java | 6 +-
.../dsl/DigitalOceanEndpointBuilderFactory.java | 90 +--
.../DigitalSignatureEndpointBuilderFactory.java | 2 +-
.../dsl/DisruptorEndpointBuilderFactory.java | 8 +-
.../dsl/DisruptorVmEndpointBuilderFactory.java | 8 +-
.../endpoint/dsl/DnsEndpointBuilderFactory.java | 6 +-
.../endpoint/dsl/DockerEndpointBuilderFactory.java | 72 +--
.../endpoint/dsl/DrillEndpointBuilderFactory.java | 2 +-
.../dsl/DropboxEndpointBuilderFactory.java | 10 +-
.../endpoint/dsl/EC2EndpointBuilderFactory.java | 20 +-
.../endpoint/dsl/ECSEndpointBuilderFactory.java | 6 +-
.../endpoint/dsl/EKSEndpointBuilderFactory.java | 6 +-
.../dsl/EhcacheEndpointBuilderFactory.java | 12 +-
.../dsl/ElasticsearchEndpointBuilderFactory.java | 24 +-
.../endpoint/dsl/ElsqlEndpointBuilderFactory.java | 16 +-
.../endpoint/dsl/EtcdEndpointBuilderFactory.java | 4 +-
.../dsl/FacebookEndpointBuilderFactory.java | 10 +-
.../endpoint/dsl/FhirEndpointBuilderFactory.java | 44 +-
.../endpoint/dsl/FileEndpointBuilderFactory.java | 10 +-
.../dsl/FlatpackEndpointBuilderFactory.java | 2 +-
.../endpoint/dsl/FlinkEndpointBuilderFactory.java | 2 +-
.../endpoint/dsl/FopEndpointBuilderFactory.java | 18 +-
.../endpoint/dsl/FtpEndpointBuilderFactory.java | 14 +-
.../endpoint/dsl/FtpsEndpointBuilderFactory.java | 14 +-
.../dsl/GangliaEndpointBuilderFactory.java | 24 +-
.../endpoint/dsl/GitEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/GitHubEndpointBuilderFactory.java | 16 +-
.../dsl/GoogleCalendarEndpointBuilderFactory.java | 14 +-
.../dsl/GoogleDriveEndpointBuilderFactory.java | 24 +-
.../dsl/GoogleMailEndpointBuilderFactory.java | 12 +-
.../dsl/GooglePubsubEndpointBuilderFactory.java | 2 +-
.../dsl/GoogleSheetsEndpointBuilderFactory.java | 2 +-
.../endpoint/dsl/GridFsEndpointBuilderFactory.java | 8 +-
.../endpoint/dsl/GrpcEndpointBuilderFactory.java | 16 +-
...azelcastAtomicnumberEndpointBuilderFactory.java | 70 +-
.../HazelcastInstanceEndpointBuilderFactory.java | 72 +--
.../dsl/HazelcastListEndpointBuilderFactory.java | 72 +--
.../dsl/HazelcastMapEndpointBuilderFactory.java | 72 +--
.../HazelcastMultimapEndpointBuilderFactory.java | 72 +--
.../dsl/HazelcastQueueEndpointBuilderFactory.java | 72 +--
...zelcastReplicatedmapEndpointBuilderFactory.java | 72 +--
.../HazelcastRingbufferEndpointBuilderFactory.java | 70 +-
.../dsl/HazelcastSedaEndpointBuilderFactory.java | 72 +--
.../dsl/HazelcastSetEndpointBuilderFactory.java | 72 +--
.../dsl/HazelcastTopicEndpointBuilderFactory.java | 72 +--
.../endpoint/dsl/HdfsEndpointBuilderFactory.java | 34 +-
.../endpoint/dsl/HttpEndpointBuilderFactory.java | 14 +-
.../endpoint/dsl/IAMEndpointBuilderFactory.java | 24 +-
.../dsl/IgniteCacheEndpointBuilderFactory.java | 22 +-
.../dsl/IgniteComputeEndpointBuilderFactory.java | 12 +-
.../dsl/IgniteIdGenEndpointBuilderFactory.java | 8 +-
.../dsl/IgniteMessagingEndpointBuilderFactory.java | 2 +-
.../dsl/IgniteQueueEndpointBuilderFactory.java | 28 +-
.../dsl/IgniteSetEndpointBuilderFactory.java | 14 +-
.../dsl/InfinispanEndpointBuilderFactory.java | 100 +--
.../endpoint/dsl/JCacheEndpointBuilderFactory.java | 6 +-
.../dsl/JcloudsEndpointBuilderFactory.java | 2 +-
.../endpoint/dsl/JdbcEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/JiraEndpointBuilderFactory.java | 16 +-
.../endpoint/dsl/JmsEndpointBuilderFactory.java | 20 +-
.../endpoint/dsl/JoltEndpointBuilderFactory.java | 10 +-
.../endpoint/dsl/JooqEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/JpaEndpointBuilderFactory.java | 14 +-
.../endpoint/dsl/Jt400EndpointBuilderFactory.java | 16 +-
.../endpoint/dsl/KMSEndpointBuilderFactory.java | 10 +-
.../dsl/KinesisEndpointBuilderFactory.java | 12 +-
.../endpoint/dsl/LambdaEndpointBuilderFactory.java | 26 +-
.../dsl/LinkedInEndpointBuilderFactory.java | 30 +-
.../endpoint/dsl/LogEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/LuceneEndpointBuilderFactory.java | 2 +-
.../endpoint/dsl/MQEndpointBuilderFactory.java | 10 +-
.../endpoint/dsl/MQTTEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/MSKEndpointBuilderFactory.java | 6 +-
.../dsl/MetricsEndpointBuilderFactory.java | 10 +-
.../dsl/MicrometerEndpointBuilderFactory.java | 10 +-
.../endpoint/dsl/Mina2EndpointBuilderFactory.java | 8 +-
.../dsl/MongoDbEndpointBuilderFactory.java | 30 +-
.../dsl/MyBatisBeanEndpointBuilderFactory.java | 4 +-
.../dsl/MyBatisEndpointBuilderFactory.java | 18 +-
.../endpoint/dsl/NagiosEndpointBuilderFactory.java | 16 +-
.../endpoint/dsl/NettyEndpointBuilderFactory.java | 2 +-
.../endpoint/dsl/PahoEndpointBuilderFactory.java | 2 +-
.../endpoint/dsl/PdfEndpointBuilderFactory.java | 6 +-
.../endpoint/dsl/PulsarEndpointBuilderFactory.java | 4 +-
.../dsl/QueueServiceEndpointBuilderFactory.java | 14 +-
.../dsl/ReactiveStreamsEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/RedisEndpointBuilderFactory.java | 256 ++++----
.../endpoint/dsl/RestEndpointBuilderFactory.java | 8 +-
.../endpoint/dsl/S3EndpointBuilderFactory.java | 12 +-
.../endpoint/dsl/SagaEndpointBuilderFactory.java | 2 +-
.../dsl/SalesforceEndpointBuilderFactory.java | 110 ++--
.../endpoint/dsl/SdbEndpointBuilderFactory.java | 16 +-
.../endpoint/dsl/ServerEndpointBuilderFactory.java | 8 +-
.../dsl/ServiceNowEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/SftpEndpointBuilderFactory.java | 14 +-
.../endpoint/dsl/Sjms2EndpointBuilderFactory.java | 6 +-
.../endpoint/dsl/SjmsEndpointBuilderFactory.java | 6 +-
.../endpoint/dsl/SmppEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/SnmpEndpointBuilderFactory.java | 4 +-
.../dsl/SoroushBotEndpointBuilderFactory.java | 6 +-
.../endpoint/dsl/SplunkEndpointBuilderFactory.java | 6 +-
.../dsl/SpringLdapEndpointBuilderFactory.java | 10 +-
.../SpringWebserviceEndpointBuilderFactory.java | 14 +-
.../endpoint/dsl/SqlEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/SqsEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/ThriftEndpointBuilderFactory.java | 12 +-
.../endpoint/dsl/TikaEndpointBuilderFactory.java | 8 +-
.../endpoint/dsl/TwilioEndpointBuilderFactory.java | 110 ++--
...TwitterDirectMessageEndpointBuilderFactory.java | 4 +-
.../dsl/TwitterSearchEndpointBuilderFactory.java | 4 +-
.../TwitterStreamingEndpointBuilderFactory.java | 10 +-
.../dsl/TwitterTimelineEndpointBuilderFactory.java | 14 +-
.../dsl/WeatherEndpointBuilderFactory.java | 56 +-
.../dsl/XChangeEndpointBuilderFactory.java | 18 +-
.../endpoint/dsl/XQueryEndpointBuilderFactory.java | 12 +-
.../dsl/XmlSignatureEndpointBuilderFactory.java | 2 +-
.../endpoint/dsl/XsltEndpointBuilderFactory.java | 6 +-
.../endpoint/dsl/YammerEndpointBuilderFactory.java | 16 +-
.../endpoint/ProcessorDefinitionDslTest.java | 67 ++
.../src/test/resources/log4j2.properties | 0
.../camel/maven/packaging/srcgen/JavaClass.java | 2 +-
161 files changed, 2295 insertions(+), 1783 deletions(-)
create mode 100644 core/camel-endpointdsl/src/test/java/org/apache/camel/builder/endpoint/ProcessorDefinitionDslTest.java
copy core/{camel-management-impl => camel-endpointdsl}/src/test/resources/log4j2.properties (100%)
[camel] 04/05: [CAMEL-8362] Fully integrate the endpoint dsl in the
java dsl
Posted by gn...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
gnodet pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit fed5ab34eefbf00a59ab9ea2403b0df4070e311b
Author: Guillaume Nodet <gn...@gmail.com>
AuthorDate: Mon Jun 17 20:59:07 2019 +0200
[CAMEL-8362] Fully integrate the endpoint dsl in the java dsl
WIth support for recipientList, routingSlip, wireTap, enrich, toD
---
.../camel/builder/EndpointProducerBuilder.java | 3 +
.../apache/camel/model/ProcessorDefinition.java | 463 +++++++++++++++++++--
.../org/apache/camel/model/RouteDefinition.java | 6 +
.../java/org/apache/camel/model/ToDefinition.java | 5 +
.../apache/camel/model/ToDynamicDefinition.java | 12 +
.../org/apache/camel/reifier/ToDynamicReifier.java | 18 +-
.../org/apache/camel/reifier/WireTapReifier.java | 6 +-
core/camel-endpointdsl/pom.xml | 14 +
.../builder/endpoint/AbstractEndpointBuilder.java | 14 +-
.../builder/endpoint/EndpointBuilderFactory.java | 21 +
.../endpoint/ProcessorDefinitionDslTest.java | 67 +++
.../src/test/resources/log4j2.properties | 49 +++
12 files changed, 643 insertions(+), 35 deletions(-)
diff --git a/core/camel-core/src/main/java/org/apache/camel/builder/EndpointProducerBuilder.java b/core/camel-core/src/main/java/org/apache/camel/builder/EndpointProducerBuilder.java
index d003692..b08034b 100644
--- a/core/camel-core/src/main/java/org/apache/camel/builder/EndpointProducerBuilder.java
+++ b/core/camel-core/src/main/java/org/apache/camel/builder/EndpointProducerBuilder.java
@@ -18,6 +18,7 @@ package org.apache.camel.builder;
import org.apache.camel.CamelContext;
import org.apache.camel.Endpoint;
+import org.apache.camel.Expression;
import org.apache.camel.NoSuchEndpointException;
public interface EndpointProducerBuilder {
@@ -28,4 +29,6 @@ public interface EndpointProducerBuilder {
void setProperty(String name, Object value);
+ Expression expr();
+
}
diff --git a/core/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java b/core/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
index b6439c5..ce50486 100644
--- a/core/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
+++ b/core/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
@@ -265,6 +265,19 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
/**
* Sends the exchange to the given dynamic endpoint
*
+ * @param endpointProducerBuilder the dynamic endpoint to send to (resolved using simple language by default)
+ * @return the builder
+ */
+ public Type toD(@AsEndpointUri EndpointProducerBuilder endpointProducerBuilder) {
+ ToDynamicDefinition answer = new ToDynamicDefinition();
+ answer.setEndpointProducerBuilder(endpointProducerBuilder);
+ addOutput(answer);
+ return asType();
+ }
+
+ /**
+ * Sends the exchange to the given dynamic endpoint
+ *
* @param uri the dynamic endpoint to send to (resolved using simple language by default)
* @param cacheSize sets the maximum size used by the {@link org.apache.camel.spi.ConsumerCache} which is used to cache and reuse producers.
*
@@ -281,6 +294,22 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
/**
* Sends the exchange to the given dynamic endpoint
*
+ * @param endpointProducerBuilder the dynamic endpoint to send to (resolved using simple language by default)
+ * @param cacheSize sets the maximum size used by the {@link org.apache.camel.spi.ConsumerCache} which is used to cache and reuse producers.
+ *
+ * @return the builder
+ */
+ public Type toD(@AsEndpointUri EndpointProducerBuilder endpointProducerBuilder, int cacheSize) {
+ ToDynamicDefinition answer = new ToDynamicDefinition();
+ answer.setEndpointProducerBuilder(endpointProducerBuilder);
+ answer.setCacheSize(cacheSize);
+ addOutput(answer);
+ return asType();
+ }
+
+ /**
+ * Sends the exchange to the given dynamic endpoint
+ *
* @param uri the dynamic endpoint to send to (resolved using simple language by default)
* @param ignoreInvalidEndpoint ignore the invalidate endpoint exception when try to create a producer with that endpoint
* @return the builder
@@ -294,6 +323,21 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
}
/**
+ * Sends the exchange to the given dynamic endpoint
+ *
+ * @param endpointProducerBuilder the dynamic endpoint to send to (resolved using simple language by default)
+ * @param ignoreInvalidEndpoint ignore the invalidate endpoint exception when try to create a producer with that endpoint
+ * @return the builder
+ */
+ public Type toD(@AsEndpointUri EndpointProducerBuilder endpointProducerBuilder, boolean ignoreInvalidEndpoint) {
+ ToDynamicDefinition answer = new ToDynamicDefinition();
+ answer.setEndpointProducerBuilder(endpointProducerBuilder);
+ answer.setIgnoreInvalidEndpoint(ignoreInvalidEndpoint);
+ addOutput(answer);
+ return asType();
+ }
+
+ /**
* Sends the exchange to the given endpoint
*
* @param uri the String formatted endpoint uri to send to
@@ -355,7 +399,13 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
return asType();
}
- public Type to(EndpointProducerBuilder endpoint) {
+ /**
+ * Sends the exchange to the given endpoint
+ *
+ * @param endpoint the endpoint to send to
+ * @return the builder
+ */
+ public Type to(@AsEndpointUri EndpointProducerBuilder endpoint) {
addOutput(new ToDefinition(endpoint));
return asType();
}
@@ -372,7 +422,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
public Type to(ExchangePattern pattern, @AsEndpointUri String uri) {
addOutput(new ToDefinition(uri, pattern));
return asType();
- }
+ }
/**
* Sends the exchange with certain exchange pattern to the given endpoint
@@ -389,6 +439,20 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
}
/**
+ * Sends the exchange with certain exchange pattern to the given endpoint
+ * <p/>
+ * Notice the existing MEP is preserved
+ *
+ * @param pattern the pattern to use for the message exchange
+ * @param endpoint the endpoint to send to
+ * @return the builder
+ */
+ public Type to(ExchangePattern pattern, EndpointProducerBuilder endpoint) {
+ addOutput(new ToDefinition(endpoint, pattern));
+ return asType();
+ }
+
+ /**
* Sends the exchange to a list of endpoints
*
* @param uris list of endpoints to send to
@@ -429,6 +493,19 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
/**
* Sends the exchange to a list of endpoints
+ *
+ * @param endpoints list of endpoints to send to
+ * @return the builder
+ */
+ public Type to(@AsEndpointUri EndpointProducerBuilder... endpoints) {
+ for (EndpointProducerBuilder endpoint : endpoints) {
+ addOutput(new ToDefinition(endpoint));
+ }
+ return asType();
+ }
+
+ /**
+ * Sends the exchange to a list of endpoints
* <p/>
* Notice the existing MEP is preserved
*
@@ -474,6 +551,22 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
}
/**
+ * Sends the exchange to a list of endpoints
+ * <p/>
+ * Notice the existing MEP is preserved
+ *
+ * @param pattern the pattern to use for the message exchanges
+ * @param endpoints list of endpoints to send to
+ * @return the builder
+ */
+ public Type to(ExchangePattern pattern, @AsEndpointUri EndpointProducerBuilder... endpoints) {
+ for (EndpointProducerBuilder endpoint : endpoints) {
+ addOutput(new ToDefinition(endpoint, pattern));
+ }
+ return asType();
+ }
+
+ /**
* <a href="http://camel.apache.org/exchange-pattern.html">ExchangePattern:</a>
* set the {@link ExchangePattern} into the {@link Exchange}.
* <p/>
@@ -1983,6 +2076,22 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* destination gets a copy of the original message to avoid the processors
* interfering with each other using {@link ExchangePattern#InOnly}.
*
+ * @param endpoint the endpoint to wiretap to
+ * @return the builder
+ */
+ public WireTapDefinition<Type> wireTap(@AsEndpointUri EndpointProducerBuilder endpoint) {
+ WireTapDefinition answer = new WireTapDefinition();
+ answer.setEndpointProducerBuilder(endpoint);
+ addOutput(answer);
+ return answer;
+ }
+
+ /**
+ * <a href="http://camel.apache.org/wiretap.html">WireTap EIP:</a>
+ * Sends messages to all its child outputs; so that each processor and
+ * destination gets a copy of the original message to avoid the processors
+ * interfering with each other using {@link ExchangePattern#InOnly}.
+ *
* @param uri the dynamic endpoint to wiretap to (resolved using simple language by default)
* @return the builder
*/
@@ -2704,7 +2813,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
/**
* The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
* enriches an exchange with additional data obtained from a <code>resourceUri</code>.
- *
+ *
* @param resourceUri URI of resource endpoint for obtaining additional data.
* @param aggregationStrategy aggregation strategy to aggregate input data and additional data.
* @return the builder
@@ -2716,9 +2825,37 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
/**
* The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
+ * enriches an exchange with additional data obtained from a <code>resourceUri</code>.
+ * <p/>
+ * The difference between this and {@link #pollEnrich(String)} is that this uses a producer
+ * to obatin the additional data, where as pollEnrich uses a polling consumer.
+ *
+ * @param resourceUri URI of resource endpoint for obtaining additional data.
+ * @return the builder
+ * @see org.apache.camel.processor.Enricher
+ */
+ public Type enrich(@AsEndpointUri EndpointProducerBuilder resourceUri) {
+ return enrich(resourceUri, null);
+ }
+
+ /**
+ * The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
+ * enriches an exchange with additional data obtained from a <code>resourceUri</code>.
+ *
+ * @param resourceUri URI of resource endpoint for obtaining additional data.
+ * @param aggregationStrategy aggregation strategy to aggregate input data and additional data.
+ * @return the builder
+ * @see org.apache.camel.processor.Enricher
+ */
+ public Type enrich(@AsEndpointUri EndpointProducerBuilder resourceUri, AggregationStrategy aggregationStrategy) {
+ return enrich(resourceUri, aggregationStrategy, false);
+ }
+
+ /**
+ * The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
* enriches an exchange with additional data obtained from a <code>resourceUri</code> and
* with an aggregation strategy created using a fluent builder.
- *
+ *
* <blockquote><pre>{@code
* fom("direct:start")
* .enrichWith("direct:resource")
@@ -2759,6 +2896,47 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
/**
* The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
+ * enriches an exchange with additional data obtained from a <code>resourceUri</code> and
+ * with an aggregation strategy created using a fluent builder.
+ *
+ * <blockquote><pre>{@code
+ * fom("direct:start")
+ * .enrichWith("direct:resource")
+ * .body(String.class, (o, n) -> n + o);
+ * }</pre></blockquote>
+ *
+ * @param resourceUri URI of resource endpoint for obtaining additional data.
+ * @return the builder
+ * @see org.apache.camel.processor.Enricher
+ */
+ public EnrichClause<ProcessorDefinition<Type>> enrichWith(@AsEndpointUri EndpointProducerBuilder resourceUri) {
+ return enrichWith(resourceUri.getUri());
+ }
+
+ /**
+ * The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
+ * enriches an exchange with additional data obtained from a <code>resourceUri</code> and
+ * with an aggregation strategy created using a fluent builder.
+ */
+ public EnrichClause<ProcessorDefinition<Type>> enrichWith(@AsEndpointUri EndpointProducerBuilder resourceUri, boolean aggregateOnException) {
+ EnrichClause<ProcessorDefinition<Type>> clause = new EnrichClause<>(this);
+ enrich(resourceUri, clause, aggregateOnException, false);
+ return clause;
+ }
+
+ /**
+ * The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
+ * enriches an exchange with additional data obtained from a <code>resourceUri</code> and
+ * with an aggregation strategy created using a fluent builder.
+ */
+ public EnrichClause<ProcessorDefinition<Type>> enrichWith(@AsEndpointUri EndpointProducerBuilder resourceUri, boolean aggregateOnException, boolean shareUnitOfWork) {
+ EnrichClause<ProcessorDefinition<Type>> clause = new EnrichClause<>(this);
+ enrich(resourceUri, clause, aggregateOnException, shareUnitOfWork);
+ return clause;
+ }
+
+ /**
+ * The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
* enriches an exchange with additional data obtained from a <code>resourceUri</code>.
*
* @param resourceUri URI of resource endpoint for obtaining additional data.
@@ -2797,6 +2975,43 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
/**
* The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
* enriches an exchange with additional data obtained from a <code>resourceUri</code>.
+ *
+ * @param resourceUri URI of resource endpoint for obtaining additional data.
+ * @param aggregationStrategy aggregation strategy to aggregate input data and additional data.
+ * @param aggregateOnException whether to call {@link AggregationStrategy#aggregate(org.apache.camel.Exchange, org.apache.camel.Exchange)} if
+ * an exception was thrown.
+ * @return the builder
+ * @see org.apache.camel.processor.Enricher
+ */
+ public Type enrich(@AsEndpointUri EndpointProducerBuilder resourceUri, AggregationStrategy aggregationStrategy, boolean aggregateOnException) {
+ return enrich(resourceUri, aggregationStrategy, aggregateOnException, false);
+ }
+
+ /**
+ * The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
+ * enriches an exchange with additional data obtained from a <code>resourceUri</code>.
+ *
+ * @param resourceUri URI of resource endpoint for obtaining additional data.
+ * @param aggregationStrategy aggregation strategy to aggregate input data and additional data.
+ * @param aggregateOnException whether to call {@link AggregationStrategy#aggregate(org.apache.camel.Exchange, org.apache.camel.Exchange)} if
+ * an exception was thrown.
+ * @param shareUnitOfWork whether to share unit of work
+ * @return the builder
+ * @see org.apache.camel.processor.Enricher
+ */
+ public Type enrich(@AsEndpointUri EndpointProducerBuilder resourceUri, AggregationStrategy aggregationStrategy, boolean aggregateOnException, boolean shareUnitOfWork) {
+ EnrichDefinition answer = new EnrichDefinition();
+ answer.setExpression(resourceUri.expr());
+ answer.setAggregationStrategy(aggregationStrategy);
+ answer.setAggregateOnException(aggregateOnException);
+ answer.setShareUnitOfWork(shareUnitOfWork);
+ addOutput(answer);
+ return asType();
+ }
+
+ /**
+ * The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
+ * enriches an exchange with additional data obtained from a <code>resourceUri</code>.
* <p/>
* The difference between this and {@link #pollEnrich(String)} is that this uses a producer
* to obtain the additional data, where as pollEnrich uses a polling consumer.
@@ -2896,14 +3111,95 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
/**
* The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
+ * enriches an exchange with additional data obtained from a <code>resourceUri</code>
+ * using a {@link org.apache.camel.PollingConsumer} to poll the endpoint.
+ * <p/>
+ * The difference between this and {@link #enrich(String)} is that this uses a consumer
+ * to obtain the additional data, where as enrich uses a producer.
+ * <p/>
+ * This method will <tt>block</tt> until data is available, use the method with timeout if you do not
+ * want to risk waiting a long time before data is available from the resourceUri.
+ *
+ * @param resourceUri URI of resource endpoint for obtaining additional data.
+ * @return the builder
+ * @see org.apache.camel.processor.PollEnricher
+ */
+ public Type pollEnrich(EndpointProducerBuilder resourceUri) {
+ return pollEnrich(resourceUri.getUri());
+ }
+
+ /**
+ * The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
+ * enriches an exchange with additional data obtained from a <code>resourceUri</code>
+ * using a {@link org.apache.camel.PollingConsumer} to poll the endpoint.
+ * <p/>
+ * The difference between this and {@link #enrich(String)} is that this uses a consumer
+ * to obtain the additional data, where as enrich uses a producer.
+ * <p/>
+ * This method will <b>block</b> until data is available, use the method with timeout if you do not
+ * want to risk waiting a long time before data is available from the resourceUri.
+ *
+ * @param resourceUri URI of resource endpoint for obtaining additional data.
+ * @param aggregationStrategy aggregation strategy to aggregate input data and additional data.
+ * @return the builder
+ * @see org.apache.camel.processor.PollEnricher
+ */
+ public Type pollEnrich(EndpointProducerBuilder resourceUri, AggregationStrategy aggregationStrategy) {
+ return pollEnrich(resourceUri, -1, aggregationStrategy);
+ }
+
+ /**
+ * The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
+ * enriches an exchange with additional data obtained from a <code>resourceUri</code>
+ * using a {@link org.apache.camel.PollingConsumer} to poll the endpoint.
+ * <p/>
+ * The difference between this and {@link #enrich(String)} is that this uses a consumer
+ * to obtain the additional data, where as enrich uses a producer.
+ * <p/>
+ * The timeout controls which operation to use on {@link org.apache.camel.PollingConsumer}.
+ * If timeout is negative, we use <tt>receive</tt>. If timeout is 0 then we use <tt>receiveNoWait</tt>
+ * otherwise we use <tt>receive(timeout)</tt>.
+ *
+ * @param resourceUri URI of resource endpoint for obtaining additional data.
+ * @param timeout timeout in millis to wait at most for data to be available.
+ * @param aggregationStrategy aggregation strategy to aggregate input data and additional data.
+ * @return the builder
+ * @see org.apache.camel.processor.PollEnricher
+ */
+ public Type pollEnrich(EndpointProducerBuilder resourceUri, long timeout, AggregationStrategy aggregationStrategy) {
+ return pollEnrich(resourceUri, timeout, aggregationStrategy, false);
+ }
+
+ /**
+ * The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
+ * enriches an exchange with additional data obtained from a <code>resourceUri</code>
+ * using a {@link org.apache.camel.PollingConsumer} to poll the endpoint.
+ * <p/>
+ * The difference between this and {@link #enrich(String)} is that this uses a consumer
+ * to obtain the additional data, where as enrich uses a producer.
+ * <p/>
+ * The timeout controls which operation to use on {@link org.apache.camel.PollingConsumer}.
+ * If timeout is negative, we use <tt>receive</tt>. If timeout is 0 then we use <tt>receiveNoWait</tt>
+ * otherwise we use <tt>receive(timeout)</tt>.
+ *
+ * @param resourceUri URI of resource endpoint for obtaining additional data.
+ * @param timeout timeout in millis to wait at most for data to be available.
+ * @param aggregationStrategyRef Reference of aggregation strategy to aggregate input data and additional data.
+ * @return the builder
+ * @see org.apache.camel.processor.PollEnricher
+ */
+ public Type pollEnrich(EndpointProducerBuilder resourceUri, long timeout, String aggregationStrategyRef) {
+ return pollEnrich(resourceUri, timeout, aggregationStrategyRef, false);
+ }
+
+ /**
+ * The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
* enriches an exchange with additional data obtained from a <code>resourceUri</code>
* and with an aggregation strategy created using a fluent builder using
* a {@link org.apache.camel.PollingConsumer} to poll the endpoint.
*/
public EnrichClause<ProcessorDefinition<Type>> pollEnrichWith(@AsEndpointUri String resourceUri) {
- EnrichClause<ProcessorDefinition<Type>> clause = new EnrichClause<>(this);
- pollEnrich(resourceUri, -1, clause, false);
- return clause;
+ return pollEnrichWith(resourceUri, -1);
}
/**
@@ -2913,9 +3209,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* a {@link org.apache.camel.PollingConsumer} to poll the endpoint.
*/
public EnrichClause<ProcessorDefinition<Type>> pollEnrichWith(@AsEndpointUri String resourceUri, long timeout) {
- EnrichClause<ProcessorDefinition<Type>> clause = new EnrichClause<>(this);
- pollEnrich(resourceUri, timeout, clause, false);
- return clause;
+ return pollEnrichWith(resourceUri, timeout, false);
}
/**
@@ -2933,6 +3227,38 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
/**
* The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
* enriches an exchange with additional data obtained from a <code>resourceUri</code>
+ * and with an aggregation strategy created using a fluent builder using
+ * a {@link org.apache.camel.PollingConsumer} to poll the endpoint.
+ */
+ public EnrichClause<ProcessorDefinition<Type>> pollEnrichWith(EndpointProducerBuilder resourceUri) {
+ return pollEnrichWith(resourceUri, -1);
+ }
+
+ /**
+ * The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
+ * enriches an exchange with additional data obtained from a <code>resourceUri</code>
+ * and with an aggregation strategy created using a fluent builder using
+ * a {@link org.apache.camel.PollingConsumer} to poll the endpoint.
+ */
+ public EnrichClause<ProcessorDefinition<Type>> pollEnrichWith(EndpointProducerBuilder resourceUri, long timeout) {
+ return pollEnrichWith(resourceUri, timeout, false);
+ }
+
+ /**
+ * The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
+ * enriches an exchange with additional data obtained from a <code>resourceUri</code>
+ * and with an aggregation strategy created using a fluent builder using
+ * a {@link org.apache.camel.PollingConsumer} to poll the endpoint.
+ */
+ public EnrichClause<ProcessorDefinition<Type>> pollEnrichWith(EndpointProducerBuilder resourceUri, long timeout, boolean aggregateOnException) {
+ EnrichClause<ProcessorDefinition<Type>> clause = new EnrichClause<>(this);
+ pollEnrich(resourceUri, timeout, clause, aggregateOnException);
+ return clause;
+ }
+
+ /**
+ * The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
+ * enriches an exchange with additional data obtained from a <code>resourceUri</code>
* using a {@link org.apache.camel.PollingConsumer} to poll the endpoint.
* <p/>
* The difference between this and {@link #enrich(String)} is that this uses a consumer
@@ -2951,13 +3277,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @see org.apache.camel.processor.PollEnricher
*/
public Type pollEnrich(@AsEndpointUri String resourceUri, long timeout, AggregationStrategy aggregationStrategy, boolean aggregateOnException) {
- PollEnrichDefinition pollEnrich = new PollEnrichDefinition();
- pollEnrich.setExpression(new ConstantExpression(resourceUri));
- pollEnrich.setTimeout(timeout);
- pollEnrich.setAggregationStrategy(aggregationStrategy);
- pollEnrich.setAggregateOnException(aggregateOnException);
- addOutput(pollEnrich);
- return asType();
+ return pollEnrich(new ConstantExpression(resourceUri), timeout, aggregationStrategy, aggregateOnException);
}
/**
@@ -2981,13 +3301,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @see org.apache.camel.processor.PollEnricher
*/
public Type pollEnrich(@AsEndpointUri String resourceUri, long timeout, String aggregationStrategyRef, boolean aggregateOnException) {
- PollEnrichDefinition pollEnrich = new PollEnrichDefinition();
- pollEnrich.setExpression(new ConstantExpression(resourceUri));
- pollEnrich.setTimeout(timeout);
- pollEnrich.setAggregationStrategyRef(aggregationStrategyRef);
- pollEnrich.setAggregateOnException(aggregateOnException);
- addOutput(pollEnrich);
- return asType();
+ return pollEnrich(new ConstantExpression(resourceUri), timeout, aggregationStrategyRef, aggregateOnException);
}
/**
@@ -3023,6 +3337,75 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* If timeout is negative, we use <tt>receive</tt>. If timeout is 0 then we use <tt>receiveNoWait</tt>
* otherwise we use <tt>receive(timeout)</tt>.
*
+ * @param resourceUri URI of resource endpoint for obtaining additional data.
+ * @param timeout timeout in millis to wait at most for data to be available.
+ * @param aggregationStrategy aggregation strategy to aggregate input data and additional data.
+ * @param aggregateOnException whether to call {@link AggregationStrategy#aggregate(org.apache.camel.Exchange, org.apache.camel.Exchange)} if
+ * an exception was thrown.
+ * @return the builder
+ * @see org.apache.camel.processor.PollEnricher
+ */
+ public Type pollEnrich(@AsEndpointUri EndpointProducerBuilder resourceUri, long timeout, AggregationStrategy aggregationStrategy, boolean aggregateOnException) {
+ return pollEnrich(resourceUri.expr(), timeout, aggregationStrategy, aggregateOnException);
+ }
+
+ /**
+ * The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
+ * enriches an exchange with additional data obtained from a <code>resourceUri</code>
+ * using a {@link org.apache.camel.PollingConsumer} to poll the endpoint.
+ * <p/>
+ * The difference between this and {@link #enrich(String)} is that this uses a consumer
+ * to obtain the additional data, where as enrich uses a producer.
+ * <p/>
+ * The timeout controls which operation to use on {@link org.apache.camel.PollingConsumer}.
+ * If timeout is negative, we use <tt>receive</tt>. If timeout is 0 then we use <tt>receiveNoWait</tt>
+ * otherwise we use <tt>receive(timeout)</tt>.
+ *
+ * @param resourceUri URI of resource endpoint for obtaining additional data.
+ * @param timeout timeout in millis to wait at most for data to be available.
+ * @param aggregationStrategyRef Reference of aggregation strategy to aggregate input data and additional data.
+ * @param aggregateOnException whether to call {@link AggregationStrategy#aggregate(org.apache.camel.Exchange, org.apache.camel.Exchange)} if
+ * an exception was thrown.
+ * @return the builder
+ * @see org.apache.camel.processor.PollEnricher
+ */
+ public Type pollEnrich(@AsEndpointUri EndpointProducerBuilder resourceUri, long timeout, String aggregationStrategyRef, boolean aggregateOnException) {
+ return pollEnrich(resourceUri.expr(), timeout, aggregationStrategyRef, aggregateOnException);
+ }
+
+ /**
+ * The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
+ * enriches an exchange with additional data obtained from a <code>resourceUri</code>
+ * using a {@link org.apache.camel.PollingConsumer} to poll the endpoint.
+ * <p/>
+ * The difference between this and {@link #enrich(String)} is that this uses a consumer
+ * to obtain the additional data, where as enrich uses a producer.
+ * <p/>
+ * The timeout controls which operation to use on {@link org.apache.camel.PollingConsumer}.
+ * If timeout is negative, we use <tt>receive</tt>. If timeout is 0 then we use <tt>receiveNoWait</tt>
+ * otherwise we use <tt>receive(timeout)</tt>.
+ *
+ * @param resourceUri URI of resource endpoint for obtaining additional data.
+ * @param timeout timeout in millis to wait at most for data to be available.
+ * @return the builder
+ * @see org.apache.camel.processor.PollEnricher
+ */
+ public Type pollEnrich(@AsEndpointUri EndpointProducerBuilder resourceUri, long timeout) {
+ return pollEnrich(resourceUri, timeout, (String) null);
+ }
+
+ /**
+ * The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
+ * enriches an exchange with additional data obtained from a <code>resourceUri</code>
+ * using a {@link org.apache.camel.PollingConsumer} to poll the endpoint.
+ * <p/>
+ * The difference between this and {@link #enrich(String)} is that this uses a consumer
+ * to obtain the additional data, where as enrich uses a producer.
+ * <p/>
+ * The timeout controls which operation to use on {@link org.apache.camel.PollingConsumer}.
+ * If timeout is negative, we use <tt>receive</tt>. If timeout is 0 then we use <tt>receiveNoWait</tt>
+ * otherwise we use <tt>receive(timeout)</tt>.
+ *
* @param expression to use an expression to dynamically compute the endpoint to poll from
* @param timeout timeout in millis to wait at most for data to be available.
* @param aggregationStrategyRef Reference of aggregation strategy to aggregate input data and additional data.
@@ -3033,7 +3416,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
*/
public Type pollEnrich(@AsEndpointUri Expression expression, long timeout, String aggregationStrategyRef, boolean aggregateOnException) {
PollEnrichDefinition pollEnrich = new PollEnrichDefinition();
- pollEnrich.setExpression(new ExpressionDefinition(expression));
+ pollEnrich.setExpression(expression);
pollEnrich.setTimeout(timeout);
pollEnrich.setAggregationStrategyRef(aggregationStrategyRef);
pollEnrich.setAggregateOnException(aggregateOnException);
@@ -3053,6 +3436,36 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* If timeout is negative, we use <tt>receive</tt>. If timeout is 0 then we use <tt>receiveNoWait</tt>
* otherwise we use <tt>receive(timeout)</tt>.
*
+ * @param expression to use an expression to dynamically compute the endpoint to poll from
+ * @param timeout timeout in millis to wait at most for data to be available.
+ * @param aggregationStrategy aggregation strategy to aggregate input data and additional data.
+ * @param aggregateOnException whether to call {@link AggregationStrategy#aggregate(org.apache.camel.Exchange, org.apache.camel.Exchange)} if
+ * an exception was thrown.
+ * @return the builder
+ * @see org.apache.camel.processor.PollEnricher
+ */
+ public Type pollEnrich(@AsEndpointUri Expression expression, long timeout, AggregationStrategy aggregationStrategy, boolean aggregateOnException) {
+ PollEnrichDefinition pollEnrich = new PollEnrichDefinition();
+ pollEnrich.setExpression(expression);
+ pollEnrich.setTimeout(timeout);
+ pollEnrich.setAggregationStrategy(aggregationStrategy);
+ pollEnrich.setAggregateOnException(aggregateOnException);
+ addOutput(pollEnrich);
+ return asType();
+ }
+
+ /**
+ * The <a href="http://camel.apache.org/content-enricher.html">Content Enricher EIP</a>
+ * enriches an exchange with additional data obtained from a <code>resourceUri</code>
+ * using a {@link org.apache.camel.PollingConsumer} to poll the endpoint.
+ * <p/>
+ * The difference between this and {@link #enrich(String)} is that this uses a consumer
+ * to obtain the additional data, where as enrich uses a producer.
+ * <p/>
+ * The timeout controls which operation to use on {@link org.apache.camel.PollingConsumer}.
+ * If timeout is negative, we use <tt>receive</tt>. If timeout is 0 then we use <tt>receiveNoWait</tt>
+ * otherwise we use <tt>receive(timeout)</tt>.
+ *
* @return a expression builder clause to set the expression to use for computing the endpoint to poll from
* @see org.apache.camel.processor.PollEnricher
*/
diff --git a/core/camel-core/src/main/java/org/apache/camel/model/RouteDefinition.java b/core/camel-core/src/main/java/org/apache/camel/model/RouteDefinition.java
index 4489e25..338cf4d 100644
--- a/core/camel-core/src/main/java/org/apache/camel/model/RouteDefinition.java
+++ b/core/camel-core/src/main/java/org/apache/camel/model/RouteDefinition.java
@@ -169,6 +169,12 @@ public class RouteDefinition extends ProcessorDefinition<RouteDefinition> {
return this;
}
+ /**
+ * Creates an input to the route
+ *
+ * @param endpoint the from endpoint
+ * @return the builder
+ */
public RouteDefinition from(EndpointConsumerBuilder endpoint) {
setInput(new FromDefinition(endpoint));
return this;
diff --git a/core/camel-core/src/main/java/org/apache/camel/model/ToDefinition.java b/core/camel-core/src/main/java/org/apache/camel/model/ToDefinition.java
index 2a7ee92..78828ad 100644
--- a/core/camel-core/src/main/java/org/apache/camel/model/ToDefinition.java
+++ b/core/camel-core/src/main/java/org/apache/camel/model/ToDefinition.java
@@ -61,6 +61,11 @@ public class ToDefinition extends SendDefinition<ToDefinition> {
this.pattern = pattern;
}
+ public ToDefinition(EndpointProducerBuilder endpoint, ExchangePattern pattern) {
+ this(endpoint);
+ this.pattern = pattern;
+ }
+
@Override
public String getShortName() {
return "to";
diff --git a/core/camel-core/src/main/java/org/apache/camel/model/ToDynamicDefinition.java b/core/camel-core/src/main/java/org/apache/camel/model/ToDynamicDefinition.java
index 6f3c2ce..165376e 100644
--- a/core/camel-core/src/main/java/org/apache/camel/model/ToDynamicDefinition.java
+++ b/core/camel-core/src/main/java/org/apache/camel/model/ToDynamicDefinition.java
@@ -20,8 +20,10 @@ import javax.xml.bind.annotation.XmlAccessType;
import javax.xml.bind.annotation.XmlAccessorType;
import javax.xml.bind.annotation.XmlAttribute;
import javax.xml.bind.annotation.XmlRootElement;
+import javax.xml.bind.annotation.XmlTransient;
import org.apache.camel.ExchangePattern;
+import org.apache.camel.builder.EndpointProducerBuilder;
import org.apache.camel.spi.Metadata;
/**
@@ -40,6 +42,8 @@ public class ToDynamicDefinition extends NoOutputDefinition<ToDynamicDefinition>
@XmlAttribute @Metadata(required = true)
private String uri;
+ @XmlTransient
+ protected EndpointProducerBuilder endpointProducerBuilder;
@XmlAttribute
private ExchangePattern pattern;
@XmlAttribute
@@ -122,6 +126,14 @@ public class ToDynamicDefinition extends NoOutputDefinition<ToDynamicDefinition>
this.uri = uri;
}
+ public EndpointProducerBuilder getEndpointProducerBuilder() {
+ return endpointProducerBuilder;
+ }
+
+ public void setEndpointProducerBuilder(EndpointProducerBuilder endpointProducerBuilder) {
+ this.endpointProducerBuilder = endpointProducerBuilder;
+ }
+
public ExchangePattern getPattern() {
return pattern;
}
diff --git a/core/camel-core/src/main/java/org/apache/camel/reifier/ToDynamicReifier.java b/core/camel-core/src/main/java/org/apache/camel/reifier/ToDynamicReifier.java
index 0b1d264..042fede 100644
--- a/core/camel-core/src/main/java/org/apache/camel/reifier/ToDynamicReifier.java
+++ b/core/camel-core/src/main/java/org/apache/camel/reifier/ToDynamicReifier.java
@@ -40,11 +40,17 @@ class ToDynamicReifier<T extends ToDynamicDefinition> extends ProcessorReifier<T
@Override
public Processor createProcessor(RouteContext routeContext) throws Exception {
- StringHelper.notEmpty(definition.getUri(), "uri", this);
-
- Expression exp = createExpression(routeContext);
+ String uri;
+ Expression exp;
+ if (definition.getEndpointProducerBuilder() != null) {
+ uri = definition.getEndpointProducerBuilder().getUri();
+ exp = definition.getEndpointProducerBuilder().expr();
+ } else {
+ uri = StringHelper.notEmpty(definition.getUri(), "uri", this);
+ exp = createExpression(routeContext, uri);
+ }
- SendDynamicProcessor processor = new SendDynamicProcessor(definition.getUri(), exp);
+ SendDynamicProcessor processor = new SendDynamicProcessor(uri, exp);
processor.setCamelContext(routeContext.getCamelContext());
processor.setPattern(definition.getPattern());
if (definition.getCacheSize() != null) {
@@ -56,10 +62,10 @@ class ToDynamicReifier<T extends ToDynamicDefinition> extends ProcessorReifier<T
return processor;
}
- protected Expression createExpression(RouteContext routeContext) {
+ protected Expression createExpression(RouteContext routeContext, String uri) {
List<Expression> list = new ArrayList<>();
- String[] parts = safeSplitRaw(definition.getUri());
+ String[] parts = safeSplitRaw(uri);
for (String part : parts) {
// the part may have optional language to use, so you can mix languages
String value = StringHelper.after(part, "language:");
diff --git a/core/camel-core/src/main/java/org/apache/camel/reifier/WireTapReifier.java b/core/camel-core/src/main/java/org/apache/camel/reifier/WireTapReifier.java
index b889785..7b0f412 100644
--- a/core/camel-core/src/main/java/org/apache/camel/reifier/WireTapReifier.java
+++ b/core/camel-core/src/main/java/org/apache/camel/reifier/WireTapReifier.java
@@ -88,12 +88,12 @@ class WireTapReifier extends ToDynamicReifier<WireTapDefinition<?>> {
}
@Override
- protected Expression createExpression(RouteContext routeContext) {
+ protected Expression createExpression(RouteContext routeContext, String uri) {
// whether to use dynamic or static uri
if (definition.isDynamic()) {
- return super.createExpression(routeContext);
+ return super.createExpression(routeContext, uri);
} else {
- return ExpressionBuilder.constantExpression(definition.getUri());
+ return ExpressionBuilder.constantExpression(uri);
}
}
diff --git a/core/camel-endpointdsl/pom.xml b/core/camel-endpointdsl/pom.xml
index 63f9b65..ed085c3 100644
--- a/core/camel-endpointdsl/pom.xml
+++ b/core/camel-endpointdsl/pom.xml
@@ -61,6 +61,10 @@
<artifactId>camel-util-json</artifactId>
</dependency>
<dependency>
+ <groupId>org.apache.camel</groupId>
+ <artifactId>camel-jaxp</artifactId>
+ </dependency>
+ <dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
</dependency>
@@ -109,6 +113,16 @@
<artifactId>mockito-core</artifactId>
<scope>test</scope>
</dependency>
+ <dependency>
+ <groupId>org.apache.logging.log4j</groupId>
+ <artifactId>log4j-core</artifactId>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.logging.log4j</groupId>
+ <artifactId>log4j-slf4j-impl</artifactId>
+ <scope>test</scope>
+ </dependency>
</dependencies>
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/AbstractEndpointBuilder.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/AbstractEndpointBuilder.java
index 518c756..b243ac1 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/AbstractEndpointBuilder.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/AbstractEndpointBuilder.java
@@ -25,9 +25,13 @@ import javax.xml.bind.annotation.XmlTransient;
import org.apache.camel.CamelContext;
import org.apache.camel.Endpoint;
+import org.apache.camel.Exchange;
+import org.apache.camel.Expression;
import org.apache.camel.NoSuchEndpointException;
import org.apache.camel.RuntimeCamelException;
+import org.apache.camel.model.language.SimpleExpression;
import org.apache.camel.spi.RouteContext;
+import org.apache.camel.support.ExpressionAdapter;
import org.apache.camel.util.URISupport;
@XmlTransient
@@ -49,7 +53,7 @@ public class AbstractEndpointBuilder {
if (endpoint == null) {
throw new NoSuchEndpointException(uri);
}
- return null;
+ return endpoint;
}
public String getUri() {
@@ -89,4 +93,12 @@ public class AbstractEndpointBuilder {
public void setProperty(String key, Object value) {
this.properties.put(key, value);
}
+
+ /**
+ * Builds an expression that can be used
+ * @return
+ */
+ public Expression expr() {
+ return new SimpleExpression(getUri());
+ }
}
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
index 9faa1f4..9d3ec10 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
@@ -17,7 +17,15 @@
package org.apache.camel.builder.endpoint;
// CHECKSTYLE:OFF
+import java.util.List;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
+import org.apache.camel.Exchange;
+import org.apache.camel.Expression;
+import org.apache.camel.builder.EndpointProducerBuilder;
import org.apache.camel.builder.endpoint.dsl.*;
+import org.apache.camel.support.ExpressionAdapter;
public interface EndpointBuilderFactory extends
AMQPEndpointBuilderFactory,
@@ -317,4 +325,17 @@ public interface EndpointBuilderFactory extends
ZooKeeperEndpointBuilderFactory,
ZooKeeperMasterEndpointBuilderFactory
{
+
+ default Expression endpoints(EndpointProducerBuilder... endpoints) {
+ return new ExpressionAdapter() {
+ List<Expression> expressions = Stream.of(endpoints)
+ .map(EndpointProducerBuilder::expr).collect(Collectors.toList());
+ @Override
+ public Object evaluate(Exchange exchange) {
+ return expressions.stream().map(e -> e.evaluate(exchange, Object.class))
+ .collect(Collectors.toList());
+ }
+ };
+ }
+
}
diff --git a/core/camel-endpointdsl/src/test/java/org/apache/camel/builder/endpoint/ProcessorDefinitionDslTest.java b/core/camel-endpointdsl/src/test/java/org/apache/camel/builder/endpoint/ProcessorDefinitionDslTest.java
new file mode 100644
index 0000000..34fa6cb
--- /dev/null
+++ b/core/camel-endpointdsl/src/test/java/org/apache/camel/builder/endpoint/ProcessorDefinitionDslTest.java
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.builder.endpoint;
+
+import org.apache.camel.ContextTestSupport;
+import org.apache.camel.ResolveEndpointFailedException;
+import org.apache.camel.builder.EndpointProducerBuilder;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.mock.MockEndpoint;
+import org.junit.Test;
+
+public class ProcessorDefinitionDslTest extends ContextTestSupport {
+
+ @Test
+ public void testFlow() throws Exception {
+ MockEndpoint m1 = getMockEndpoint("mock:m1");
+ m1.expectedMessageCount(1);
+
+ MockEndpoint m2 = getMockEndpoint("mock:m2");
+ m2.expectedMessageCount(1);
+
+ MockEndpoint m3 = getMockEndpoint("mock:m3");
+ m3.expectedMessageCount(1);
+
+ template.requestBody("direct:a", "Hello World", String.class);
+
+ assertMockEndpointsSatisfied();
+ }
+
+ protected RouteBuilder createRouteBuilder() {
+ return new EndpointRouteBuilder() {
+ public void configure() {
+ from(direct("a"))
+ .recipientList(endpoints(mock("m1"), direct("b")))
+ .routingSlip(endpoints(mock("m2"), direct("c")))
+ .wireTap(direct("d"))
+ .enrich(direct("e"))
+ .toD(mock("${header.next}"));
+
+ from(direct("b")).to(log("endpoint.b"));
+ from(direct("c")).to(log("endpoint.c"));
+ from(direct("d")).to(log("endpoint.d"));
+ from(direct("e"))
+ .setBody(constant("body"))
+ .setHeader("next", constant("m3"));
+
+
+ }
+ };
+ }
+
+
+}
diff --git a/core/camel-endpointdsl/src/test/resources/log4j2.properties b/core/camel-endpointdsl/src/test/resources/log4j2.properties
new file mode 100644
index 0000000..a5b53e0
--- /dev/null
+++ b/core/camel-endpointdsl/src/test/resources/log4j2.properties
@@ -0,0 +1,49 @@
+## ---------------------------------------------------------------------------
+## Licensed to the Apache Software Foundation (ASF) under one or more
+## contributor license agreements. See the NOTICE file distributed with
+## this work for additional information regarding copyright ownership.
+## The ASF licenses this file to You under the Apache License, Version 2.0
+## (the "License"); you may not use this file except in compliance with
+## the License. You may obtain a copy of the License at
+##
+## http://www.apache.org/licenses/LICENSE-2.0
+##
+## Unless required by applicable law or agreed to in writing, software
+## distributed under the License is distributed on an "AS IS" BASIS,
+## WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+## See the License for the specific language governing permissions and
+## limitations under the License.
+## ---------------------------------------------------------------------------
+appender.console.type = Console
+appender.console.name = console
+appender.console.layout.type = PatternLayout
+appender.console.layout.pattern = %d [%-15.15t] %-5p %-30.30c{1} - %m%n
+
+appender.file.type = File
+appender.file.name = file
+appender.file.fileName = target/camel-core-test.log
+appender.file.append = true
+appender.file.layout.type = PatternLayout
+appender.file.layout.pattern = %d [%-15.15t] %-5p %-30.30c{1} - %m%n
+
+appender.file2.type = File
+appender.file2.name = file2
+appender.file2.fileName = target/custom-logger-test.log
+appender.file2.append = false
+appender.file2.layout.type = PatternLayout
+appender.file2.layout.pattern = %-5p %c{1} %m%n
+
+logger.customlogger.name = org.apache.camel.customlogger
+logger.customlogger.level = TRACE
+logger.customlogger.appenderRef.file2.ref = file2
+
+logger.file-cluster.name = org.apache.camel.component.file.cluster
+logger.file-cluster.level = DEBUG
+
+rootLogger.level = INFO
+
+rootLogger.appenderRef.file.ref = file
+#rootLogger.appenderRef.console.ref = console
+
+#logger.camel-core.name = org.apache.camel
+#logger.camel-core.level = TRACE
[camel] 03/05: Fix bad reference in javadoc
Posted by gn...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
gnodet pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 184ca6a4b37e4f9c46282b43d98c09cd3ce3791c
Author: Guillaume Nodet <gn...@gmail.com>
AuthorDate: Fri Jun 14 10:45:06 2019 +0200
Fix bad reference in javadoc
---
.../src/main/java/org/apache/camel/model/ProcessorDefinition.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/core/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java b/core/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
index 7ee70d0..b6439c5 100644
--- a/core/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
+++ b/core/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
@@ -1145,7 +1145,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
/**
* Creates a validation expression which only if it is <tt>true</tt> then the
* exchange is forwarded to the destination.
- * Otherwise a {@link org.apache.camel.processor.validation.PredicateValidationException} is thrown.
+ * Otherwise a {@link org.apache.camel.support.processor.validation.PredicateValidationException} is thrown.
*
* @param expression the expression
* @return the builder
@@ -1159,7 +1159,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
/**
* Creates a validation expression which only if it is <tt>true</tt> then the
* exchange is forwarded to the destination.
- * Otherwise a {@link org.apache.camel.processor.validation.PredicateValidationException} is thrown.
+ * Otherwise a {@link org.apache.camel.support.processor.validation.PredicateValidationException} is thrown.
*
* @param predicate the predicate
* @return the builder
@@ -1173,7 +1173,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
/**
* Creates a validation expression which only if it is <tt>true</tt> then the
* exchange is forwarded to the destination.
- * Otherwise a {@link org.apache.camel.processor.validation.PredicateValidationException} is thrown.
+ * Otherwise a {@link org.apache.camel.support.processor.validation.PredicateValidationException} is thrown.
*
* @return the builder
*/
[camel] 02/05: Use the CamelContext instead of the RouteContext
Posted by gn...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
gnodet pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 4f081d08b3da979dd8898a8fa47f2cde96f25284
Author: Guillaume Nodet <gn...@gmail.com>
AuthorDate: Fri Jun 14 10:38:33 2019 +0200
Use the CamelContext instead of the RouteContext
---
.../java/org/apache/camel/spi/RouteContext.java | 9 -------
.../camel/impl/engine/DefaultRouteContext.java | 15 -----------
.../camel/builder/EndpointConsumerBuilder.java | 4 +--
.../camel/builder/EndpointProducerBuilder.java | 4 +--
.../org/apache/camel/reifier/RouteReifier.java | 2 +-
.../java/org/apache/camel/reifier/SendReifier.java | 2 +-
.../builder/endpoint/AbstractEndpointBuilder.java | 9 +++++--
.../builder/endpoint/EndpointRouteBuilder.java | 30 ++++++++++++++++++++++
8 files changed, 43 insertions(+), 32 deletions(-)
diff --git a/core/camel-api/src/main/java/org/apache/camel/spi/RouteContext.java b/core/camel-api/src/main/java/org/apache/camel/spi/RouteContext.java
index a7c194a..48c8967 100644
--- a/core/camel-api/src/main/java/org/apache/camel/spi/RouteContext.java
+++ b/core/camel-api/src/main/java/org/apache/camel/spi/RouteContext.java
@@ -72,15 +72,6 @@ public interface RouteContext extends RuntimeConfiguration, EndpointAware {
Endpoint resolveEndpoint(String uri, String ref);
/**
- * Resolves an endpoint from the scheme, path and properties
- *
- * @param uri the URI scheme
- * @param properties the endpoint properties
- * @return the resolved endpoint
- */
- Endpoint resolveEndpoint(String uri, Map<String, Object> properties);
-
- /**
* lookup an object by name and type
*
* @param name the name to lookup
diff --git a/core/camel-base/src/main/java/org/apache/camel/impl/engine/DefaultRouteContext.java b/core/camel-base/src/main/java/org/apache/camel/impl/engine/DefaultRouteContext.java
index 1f52ff3..ebbc5a4 100644
--- a/core/camel-base/src/main/java/org/apache/camel/impl/engine/DefaultRouteContext.java
+++ b/core/camel-base/src/main/java/org/apache/camel/impl/engine/DefaultRouteContext.java
@@ -24,13 +24,11 @@ import java.util.Map;
import java.util.Set;
import org.apache.camel.CamelContext;
-import org.apache.camel.Component;
import org.apache.camel.Endpoint;
import org.apache.camel.ErrorHandlerFactory;
import org.apache.camel.NamedNode;
import org.apache.camel.NoSuchEndpointException;
import org.apache.camel.Processor;
-import org.apache.camel.ResolveEndpointFailedException;
import org.apache.camel.Route;
import org.apache.camel.RuntimeCamelException;
import org.apache.camel.ShutdownRoute;
@@ -46,8 +44,6 @@ import org.apache.camel.spi.RouteError;
import org.apache.camel.spi.RoutePolicy;
import org.apache.camel.support.CamelContextHelper;
import org.apache.camel.util.ObjectHelper;
-import org.apache.camel.util.StringHelper;
-import org.apache.camel.util.URISupport;
/**
* The context used to activate new routing rules
@@ -149,17 +145,6 @@ public class DefaultRouteContext implements RouteContext {
}
}
- public Endpoint resolveEndpoint(String uri, Map<String, Object> properties) {
- Endpoint endpoint = camelContext.hasEndpoint(uri);
- if (endpoint == null) {
- endpoint = camelContext.getEndpoint(uri, properties);
- }
- if (endpoint != null) {
- return endpoint;
- }
- throw new NoSuchEndpointException(uri);
- }
-
public <T> T lookup(String name, Class<T> type) {
return getCamelContext().getRegistry().lookupByNameAndType(name, type);
}
diff --git a/core/camel-core/src/main/java/org/apache/camel/builder/EndpointConsumerBuilder.java b/core/camel-core/src/main/java/org/apache/camel/builder/EndpointConsumerBuilder.java
index 77257bd..7d5b9ce 100644
--- a/core/camel-core/src/main/java/org/apache/camel/builder/EndpointConsumerBuilder.java
+++ b/core/camel-core/src/main/java/org/apache/camel/builder/EndpointConsumerBuilder.java
@@ -16,13 +16,13 @@
*/
package org.apache.camel.builder;
+import org.apache.camel.CamelContext;
import org.apache.camel.Endpoint;
import org.apache.camel.NoSuchEndpointException;
-import org.apache.camel.spi.RouteContext;
public interface EndpointConsumerBuilder {
- Endpoint resolve(RouteContext context) throws NoSuchEndpointException;
+ Endpoint resolve(CamelContext context) throws NoSuchEndpointException;
String getUri();
diff --git a/core/camel-core/src/main/java/org/apache/camel/builder/EndpointProducerBuilder.java b/core/camel-core/src/main/java/org/apache/camel/builder/EndpointProducerBuilder.java
index 2ced548..d003692 100644
--- a/core/camel-core/src/main/java/org/apache/camel/builder/EndpointProducerBuilder.java
+++ b/core/camel-core/src/main/java/org/apache/camel/builder/EndpointProducerBuilder.java
@@ -16,13 +16,13 @@
*/
package org.apache.camel.builder;
+import org.apache.camel.CamelContext;
import org.apache.camel.Endpoint;
import org.apache.camel.NoSuchEndpointException;
-import org.apache.camel.spi.RouteContext;
public interface EndpointProducerBuilder {
- Endpoint resolve(RouteContext context) throws NoSuchEndpointException;
+ Endpoint resolve(CamelContext context) throws NoSuchEndpointException;
String getUri();
diff --git a/core/camel-core/src/main/java/org/apache/camel/reifier/RouteReifier.java b/core/camel-core/src/main/java/org/apache/camel/reifier/RouteReifier.java
index ce36e23..1675c38 100644
--- a/core/camel-core/src/main/java/org/apache/camel/reifier/RouteReifier.java
+++ b/core/camel-core/src/main/java/org/apache/camel/reifier/RouteReifier.java
@@ -329,7 +329,7 @@ public class RouteReifier extends ProcessorReifier<RouteDefinition> {
if (endpoint == null) {
EndpointConsumerBuilder def = definition.getInput().getEndpointConsumerBuilder();
if (def != null) {
- endpoint = def.resolve(routeContext);
+ endpoint = def.resolve(routeContext.getCamelContext());
} else {
endpoint = routeContext.resolveEndpoint(definition.getInput().getEndpointUri());
}
diff --git a/core/camel-core/src/main/java/org/apache/camel/reifier/SendReifier.java b/core/camel-core/src/main/java/org/apache/camel/reifier/SendReifier.java
index e541143..9f2397a 100644
--- a/core/camel-core/src/main/java/org/apache/camel/reifier/SendReifier.java
+++ b/core/camel-core/src/main/java/org/apache/camel/reifier/SendReifier.java
@@ -40,7 +40,7 @@ class SendReifier extends ProcessorReifier<SendDefinition<?>> {
if (definition.getEndpointProducerBuilder() == null) {
return context.resolveEndpoint(definition.getEndpointUri(), (String) null);
} else {
- return definition.getEndpointProducerBuilder().resolve(context);
+ return definition.getEndpointProducerBuilder().resolve(context.getCamelContext());
}
} else {
return definition.getEndpoint();
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/AbstractEndpointBuilder.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/AbstractEndpointBuilder.java
index fde528e..518c756 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/AbstractEndpointBuilder.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/AbstractEndpointBuilder.java
@@ -23,6 +23,7 @@ import java.util.TreeMap;
import javax.xml.bind.annotation.XmlTransient;
+import org.apache.camel.CamelContext;
import org.apache.camel.Endpoint;
import org.apache.camel.NoSuchEndpointException;
import org.apache.camel.RuntimeCamelException;
@@ -41,10 +42,14 @@ public class AbstractEndpointBuilder {
this.path = path;
}
- public Endpoint resolve(RouteContext context) throws NoSuchEndpointException {
+ public Endpoint resolve(CamelContext context) throws NoSuchEndpointException {
Map<String, Object> remaining = new HashMap<>();
String uri = computeUri(remaining);
- return context.resolveEndpoint(uri, remaining);
+ Endpoint endpoint = context.getEndpoint(uri, properties);
+ if (endpoint == null) {
+ throw new NoSuchEndpointException(uri);
+ }
+ return null;
}
public String getUri() {
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/EndpointRouteBuilder.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/EndpointRouteBuilder.java
index 172c4d0..d6f30e1 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/EndpointRouteBuilder.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/EndpointRouteBuilder.java
@@ -16,11 +16,41 @@
*/
package org.apache.camel.builder.endpoint;
+import org.apache.camel.CamelContext;
import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.util.function.ThrowingConsumer;
/**
* A route builder which gives access to the endpoint DSL
*/
public abstract class EndpointRouteBuilder extends RouteBuilder implements EndpointBuilderFactory {
+ public EndpointRouteBuilder() {
+ }
+
+ public EndpointRouteBuilder(CamelContext context) {
+ super(context);
+ }
+
+ /**
+ * Add routes to a context using a lambda expression.
+ * It can be used as following:
+ * <pre>
+ * RouteBuilder.addRoutes(context, rb ->
+ * rb.from("direct:inbound").bean(ProduceTemplateBean.class)));
+ * </pre>
+ *
+ * @param context the camel context to add routes
+ * @param rbc a lambda expression receiving the {@code RouteBuilder} to use to create routes
+ * @throws Exception if an error occurs
+ */
+ public static void addEndpointRoutes(CamelContext context, ThrowingConsumer<EndpointRouteBuilder, Exception> rbc) throws Exception {
+ context.addRoutes(new EndpointRouteBuilder(context) {
+ @Override
+ public void configure() throws Exception {
+ rbc.accept(this);
+ }
+ });
+ }
+
}
[camel] 05/05: Fix indentation for generated enums
Posted by gn...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
gnodet pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 08d401c1aa6396b9bb36be6474dda8e9a3183f79
Author: Guillaume Nodet <gn...@gmail.com>
AuthorDate: Mon Jun 17 21:09:30 2019 +0200
Fix indentation for generated enums
---
.../endpoint/dsl/AMQPEndpointBuilderFactory.java | 20 +-
.../endpoint/dsl/AS2EndpointBuilderFactory.java | 146 ++++++------
.../dsl/ActiveMQEndpointBuilderFactory.java | 20 +-
.../dsl/AsteriskEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/AtmosEndpointBuilderFactory.java | 8 +-
.../dsl/AtomixMapEndpointBuilderFactory.java | 28 +--
.../dsl/AtomixMessagingEndpointBuilderFactory.java | 10 +-
.../dsl/AtomixMultiMapEndpointBuilderFactory.java | 20 +-
.../dsl/AtomixQueueEndpointBuilderFactory.java | 22 +-
.../dsl/AtomixSetEndpointBuilderFactory.java | 16 +-
.../dsl/AtomixValueEndpointBuilderFactory.java | 12 +-
.../endpoint/dsl/AvroEndpointBuilderFactory.java | 2 +-
.../dsl/BeanstalkEndpointBuilderFactory.java | 10 +-
.../dsl/BlobServiceEndpointBuilderFactory.java | 30 +--
.../endpoint/dsl/BoxEndpointBuilderFactory.java | 22 +-
.../dsl/BraintreeEndpointBuilderFactory.java | 32 +--
.../dsl/CaffeineCacheEndpointBuilderFactory.java | 2 +-
.../CaffeineLoadCacheEndpointBuilderFactory.java | 2 +-
.../dsl/CassandraEndpointBuilderFactory.java | 20 +-
.../endpoint/dsl/ClientEndpointBuilderFactory.java | 8 +-
.../dsl/CryptoCmsEndpointBuilderFactory.java | 6 +-
.../endpoint/dsl/CxfEndpointBuilderFactory.java | 8 +-
.../endpoint/dsl/CxfRsEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/DdbEndpointBuilderFactory.java | 18 +-
.../dsl/DdbStreamEndpointBuilderFactory.java | 6 +-
.../dsl/DigitalOceanEndpointBuilderFactory.java | 90 ++++----
.../DigitalSignatureEndpointBuilderFactory.java | 2 +-
.../dsl/DisruptorEndpointBuilderFactory.java | 8 +-
.../dsl/DisruptorVmEndpointBuilderFactory.java | 8 +-
.../endpoint/dsl/DnsEndpointBuilderFactory.java | 6 +-
.../endpoint/dsl/DockerEndpointBuilderFactory.java | 72 +++---
.../endpoint/dsl/DrillEndpointBuilderFactory.java | 2 +-
.../dsl/DropboxEndpointBuilderFactory.java | 10 +-
.../endpoint/dsl/EC2EndpointBuilderFactory.java | 20 +-
.../endpoint/dsl/ECSEndpointBuilderFactory.java | 6 +-
.../endpoint/dsl/EKSEndpointBuilderFactory.java | 6 +-
.../dsl/EhcacheEndpointBuilderFactory.java | 12 +-
.../dsl/ElasticsearchEndpointBuilderFactory.java | 24 +-
.../endpoint/dsl/ElsqlEndpointBuilderFactory.java | 16 +-
.../endpoint/dsl/EtcdEndpointBuilderFactory.java | 4 +-
.../dsl/FacebookEndpointBuilderFactory.java | 10 +-
.../endpoint/dsl/FhirEndpointBuilderFactory.java | 44 ++--
.../endpoint/dsl/FileEndpointBuilderFactory.java | 10 +-
.../dsl/FlatpackEndpointBuilderFactory.java | 2 +-
.../endpoint/dsl/FlinkEndpointBuilderFactory.java | 2 +-
.../endpoint/dsl/FopEndpointBuilderFactory.java | 18 +-
.../endpoint/dsl/FtpEndpointBuilderFactory.java | 14 +-
.../endpoint/dsl/FtpsEndpointBuilderFactory.java | 14 +-
.../dsl/GangliaEndpointBuilderFactory.java | 24 +-
.../endpoint/dsl/GitEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/GitHubEndpointBuilderFactory.java | 16 +-
.../dsl/GoogleCalendarEndpointBuilderFactory.java | 14 +-
.../dsl/GoogleDriveEndpointBuilderFactory.java | 24 +-
.../dsl/GoogleMailEndpointBuilderFactory.java | 12 +-
.../dsl/GooglePubsubEndpointBuilderFactory.java | 2 +-
.../dsl/GoogleSheetsEndpointBuilderFactory.java | 2 +-
.../endpoint/dsl/GridFsEndpointBuilderFactory.java | 8 +-
.../endpoint/dsl/GrpcEndpointBuilderFactory.java | 16 +-
...azelcastAtomicnumberEndpointBuilderFactory.java | 70 +++---
.../HazelcastInstanceEndpointBuilderFactory.java | 72 +++---
.../dsl/HazelcastListEndpointBuilderFactory.java | 72 +++---
.../dsl/HazelcastMapEndpointBuilderFactory.java | 72 +++---
.../HazelcastMultimapEndpointBuilderFactory.java | 72 +++---
.../dsl/HazelcastQueueEndpointBuilderFactory.java | 72 +++---
...zelcastReplicatedmapEndpointBuilderFactory.java | 72 +++---
.../HazelcastRingbufferEndpointBuilderFactory.java | 70 +++---
.../dsl/HazelcastSedaEndpointBuilderFactory.java | 72 +++---
.../dsl/HazelcastSetEndpointBuilderFactory.java | 72 +++---
.../dsl/HazelcastTopicEndpointBuilderFactory.java | 72 +++---
.../endpoint/dsl/HdfsEndpointBuilderFactory.java | 34 +--
.../endpoint/dsl/HttpEndpointBuilderFactory.java | 14 +-
.../endpoint/dsl/IAMEndpointBuilderFactory.java | 24 +-
.../dsl/IgniteCacheEndpointBuilderFactory.java | 22 +-
.../dsl/IgniteComputeEndpointBuilderFactory.java | 12 +-
.../dsl/IgniteIdGenEndpointBuilderFactory.java | 8 +-
.../dsl/IgniteMessagingEndpointBuilderFactory.java | 2 +-
.../dsl/IgniteQueueEndpointBuilderFactory.java | 28 +--
.../dsl/IgniteSetEndpointBuilderFactory.java | 14 +-
.../dsl/InfinispanEndpointBuilderFactory.java | 100 ++++----
.../endpoint/dsl/JCacheEndpointBuilderFactory.java | 6 +-
.../dsl/JcloudsEndpointBuilderFactory.java | 2 +-
.../endpoint/dsl/JdbcEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/JiraEndpointBuilderFactory.java | 16 +-
.../endpoint/dsl/JmsEndpointBuilderFactory.java | 20 +-
.../endpoint/dsl/JoltEndpointBuilderFactory.java | 10 +-
.../endpoint/dsl/JooqEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/JpaEndpointBuilderFactory.java | 14 +-
.../endpoint/dsl/Jt400EndpointBuilderFactory.java | 16 +-
.../endpoint/dsl/KMSEndpointBuilderFactory.java | 10 +-
.../dsl/KinesisEndpointBuilderFactory.java | 12 +-
.../endpoint/dsl/LambdaEndpointBuilderFactory.java | 26 +--
.../dsl/LinkedInEndpointBuilderFactory.java | 30 +--
.../endpoint/dsl/LogEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/LuceneEndpointBuilderFactory.java | 2 +-
.../endpoint/dsl/MQEndpointBuilderFactory.java | 10 +-
.../endpoint/dsl/MQTTEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/MSKEndpointBuilderFactory.java | 6 +-
.../dsl/MetricsEndpointBuilderFactory.java | 10 +-
.../dsl/MicrometerEndpointBuilderFactory.java | 10 +-
.../endpoint/dsl/Mina2EndpointBuilderFactory.java | 8 +-
.../dsl/MongoDbEndpointBuilderFactory.java | 30 +--
.../dsl/MyBatisBeanEndpointBuilderFactory.java | 4 +-
.../dsl/MyBatisEndpointBuilderFactory.java | 18 +-
.../endpoint/dsl/NagiosEndpointBuilderFactory.java | 16 +-
.../endpoint/dsl/NettyEndpointBuilderFactory.java | 2 +-
.../endpoint/dsl/PahoEndpointBuilderFactory.java | 2 +-
.../endpoint/dsl/PdfEndpointBuilderFactory.java | 6 +-
.../endpoint/dsl/PulsarEndpointBuilderFactory.java | 4 +-
.../dsl/QueueServiceEndpointBuilderFactory.java | 14 +-
.../dsl/ReactiveStreamsEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/RedisEndpointBuilderFactory.java | 256 ++++++++++-----------
.../endpoint/dsl/RestEndpointBuilderFactory.java | 8 +-
.../endpoint/dsl/S3EndpointBuilderFactory.java | 12 +-
.../endpoint/dsl/SagaEndpointBuilderFactory.java | 2 +-
.../dsl/SalesforceEndpointBuilderFactory.java | 110 ++++-----
.../endpoint/dsl/SdbEndpointBuilderFactory.java | 16 +-
.../endpoint/dsl/ServerEndpointBuilderFactory.java | 8 +-
.../dsl/ServiceNowEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/SftpEndpointBuilderFactory.java | 14 +-
.../endpoint/dsl/Sjms2EndpointBuilderFactory.java | 6 +-
.../endpoint/dsl/SjmsEndpointBuilderFactory.java | 6 +-
.../endpoint/dsl/SmppEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/SnmpEndpointBuilderFactory.java | 4 +-
.../dsl/SoroushBotEndpointBuilderFactory.java | 6 +-
.../endpoint/dsl/SplunkEndpointBuilderFactory.java | 6 +-
.../dsl/SpringLdapEndpointBuilderFactory.java | 10 +-
.../SpringWebserviceEndpointBuilderFactory.java | 14 +-
.../endpoint/dsl/SqlEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/SqsEndpointBuilderFactory.java | 4 +-
.../endpoint/dsl/ThriftEndpointBuilderFactory.java | 12 +-
.../endpoint/dsl/TikaEndpointBuilderFactory.java | 8 +-
.../endpoint/dsl/TwilioEndpointBuilderFactory.java | 110 ++++-----
...TwitterDirectMessageEndpointBuilderFactory.java | 4 +-
.../dsl/TwitterSearchEndpointBuilderFactory.java | 4 +-
.../TwitterStreamingEndpointBuilderFactory.java | 10 +-
.../dsl/TwitterTimelineEndpointBuilderFactory.java | 14 +-
.../dsl/WeatherEndpointBuilderFactory.java | 56 ++---
.../dsl/XChangeEndpointBuilderFactory.java | 18 +-
.../endpoint/dsl/XQueryEndpointBuilderFactory.java | 12 +-
.../dsl/XmlSignatureEndpointBuilderFactory.java | 2 +-
.../endpoint/dsl/XsltEndpointBuilderFactory.java | 6 +-
.../endpoint/dsl/YammerEndpointBuilderFactory.java | 16 +-
.../camel/maven/packaging/srcgen/JavaClass.java | 2 +-
143 files changed, 1568 insertions(+), 1568 deletions(-)
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AMQPEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AMQPEndpointBuilderFactory.java
index 104b612..1063dbd 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AMQPEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AMQPEndpointBuilderFactory.java
@@ -4601,11 +4601,11 @@ public interface AMQPEndpointBuilderFactory {
*/
enum JmsMessageType {
Bytes,
-Map,
-Object,
-Stream,
-Text,
-Blob;
+ Map,
+ Object,
+ Stream,
+ Text,
+ Blob;
}
/**
@@ -4614,8 +4614,8 @@ Blob;
*/
enum ConsumerType {
Simple,
-Default,
-Custom;
+ Default,
+ Custom;
}
/**
@@ -4624,7 +4624,7 @@ Custom;
*/
enum DefaultTaskExecutorType {
ThreadPool,
-SimpleAsync;
+ SimpleAsync;
}
/**
@@ -4633,8 +4633,8 @@ SimpleAsync;
*/
enum ReplyToType {
Temporary,
-Shared,
-Exclusive;
+ Shared,
+ Exclusive;
}
/**
* Messaging with AMQP protocol using Apache QPid Client. Creates a builder
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AS2EndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AS2EndpointBuilderFactory.java
index 8d06be9..35dba65 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AS2EndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AS2EndpointBuilderFactory.java
@@ -1670,7 +1670,7 @@ public interface AS2EndpointBuilderFactory {
*/
enum AS2ApiName {
CLIENT,
-SERVER;
+ SERVER;
}
/**
@@ -1679,13 +1679,13 @@ SERVER;
*/
enum AS2MessageStructure {
PLAIN,
-SIGNED,
-ENCRYPTED,
-SIGNED_ENCRYPTED,
-PLAIN_COMPRESSED,
-SIGNED_COMPRESSED,
-ENCRYPTED_COMPRESSED,
-ENCRYPTED_COMPRESSED_SIGNED;
+ SIGNED,
+ ENCRYPTED,
+ SIGNED_ENCRYPTED,
+ PLAIN_COMPRESSED,
+ SIGNED_COMPRESSED,
+ ENCRYPTED_COMPRESSED,
+ ENCRYPTED_COMPRESSED_SIGNED;
}
/**
@@ -1704,25 +1704,25 @@ ENCRYPTED_COMPRESSED_SIGNED;
*/
enum AS2EncryptionAlgorithm {
AES128_CBC,
-AES192_CBC,
-AES256_CBC,
-AES128_CCM,
-AES192_CCM,
-AES256_CCM,
-AES128_GCM,
-AES192_GCM,
-AES256_GCM,
-CAMELLIA128_CBC,
-CAMELLIA192_CBC,
-CAMELLIA256_CBC,
-CAST5_CBC,
-DES_CBC,
-DES_EDE3_CBC,
-GOST28147_GCFB,
-IDEA_CBC,
-RC2_CBC,
-RC4,
-SEED_CBC;
+ AES192_CBC,
+ AES256_CBC,
+ AES128_CCM,
+ AES192_CCM,
+ AES256_CCM,
+ AES128_GCM,
+ AES192_GCM,
+ AES256_GCM,
+ CAMELLIA128_CBC,
+ CAMELLIA192_CBC,
+ CAMELLIA256_CBC,
+ CAST5_CBC,
+ DES_CBC,
+ DES_EDE3_CBC,
+ GOST28147_GCFB,
+ IDEA_CBC,
+ RC2_CBC,
+ RC4,
+ SEED_CBC;
}
/**
@@ -1732,52 +1732,52 @@ SEED_CBC;
*/
enum AS2SignatureAlgorithm {
SHA3_224WITHRSA,
-SHA3_256WITHRSA,
-SHA3_384withRSA,
-SHA3_512WITHRSA,
-MD5WITHRSA,
-SHA1WITHRSA,
-MD2WITHRSA,
-SHA224WITHRSA,
-SHA256WITHRSA,
-SHA384WITHRSA,
-SHA512WITHRSA,
-RIPEMD128WITHRSA,
-RIPEMD160WITHRSA,
-RIPEMD256WITHRSA,
-SHA224WITHDSA,
-SHA256WITHDSA,
-SHA384WITHDSA,
-SHA512WITHDSA,
-SHA3_224WITHDSA,
-SHA3_256WITHDSA,
-SHA3_384WITHDSA,
-SHA3_512WITHDSA,
-SHA1WITHDSA,
-SHA3_224WITHECDSA,
-SHA3_256WITHECDSA,
-SHA3_384WITHECDSA,
-SHA3_512WITHECDSA,
-SHA1WITHECDSA,
-SHA224WITHECDSA,
-SHA256WITHECDSA,
-SHA384WITHECDSA,
-SHA512WITHECDSA,
-SHA1WITHPLAIN_ECDSA,
-SHA224WITHPLAIN_ECDSA,
-SHA256WITHPLAIN_ECDSA,
-SHA384WITHPLAIN_ECDSA,
-SHA512WITHPLAIN_ECDSA,
-RIPEMD160WITHPLAIN_ECDSA,
-SHA1WITHRSAANDMGF1,
-SHA224WITHRSAANDMGF1,
-SHA256WITHRSAANDMGF1,
-SHA384WITHRSAANDMGF1,
-SHA512WITHRSAANDMGF1,
-SHA3_224WITHRSAANDMGF1,
-SHA3_256WITHRSAANDMGF1,
-SHA3_384WITHRSAANDMGF1,
-SHA3_512WITHRSAANDMGF1;
+ SHA3_256WITHRSA,
+ SHA3_384withRSA,
+ SHA3_512WITHRSA,
+ MD5WITHRSA,
+ SHA1WITHRSA,
+ MD2WITHRSA,
+ SHA224WITHRSA,
+ SHA256WITHRSA,
+ SHA384WITHRSA,
+ SHA512WITHRSA,
+ RIPEMD128WITHRSA,
+ RIPEMD160WITHRSA,
+ RIPEMD256WITHRSA,
+ SHA224WITHDSA,
+ SHA256WITHDSA,
+ SHA384WITHDSA,
+ SHA512WITHDSA,
+ SHA3_224WITHDSA,
+ SHA3_256WITHDSA,
+ SHA3_384WITHDSA,
+ SHA3_512WITHDSA,
+ SHA1WITHDSA,
+ SHA3_224WITHECDSA,
+ SHA3_256WITHECDSA,
+ SHA3_384WITHECDSA,
+ SHA3_512WITHECDSA,
+ SHA1WITHECDSA,
+ SHA224WITHECDSA,
+ SHA256WITHECDSA,
+ SHA384WITHECDSA,
+ SHA512WITHECDSA,
+ SHA1WITHPLAIN_ECDSA,
+ SHA224WITHPLAIN_ECDSA,
+ SHA256WITHPLAIN_ECDSA,
+ SHA384WITHPLAIN_ECDSA,
+ SHA512WITHPLAIN_ECDSA,
+ RIPEMD160WITHPLAIN_ECDSA,
+ SHA1WITHRSAANDMGF1,
+ SHA224WITHRSAANDMGF1,
+ SHA256WITHRSAANDMGF1,
+ SHA384WITHRSAANDMGF1,
+ SHA512WITHRSAANDMGF1,
+ SHA3_224WITHRSAANDMGF1,
+ SHA3_256WITHRSAANDMGF1,
+ SHA3_384WITHRSAANDMGF1,
+ SHA3_512WITHRSAANDMGF1;
}
/**
* Component used for transferring data secure and reliable over the
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ActiveMQEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ActiveMQEndpointBuilderFactory.java
index 0b14b3f..2dbd44d 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ActiveMQEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ActiveMQEndpointBuilderFactory.java
@@ -4624,11 +4624,11 @@ public interface ActiveMQEndpointBuilderFactory {
*/
enum JmsMessageType {
Bytes,
-Map,
-Object,
-Stream,
-Text,
-Blob;
+ Map,
+ Object,
+ Stream,
+ Text,
+ Blob;
}
/**
@@ -4637,8 +4637,8 @@ Blob;
*/
enum ConsumerType {
Simple,
-Default,
-Custom;
+ Default,
+ Custom;
}
/**
@@ -4647,7 +4647,7 @@ Custom;
*/
enum DefaultTaskExecutorType {
ThreadPool,
-SimpleAsync;
+ SimpleAsync;
}
/**
@@ -4656,8 +4656,8 @@ SimpleAsync;
*/
enum ReplyToType {
Temporary,
-Shared,
-Exclusive;
+ Shared,
+ Exclusive;
}
/**
* The activemq component allows messages to be sent to (or consumed from)
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AsteriskEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AsteriskEndpointBuilderFactory.java
index 9d49a4b..fa70649 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AsteriskEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AsteriskEndpointBuilderFactory.java
@@ -481,8 +481,8 @@ public interface AsteriskEndpointBuilderFactory {
*/
enum AsteriskAction {
QUEUE_STATUS,
-SIP_PEERS,
-EXTENSION_STATE;
+ SIP_PEERS,
+ EXTENSION_STATE;
}
/**
* The asterisk component is used to interact with Asterisk PBX Server.
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtmosEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtmosEndpointBuilderFactory.java
index 7fd929a..322678f 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtmosEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtmosEndpointBuilderFactory.java
@@ -693,10 +693,10 @@ public interface AtmosEndpointBuilderFactory {
*/
enum AtmosOperation {
put,
-del,
-search,
-get,
-move;
+ del,
+ search,
+ get,
+ move;
}
/**
* The atmos component is used for integrating with EMC's Atomos Storage.
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixMapEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixMapEndpointBuilderFactory.java
index 7654f84..ae56a9d 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixMapEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixMapEndpointBuilderFactory.java
@@ -1196,17 +1196,17 @@ public interface AtomixMapEndpointBuilderFactory {
*/
enum Action {
PUT,
-PUT_IF_ABSENT,
-GET,
-CLEAR,
-SIZE,
-CONTAINS_KEY,
-CONTAINS_VALUE,
-IS_EMPTY,
-ENTRY_SET,
-REMOVE,
-REPLACE,
-VALUES;
+ PUT_IF_ABSENT,
+ GET,
+ CLEAR,
+ SIZE,
+ CONTAINS_KEY,
+ CONTAINS_VALUE,
+ IS_EMPTY,
+ ENTRY_SET,
+ REMOVE,
+ REPLACE,
+ VALUES;
}
/**
@@ -1214,9 +1214,9 @@ VALUES;
*/
enum ReadConsistency {
ATOMIC,
-ATOMIC_LEASE,
-SEQUENTIAL,
-LOCAL;
+ ATOMIC_LEASE,
+ SEQUENTIAL,
+ LOCAL;
}
/**
* The atomix-map component is used to access Atomix's distributed map.
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixMessagingEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixMessagingEndpointBuilderFactory.java
index 2d33ec3..2b4d663 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixMessagingEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixMessagingEndpointBuilderFactory.java
@@ -1216,7 +1216,7 @@ public interface AtomixMessagingEndpointBuilderFactory {
*/
enum BroadcastType {
ALL,
-RANDOM;
+ RANDOM;
}
/**
@@ -1225,7 +1225,7 @@ RANDOM;
*/
enum Action {
DIRECT,
-BROADCAST;
+ BROADCAST;
}
/**
@@ -1233,9 +1233,9 @@ BROADCAST;
*/
enum ReadConsistency {
ATOMIC,
-ATOMIC_LEASE,
-SEQUENTIAL,
-LOCAL;
+ ATOMIC_LEASE,
+ SEQUENTIAL,
+ LOCAL;
}
/**
* The atomix-messaging component is used to access Atomix's group
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixMultiMapEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixMultiMapEndpointBuilderFactory.java
index 8476637..7394bd9 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixMultiMapEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixMultiMapEndpointBuilderFactory.java
@@ -383,13 +383,13 @@ public interface AtomixMultiMapEndpointBuilderFactory {
*/
enum Action {
PUT,
-GET,
-CLEAR,
-SIZE,
-CONTAINS_KEY,
-IS_EMPTY,
-REMOVE,
-REMOVE_VALUE;
+ GET,
+ CLEAR,
+ SIZE,
+ CONTAINS_KEY,
+ IS_EMPTY,
+ REMOVE,
+ REMOVE_VALUE;
}
/**
@@ -397,9 +397,9 @@ REMOVE_VALUE;
*/
enum ReadConsistency {
ATOMIC,
-ATOMIC_LEASE,
-SEQUENTIAL,
-LOCAL;
+ ATOMIC_LEASE,
+ SEQUENTIAL,
+ LOCAL;
}
/**
* The atomix-multimap component is used to access Atomix's distributed
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixQueueEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixQueueEndpointBuilderFactory.java
index bdbb9f4..09b4017 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixQueueEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixQueueEndpointBuilderFactory.java
@@ -1084,14 +1084,14 @@ public interface AtomixQueueEndpointBuilderFactory {
*/
enum Action {
ADD,
-OFFER,
-PEEK,
-POLL,
-CLEAR,
-CONTAINS,
-IS_EMPTY,
-REMOVE,
-SIZE;
+ OFFER,
+ PEEK,
+ POLL,
+ CLEAR,
+ CONTAINS,
+ IS_EMPTY,
+ REMOVE,
+ SIZE;
}
/**
@@ -1099,9 +1099,9 @@ SIZE;
*/
enum ReadConsistency {
ATOMIC,
-ATOMIC_LEASE,
-SEQUENTIAL,
-LOCAL;
+ ATOMIC_LEASE,
+ SEQUENTIAL,
+ LOCAL;
}
/**
* The atomix-queue component is used to access Atomix's distributed queue.
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixSetEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixSetEndpointBuilderFactory.java
index 0d2bba6..8291902 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixSetEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixSetEndpointBuilderFactory.java
@@ -1136,11 +1136,11 @@ public interface AtomixSetEndpointBuilderFactory {
*/
enum Action {
ADD,
-CLEAR,
-CONTAINS,
-IS_EMPTY,
-REMOVE,
-SIZE;
+ CLEAR,
+ CONTAINS,
+ IS_EMPTY,
+ REMOVE,
+ SIZE;
}
/**
@@ -1148,9 +1148,9 @@ SIZE;
*/
enum ReadConsistency {
ATOMIC,
-ATOMIC_LEASE,
-SEQUENTIAL,
-LOCAL;
+ ATOMIC_LEASE,
+ SEQUENTIAL,
+ LOCAL;
}
/**
* The atomix-set component is used to access Atomix's distributed set.
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixValueEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixValueEndpointBuilderFactory.java
index 368932f..34628b1 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixValueEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AtomixValueEndpointBuilderFactory.java
@@ -1138,9 +1138,9 @@ public interface AtomixValueEndpointBuilderFactory {
*/
enum Action {
SET,
-GET,
-GET_AND_SET,
-COMPARE_AND_SET;
+ GET,
+ GET_AND_SET,
+ COMPARE_AND_SET;
}
/**
@@ -1148,9 +1148,9 @@ COMPARE_AND_SET;
*/
enum ReadConsistency {
ATOMIC,
-ATOMIC_LEASE,
-SEQUENTIAL,
-LOCAL;
+ ATOMIC_LEASE,
+ SEQUENTIAL,
+ LOCAL;
}
/**
* The atomix-value component is used to access Atomix's distributed value.
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AvroEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AvroEndpointBuilderFactory.java
index 9694a26..7ea7cde 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AvroEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/AvroEndpointBuilderFactory.java
@@ -796,7 +796,7 @@ public interface AvroEndpointBuilderFactory {
*/
enum AvroTransport {
http,
-netty;
+ netty;
}
/**
* Working with Apache Avro for data serialization. Creates a builder to
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/BeanstalkEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/BeanstalkEndpointBuilderFactory.java
index c07f607..6416581 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/BeanstalkEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/BeanstalkEndpointBuilderFactory.java
@@ -1072,11 +1072,11 @@ public interface BeanstalkEndpointBuilderFactory {
*/
enum BeanstalkCommand {
bury,
-release,
-put,
-touch,
-delete,
-kick;
+ release,
+ put,
+ touch,
+ delete,
+ kick;
}
/**
* The beanstalk component is used for job retrieval and post-processing of
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/BlobServiceEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/BlobServiceEndpointBuilderFactory.java
index 188804e..1936d65 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/BlobServiceEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/BlobServiceEndpointBuilderFactory.java
@@ -1016,8 +1016,8 @@ public interface BlobServiceEndpointBuilderFactory {
*/
enum BlobType {
blockblob,
-appendblob,
-pageblob;
+ appendblob,
+ pageblob;
}
/**
@@ -1027,19 +1027,19 @@ pageblob;
*/
enum BlobServiceOperations {
getBlob,
-deleteBlob,
-listBlobs,
-updateBlockBlob,
-uploadBlobBlocks,
-commitBlobBlockList,
-getBlobBlockList,
-createAppendBlob,
-updateAppendBlob,
-createPageBlob,
-updatePageBlob,
-resizePageBlob,
-clearPageBlob,
-getPageBlobRanges;
+ deleteBlob,
+ listBlobs,
+ updateBlockBlob,
+ uploadBlobBlocks,
+ commitBlobBlockList,
+ getBlobBlockList,
+ createAppendBlob,
+ updateAppendBlob,
+ createPageBlob,
+ updatePageBlob,
+ resizePageBlob,
+ clearPageBlob,
+ getPageBlobRanges;
}
/**
* The azure-blob component is used for storing and retrieving blobs from
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/BoxEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/BoxEndpointBuilderFactory.java
index 4a7677a..e6f1620 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/BoxEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/BoxEndpointBuilderFactory.java
@@ -1073,15 +1073,15 @@ public interface BoxEndpointBuilderFactory {
*/
enum BoxApiName {
COLLABORATIONS,
-COMMENTS,
-EVENT_LOGS,
-FILES,
-FOLDERS,
-GROUPS,
-EVENTS,
-SEARCH,
-TASKS,
-USERS;
+ COMMENTS,
+ EVENT_LOGS,
+ FILES,
+ FOLDERS,
+ GROUPS,
+ EVENTS,
+ SEARCH,
+ TASKS,
+ USERS;
}
/**
@@ -1089,8 +1089,8 @@ USERS;
*/
enum EncryptionAlgorithm {
RSA_SHA_256,
-RSA_SHA_384,
-RSA_SHA_512;
+ RSA_SHA_384,
+ RSA_SHA_512;
}
/**
* For uploading downloading and managing files folders groups
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/BraintreeEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/BraintreeEndpointBuilderFactory.java
index 4494455..6e99e27 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/BraintreeEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/BraintreeEndpointBuilderFactory.java
@@ -821,22 +821,22 @@ public interface BraintreeEndpointBuilderFactory {
*/
enum BraintreeApiName {
ADDON,
-ADDRESS,
-CLIENTTOKEN,
-CREDITCARDVERIFICATION,
-CUSTOMER,
-DISCOUNT,
-DISPUTE,
-DOCUMENTUPLOAD,
-MERCHANTACCOUNT,
-PAYMENTMETHOD,
-PAYMENTMETHODNONCE,
-PLAN,
-REPORT,
-SETTLEMENTBATCHSUMMARY,
-SUBSCRIPTION,
-TRANSACTION,
-WEBHOOKNOTIFICATION;
+ ADDRESS,
+ CLIENTTOKEN,
+ CREDITCARDVERIFICATION,
+ CUSTOMER,
+ DISCOUNT,
+ DISPUTE,
+ DOCUMENTUPLOAD,
+ MERCHANTACCOUNT,
+ PAYMENTMETHOD,
+ PAYMENTMETHODNONCE,
+ PLAN,
+ REPORT,
+ SETTLEMENTBATCHSUMMARY,
+ SUBSCRIPTION,
+ TRANSACTION,
+ WEBHOOKNOTIFICATION;
}
/**
* The braintree component is used for integrating with the Braintree
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CaffeineCacheEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CaffeineCacheEndpointBuilderFactory.java
index a030898..6a85cbd 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CaffeineCacheEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CaffeineCacheEndpointBuilderFactory.java
@@ -819,7 +819,7 @@ public interface CaffeineCacheEndpointBuilderFactory {
*/
enum EvictionType {
size_based,
-time_based;
+ time_based;
}
/**
* The caffeine-cache component is used for integration with Caffeine Cache.
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CaffeineLoadCacheEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CaffeineLoadCacheEndpointBuilderFactory.java
index df60872..35a0ebf 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CaffeineLoadCacheEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CaffeineLoadCacheEndpointBuilderFactory.java
@@ -826,7 +826,7 @@ public interface CaffeineLoadCacheEndpointBuilderFactory {
*/
enum EvictionType {
size_based,
-time_based;
+ time_based;
}
/**
* The caffeine-loadcache component is used for integration with Caffeine
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CassandraEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CassandraEndpointBuilderFactory.java
index 3a6cf9d..361a239 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CassandraEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CassandraEndpointBuilderFactory.java
@@ -1301,16 +1301,16 @@ public interface CassandraEndpointBuilderFactory {
*/
enum ConsistencyLevel {
ANY,
-ONE,
-TWO,
-THREE,
-QUORUM,
-ALL,
-LOCAL_QUORUM,
-EACH_QUORUM,
-SERIAL,
-LOCAL_SERIAL,
-LOCAL_ONE;
+ ONE,
+ TWO,
+ THREE,
+ QUORUM,
+ ALL,
+ LOCAL_QUORUM,
+ EACH_QUORUM,
+ SERIAL,
+ LOCAL_SERIAL,
+ LOCAL_ONE;
}
/**
* The cql component aims at integrating Cassandra 2.0 using the CQL3 API
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ClientEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ClientEndpointBuilderFactory.java
index c0e210f..22a843b 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ClientEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ClientEndpointBuilderFactory.java
@@ -1295,7 +1295,7 @@ public interface ClientEndpointBuilderFactory {
*/
enum ASDUAddressType {
SIZE_1,
-SIZE_2;
+ SIZE_2;
}
/**
@@ -1304,7 +1304,7 @@ SIZE_2;
*/
enum CauseOfTransmissionType {
SIZE_1,
-SIZE_2;
+ SIZE_2;
}
/**
@@ -1313,8 +1313,8 @@ SIZE_2;
*/
enum InformationObjectAddressType {
SIZE_1,
-SIZE_2,
-SIZE_3;
+ SIZE_2,
+ SIZE_3;
}
/**
* IEC 60870 component used for telecontrol (supervisory control and data
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CryptoCmsEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CryptoCmsEndpointBuilderFactory.java
index 6700e16..29d1dae 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CryptoCmsEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CryptoCmsEndpointBuilderFactory.java
@@ -480,9 +480,9 @@ public interface CryptoCmsEndpointBuilderFactory {
*/
enum CryptoOperation {
sign,
-verify,
-encrypt,
-decrypt;
+ verify,
+ encrypt,
+ decrypt;
}
/**
* The crypto cms component is used for encrypting data in CMS Enveloped
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CxfEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CxfEndpointBuilderFactory.java
index 5f57e0c..8f6c5a9 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CxfEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CxfEndpointBuilderFactory.java
@@ -1895,10 +1895,10 @@ public interface CxfEndpointBuilderFactory {
*/
enum DataFormat {
PAYLOAD,
-RAW,
-MESSAGE,
-CXF_MESSAGE,
-POJO;
+ RAW,
+ MESSAGE,
+ CXF_MESSAGE,
+ POJO;
}
/**
* The cxf component is used for SOAP WebServices using Apache CXF. Creates
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CxfRsEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CxfRsEndpointBuilderFactory.java
index c524192..3d0f7e9 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CxfRsEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/CxfRsEndpointBuilderFactory.java
@@ -1725,8 +1725,8 @@ public interface CxfRsEndpointBuilderFactory {
*/
enum BindingStyle {
SimpleConsumer,
-Default,
-Custom;
+ Default,
+ Custom;
}
/**
* The cxfrs component is used for JAX-RS REST services using Apache CXF.
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DdbEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DdbEndpointBuilderFactory.java
index 3594316..c104eb2 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DdbEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DdbEndpointBuilderFactory.java
@@ -281,15 +281,15 @@ public interface DdbEndpointBuilderFactory {
*/
enum DdbOperations {
BatchGetItems,
-DeleteItem,
-DeleteTable,
-DescribeTable,
-GetItem,
-PutItem,
-Query,
-Scan,
-UpdateItem,
-UpdateTable;
+ DeleteItem,
+ DeleteTable,
+ DescribeTable,
+ GetItem,
+ PutItem,
+ Query,
+ Scan,
+ UpdateItem,
+ UpdateTable;
}
/**
* The aws-ddb component is used for storing and retrieving data from
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DdbStreamEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DdbStreamEndpointBuilderFactory.java
index 29b2385..2d96e00 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DdbStreamEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DdbStreamEndpointBuilderFactory.java
@@ -154,9 +154,9 @@ public interface DdbStreamEndpointBuilderFactory {
*/
enum ShardIteratorType {
TRIM_HORIZON,
-LATEST,
-AT_SEQUENCE_NUMBER,
-AFTER_SEQUENCE_NUMBER;
+ LATEST,
+ AT_SEQUENCE_NUMBER,
+ AFTER_SEQUENCE_NUMBER;
}
/**
* The aws-ddbstream component is used for working with Amazon DynamoDB
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DigitalOceanEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DigitalOceanEndpointBuilderFactory.java
index d56d72f..c8ad0cc 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DigitalOceanEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DigitalOceanEndpointBuilderFactory.java
@@ -263,41 +263,41 @@ public interface DigitalOceanEndpointBuilderFactory {
*/
enum DigitalOceanOperations {
create,
-update,
-delete,
-list,
-ownList,
-get,
-listBackups,
-listActions,
-listNeighbors,
-listSnapshots,
-listKernels,
-listAllNeighbors,
-enableBackups,
-disableBackups,
-reboot,
-powerCycle,
-shutdown,
-powerOn,
-powerOff,
-restore,
-resetPassword,
-resize,
-rebuild,
-rename,
-changeKernel,
-enableIpv6,
-enablePrivateNetworking,
-takeSnapshot,
-transfer,
-convert,
-attach,
-detach,
-assign,
-unassign,
-tag,
-untag;
+ update,
+ delete,
+ list,
+ ownList,
+ get,
+ listBackups,
+ listActions,
+ listNeighbors,
+ listSnapshots,
+ listKernels,
+ listAllNeighbors,
+ enableBackups,
+ disableBackups,
+ reboot,
+ powerCycle,
+ shutdown,
+ powerOn,
+ powerOff,
+ restore,
+ resetPassword,
+ resize,
+ rebuild,
+ rename,
+ changeKernel,
+ enableIpv6,
+ enablePrivateNetworking,
+ takeSnapshot,
+ transfer,
+ convert,
+ attach,
+ detach,
+ assign,
+ unassign,
+ tag,
+ untag;
}
/**
@@ -306,16 +306,16 @@ untag;
*/
enum DigitalOceanResources {
account,
-actions,
-blockStorages,
-droplets,
-images,
-snapshots,
-keys,
-regions,
-sizes,
-floatingIPs,
-tags;
+ actions,
+ blockStorages,
+ droplets,
+ images,
+ snapshots,
+ keys,
+ regions,
+ sizes,
+ floatingIPs,
+ tags;
}
/**
* The DigitalOcean component allows you to manage Droplets and resources
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DigitalSignatureEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DigitalSignatureEndpointBuilderFactory.java
index fbc27ec..dfca7de 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DigitalSignatureEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DigitalSignatureEndpointBuilderFactory.java
@@ -454,7 +454,7 @@ public interface DigitalSignatureEndpointBuilderFactory {
*/
enum CryptoOperation {
sign,
-verify;
+ verify;
}
/**
* The crypto component is used for signing and verifying exchanges using
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DisruptorEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DisruptorEndpointBuilderFactory.java
index 4652949..8f58925 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DisruptorEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DisruptorEndpointBuilderFactory.java
@@ -647,9 +647,9 @@ public interface DisruptorEndpointBuilderFactory {
*/
enum DisruptorWaitStrategy {
Blocking,
-Sleeping,
-BusySpin,
-Yielding;
+ Sleeping,
+ BusySpin,
+ Yielding;
}
/**
@@ -659,7 +659,7 @@ Yielding;
*/
enum DisruptorProducerType {
Single,
-Multi;
+ Multi;
}
/**
* The disruptor component provides asynchronous SEDA behavior using LMAX
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DisruptorVmEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DisruptorVmEndpointBuilderFactory.java
index 28136dc..4703632 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DisruptorVmEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DisruptorVmEndpointBuilderFactory.java
@@ -649,9 +649,9 @@ public interface DisruptorVmEndpointBuilderFactory {
*/
enum DisruptorWaitStrategy {
Blocking,
-Sleeping,
-BusySpin,
-Yielding;
+ Sleeping,
+ BusySpin,
+ Yielding;
}
/**
@@ -661,7 +661,7 @@ Yielding;
*/
enum DisruptorProducerType {
Single,
-Multi;
+ Multi;
}
/**
* The disruptor component provides asynchronous SEDA behavior using LMAX
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DnsEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DnsEndpointBuilderFactory.java
index cd7926e..8853261 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DnsEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DnsEndpointBuilderFactory.java
@@ -117,9 +117,9 @@ public interface DnsEndpointBuilderFactory {
*/
enum DnsType {
dig,
-ip,
-lookup,
-wikipedia;
+ ip,
+ lookup,
+ wikipedia;
}
/**
* To lookup domain information and run DNS queries using DNSJava. Creates a
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DockerEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DockerEndpointBuilderFactory.java
index 2578304..0de8298 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DockerEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DockerEndpointBuilderFactory.java
@@ -1135,42 +1135,42 @@ public interface DockerEndpointBuilderFactory {
*/
enum DockerOperation {
events,
-stats,
-auth,
-info,
-ping,
-version,
-imagebuild,
-imagecreate,
-imageinspect,
-imagelist,
-imagepull,
-imagepush,
-imageremove,
-imagesearch,
-imagetag,
-containerattach,
-containercommit,
-containercopyfile,
-containercreate,
-containerdiff,
-inspectcontainer,
-containerkill,
-containerlist,
-containerlog,
-containerpause,
-containerrestart,
-containerremove,
-containerstart,
-containerstop,
-containertop,
-containerunpause,
-networkcreate,
-networkremove,
-networkconnect,
-containerwait,
-execcreate,
-execstart;
+ stats,
+ auth,
+ info,
+ ping,
+ version,
+ imagebuild,
+ imagecreate,
+ imageinspect,
+ imagelist,
+ imagepull,
+ imagepush,
+ imageremove,
+ imagesearch,
+ imagetag,
+ containerattach,
+ containercommit,
+ containercopyfile,
+ containercreate,
+ containerdiff,
+ inspectcontainer,
+ containerkill,
+ containerlist,
+ containerlog,
+ containerpause,
+ containerrestart,
+ containerremove,
+ containerstart,
+ containerstop,
+ containertop,
+ containerunpause,
+ networkcreate,
+ networkremove,
+ networkconnect,
+ containerwait,
+ execcreate,
+ execstart;
}
/**
* The docker component is used for managing Docker containers. Creates a
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DrillEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DrillEndpointBuilderFactory.java
index 5bae8c7..295b024 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DrillEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DrillEndpointBuilderFactory.java
@@ -171,7 +171,7 @@ public interface DrillEndpointBuilderFactory {
*/
enum DrillConnectionMode {
ZK,
-DRILLBIT;
+ DRILLBIT;
}
/**
* The drill component gives you the ability to quering into apache drill
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DropboxEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DropboxEndpointBuilderFactory.java
index bbcc339..3dd2cca 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DropboxEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/DropboxEndpointBuilderFactory.java
@@ -742,10 +742,10 @@ public interface DropboxEndpointBuilderFactory {
*/
enum DropboxOperation {
put,
-del,
-search,
-get,
-move;
+ del,
+ search,
+ get,
+ move;
}
/**
@@ -755,7 +755,7 @@ move;
*/
enum DropboxUploadMode {
add,
-force;
+ force;
}
/**
* For uploading, downloading and managing files, folders, groups,
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/EC2EndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/EC2EndpointBuilderFactory.java
index ae5cadd..933689b 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/EC2EndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/EC2EndpointBuilderFactory.java
@@ -116,16 +116,16 @@ public interface EC2EndpointBuilderFactory {
*/
enum EC2Operations {
createAndRunInstances,
-startInstances,
-stopInstances,
-terminateInstances,
-describeInstances,
-describeInstancesStatus,
-rebootInstances,
-monitorInstances,
-unmonitorInstances,
-createTags,
-deleteTags;
+ startInstances,
+ stopInstances,
+ terminateInstances,
+ describeInstances,
+ describeInstancesStatus,
+ rebootInstances,
+ monitorInstances,
+ unmonitorInstances,
+ createTags,
+ deleteTags;
}
/**
* The aws-ec2 is used for managing Amazon EC2 instances. Creates a builder
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ECSEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ECSEndpointBuilderFactory.java
index 7271124..8a2cb51 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ECSEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ECSEndpointBuilderFactory.java
@@ -116,9 +116,9 @@ public interface ECSEndpointBuilderFactory {
*/
enum ECSOperations {
listClusters,
-describeCluster,
-createCluster,
-deleteCluster;
+ describeCluster,
+ createCluster,
+ deleteCluster;
}
/**
* The aws-kms is used for managing Amazon ECS Creates a builder to build
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/EKSEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/EKSEndpointBuilderFactory.java
index 61b3040..478f3db 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/EKSEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/EKSEndpointBuilderFactory.java
@@ -116,9 +116,9 @@ public interface EKSEndpointBuilderFactory {
*/
enum EKSOperations {
listClusters,
-describeCluster,
-createCluster,
-deleteCluster;
+ describeCluster,
+ createCluster,
+ deleteCluster;
}
/**
* The aws-kms is used for managing Amazon EKS Creates a builder to build
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/EhcacheEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/EhcacheEndpointBuilderFactory.java
index ef5eec8..6fc4206 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/EhcacheEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/EhcacheEndpointBuilderFactory.java
@@ -963,7 +963,7 @@ public interface EhcacheEndpointBuilderFactory {
*/
enum EventFiring {
ASYNCHRONOUS,
-SYNCHRONOUS;
+ SYNCHRONOUS;
}
/**
@@ -971,7 +971,7 @@ SYNCHRONOUS;
*/
enum EventOrdering {
UNORDERED,
-ORDERED;
+ ORDERED;
}
/**
@@ -979,10 +979,10 @@ ORDERED;
*/
enum EventType {
EVICTED,
-EXPIRED,
-REMOVED,
-CREATED,
-UPDATED;
+ EXPIRED,
+ REMOVED,
+ CREATED,
+ UPDATED;
}
/**
* The ehcache component enables you to perform caching operations using
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ElasticsearchEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ElasticsearchEndpointBuilderFactory.java
index cef6fd6..05e5848 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ElasticsearchEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ElasticsearchEndpointBuilderFactory.java
@@ -314,18 +314,18 @@ public interface ElasticsearchEndpointBuilderFactory {
*/
enum ElasticsearchOperation {
Index,
-Update,
-Bulk,
-BulkIndex,
-GetById,
-MultiGet,
-MultiSearch,
-Delete,
-DeleteIndex,
-Search,
-Exists,
-Ping,
-Info;
+ Update,
+ Bulk,
+ BulkIndex,
+ GetById,
+ MultiGet,
+ MultiSearch,
+ Delete,
+ DeleteIndex,
+ Search,
+ Exists,
+ Ping,
+ Info;
}
/**
* The elasticsearch component is used for interfacing with ElasticSearch
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ElsqlEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ElsqlEndpointBuilderFactory.java
index 7974fcb..fe980d0 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ElsqlEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ElsqlEndpointBuilderFactory.java
@@ -1994,12 +1994,12 @@ public interface ElsqlEndpointBuilderFactory {
*/
enum ElSqlDatabaseVendor {
Default,
-Postgres,
-HSql,
-MySql,
-Oracle,
-SqlServer2008,
-Veritca;
+ Postgres,
+ HSql,
+ MySql,
+ Oracle,
+ SqlServer2008,
+ Veritca;
}
/**
@@ -2008,8 +2008,8 @@ Veritca;
*/
enum SqlOutputType {
SelectOne,
-SelectList,
-StreamList;
+ SelectList,
+ StreamList;
}
/**
* The elsql component is an extension to the existing SQL Component that
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/EtcdEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/EtcdEndpointBuilderFactory.java
index 3a3bedc..869c13d 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/EtcdEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/EtcdEndpointBuilderFactory.java
@@ -1129,8 +1129,8 @@ public interface EtcdEndpointBuilderFactory {
*/
enum EtcdNamespace {
stats,
-watch,
-keys;
+ watch,
+ keys;
}
/**
* The camel etcd component allows you to work with Etcd, a distributed
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FacebookEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FacebookEndpointBuilderFactory.java
index c848836..4015f33 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FacebookEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FacebookEndpointBuilderFactory.java
@@ -4434,11 +4434,11 @@ public interface FacebookEndpointBuilderFactory {
*/
enum PictureSize {
square,
-small,
-normal,
-large,
-thumbnail,
-album;
+ small,
+ normal,
+ large,
+ thumbnail,
+ album;
}
/**
* The Facebook component provides access to all of the Facebook APIs
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FhirEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FhirEndpointBuilderFactory.java
index d090f87..ccc6004 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FhirEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FhirEndpointBuilderFactory.java
@@ -1478,18 +1478,18 @@ public interface FhirEndpointBuilderFactory {
*/
enum FhirApiName {
CAPABILITIES,
-CREATE,
-DELETE,
-HISTORY,
-LOAD_PAGE,
-META,
-OPERATION,
-PATCH,
-READ,
-SEARCH,
-TRANSACTION,
-UPDATE,
-VALIDATE;
+ CREATE,
+ DELETE,
+ HISTORY,
+ LOAD_PAGE,
+ META,
+ OPERATION,
+ PATCH,
+ READ,
+ SEARCH,
+ TRANSACTION,
+ UPDATE,
+ VALIDATE;
}
/**
@@ -1497,7 +1497,7 @@ VALIDATE;
*/
enum EncodingEnum {
JSON,
-XML;
+ XML;
}
/**
@@ -1505,10 +1505,10 @@ XML;
*/
enum FhirVersionEnum {
DSTU2,
-DSTU2_HL7ORG,
-DSTU2_1,
-DSTU3,
-R4;
+ DSTU2_HL7ORG,
+ DSTU2_1,
+ DSTU3,
+ R4;
}
/**
@@ -1516,10 +1516,10 @@ R4;
*/
enum SummaryEnum {
COUNT,
-TEXT,
-DATA,
-TRUE,
-FALSE;
+ TEXT,
+ DATA,
+ TRUE,
+ FALSE;
}
/**
@@ -1528,7 +1528,7 @@ FALSE;
*/
enum ServerValidationModeEnum {
NEVER,
-ONCE;
+ ONCE;
}
/**
* The fhir component is used for working with the FHIR protocol (health
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FileEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FileEndpointBuilderFactory.java
index 2c91ce5..e013c8e 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FileEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FileEndpointBuilderFactory.java
@@ -2913,11 +2913,11 @@ public interface FileEndpointBuilderFactory {
*/
enum GenericFileExist {
Override,
-Append,
-Fail,
-Ignore,
-Move,
-TryRename;
+ Append,
+ Fail,
+ Ignore,
+ Move,
+ TryRename;
}
/**
* The file component is used for reading or writing files. Creates a
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FlatpackEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FlatpackEndpointBuilderFactory.java
index a574333..7a96964 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FlatpackEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FlatpackEndpointBuilderFactory.java
@@ -1162,7 +1162,7 @@ public interface FlatpackEndpointBuilderFactory {
*/
enum FlatpackType {
fixed,
-delim;
+ delim;
}
/**
* The flatpack component supports fixed width and delimited file parsing
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FlinkEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FlinkEndpointBuilderFactory.java
index 194f8b5..a2ca4aa 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FlinkEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FlinkEndpointBuilderFactory.java
@@ -221,7 +221,7 @@ public interface FlinkEndpointBuilderFactory {
*/
enum EndpointType {
dataset,
-datastream;
+ datastream;
}
/**
* The flink component can be used to send DataSet jobs to Apache Flink
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FopEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FopEndpointBuilderFactory.java
index 0199a45..8ffb07d 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FopEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FopEndpointBuilderFactory.java
@@ -152,15 +152,15 @@ public interface FopEndpointBuilderFactory {
*/
enum FopOutputType {
pdf,
-ps,
-pcl,
-png,
-jpeg,
-svg,
-xml,
-mif,
-rtf,
-txt;
+ ps,
+ pcl,
+ png,
+ jpeg,
+ svg,
+ xml,
+ mif,
+ rtf,
+ txt;
}
/**
* The fop component allows you to render a message into different output
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FtpEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FtpEndpointBuilderFactory.java
index 80e34d5..84c37fc 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FtpEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FtpEndpointBuilderFactory.java
@@ -4250,8 +4250,8 @@ public interface FtpEndpointBuilderFactory {
*/
enum PathSeparator {
UNIX,
-Windows,
-Auto;
+ Windows,
+ Auto;
}
/**
@@ -4260,11 +4260,11 @@ Auto;
*/
enum GenericFileExist {
Override,
-Append,
-Fail,
-Ignore,
-Move,
-TryRename;
+ Append,
+ Fail,
+ Ignore,
+ Move,
+ TryRename;
}
/**
* The ftp component is used for uploading or downloading files from FTP
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FtpsEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FtpsEndpointBuilderFactory.java
index 7465003..36b0c2f 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FtpsEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/FtpsEndpointBuilderFactory.java
@@ -4844,8 +4844,8 @@ public interface FtpsEndpointBuilderFactory {
*/
enum PathSeparator {
UNIX,
-Windows,
-Auto;
+ Windows,
+ Auto;
}
/**
@@ -4854,11 +4854,11 @@ Auto;
*/
enum GenericFileExist {
Override,
-Append,
-Fail,
-Ignore,
-Move,
-TryRename;
+ Append,
+ Fail,
+ Ignore,
+ Move,
+ TryRename;
}
/**
* The ftps (FTP secure SSL/TLS) component is used for uploading or
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GangliaEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GangliaEndpointBuilderFactory.java
index a5af0b8..a5b34e3 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GangliaEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GangliaEndpointBuilderFactory.java
@@ -316,7 +316,7 @@ public interface GangliaEndpointBuilderFactory {
*/
enum UDPAddressingMode {
MULTICAST,
-UNICAST;
+ UNICAST;
}
/**
@@ -325,9 +325,9 @@ UNICAST;
*/
enum GMetricSlope {
ZERO,
-POSITIVE,
-NEGATIVE,
-BOTH;
+ POSITIVE,
+ NEGATIVE,
+ BOTH;
}
/**
@@ -336,14 +336,14 @@ BOTH;
*/
enum GMetricType {
STRING,
-INT8,
-UINT8,
-INT16,
-UINT16,
-INT32,
-UINT32,
-FLOAT,
-DOUBLE;
+ INT8,
+ UINT8,
+ INT16,
+ UINT16,
+ INT32,
+ UINT32,
+ FLOAT,
+ DOUBLE;
}
/**
* The ganglia component is used for sending metrics to the Ganglia
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GitEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GitEndpointBuilderFactory.java
index 8043561..eb4ccaf 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GitEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GitEndpointBuilderFactory.java
@@ -587,8 +587,8 @@ public interface GitEndpointBuilderFactory {
*/
enum GitType {
COMMIT,
-TAG,
-BRANCH;
+ TAG,
+ BRANCH;
}
/**
* The git component is used for working with git repositories. Creates a
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GitHubEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GitHubEndpointBuilderFactory.java
index c2b2a21..2802326 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GitHubEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GitHubEndpointBuilderFactory.java
@@ -582,14 +582,14 @@ public interface GitHubEndpointBuilderFactory {
*/
enum GitHubType {
CLOSEPULLREQUEST,
-PULLREQUESTCOMMENT,
-COMMIT,
-PULLREQUEST,
-TAG,
-PULLREQUESTSTATE,
-PULLREQUESTFILES,
-GETCOMMITFILE,
-CREATEISSUE;
+ PULLREQUESTCOMMENT,
+ COMMIT,
+ PULLREQUEST,
+ TAG,
+ PULLREQUESTSTATE,
+ PULLREQUESTFILES,
+ GETCOMMITFILE,
+ CREATEISSUE;
}
/**
* The github component is used for integrating Camel with github. Creates a
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GoogleCalendarEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GoogleCalendarEndpointBuilderFactory.java
index cd32a58..3b25266 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GoogleCalendarEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GoogleCalendarEndpointBuilderFactory.java
@@ -757,13 +757,13 @@ public interface GoogleCalendarEndpointBuilderFactory {
*/
enum GoogleCalendarApiName {
ACL,
-LIST,
-CALENDARS,
-CHANNELS,
-COLORS,
-FREEBUSY,
-EVENTS,
-SETTINGS;
+ LIST,
+ CALENDARS,
+ CHANNELS,
+ COLORS,
+ FREEBUSY,
+ EVENTS,
+ SETTINGS;
}
/**
* The google-calendar component provides access to Google Calendar. Creates
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GoogleDriveEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GoogleDriveEndpointBuilderFactory.java
index ae79a87..e691c4a 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GoogleDriveEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GoogleDriveEndpointBuilderFactory.java
@@ -769,18 +769,18 @@ public interface GoogleDriveEndpointBuilderFactory {
*/
enum GoogleDriveApiName {
DRIVE_ABOUT,
-DRIVE_APPS,
-DRIVE_CHANGES,
-DRIVE_CHANNELS,
-DRIVE_CHILDREN,
-DRIVE_COMMENTS,
-DRIVE_FILES,
-DRIVE_PARENTS,
-DRIVE_PERMISSIONS,
-DRIVE_PROPERTIES,
-DRIVE_REALTIME,
-DRIVE_REPLIES,
-DRIVE_REVISIONS;
+ DRIVE_APPS,
+ DRIVE_CHANGES,
+ DRIVE_CHANNELS,
+ DRIVE_CHILDREN,
+ DRIVE_COMMENTS,
+ DRIVE_FILES,
+ DRIVE_PARENTS,
+ DRIVE_PERMISSIONS,
+ DRIVE_PROPERTIES,
+ DRIVE_REALTIME,
+ DRIVE_REPLIES,
+ DRIVE_REVISIONS;
}
/**
* The google-drive component provides access to Google Drive file storage
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GoogleMailEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GoogleMailEndpointBuilderFactory.java
index 67253ed..c814864 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GoogleMailEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GoogleMailEndpointBuilderFactory.java
@@ -618,12 +618,12 @@ public interface GoogleMailEndpointBuilderFactory {
*/
enum GoogleMailApiName {
THREADS,
-MESSAGES,
-ATTACHMENTS,
-LABELS,
-HISTORY,
-DRAFTS,
-USERS;
+ MESSAGES,
+ ATTACHMENTS,
+ LABELS,
+ HISTORY,
+ DRAFTS,
+ USERS;
}
/**
* The google-mail component provides access to Google Mail. Creates a
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GooglePubsubEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GooglePubsubEndpointBuilderFactory.java
index f479e48..65c7eb0 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GooglePubsubEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GooglePubsubEndpointBuilderFactory.java
@@ -707,7 +707,7 @@ public interface GooglePubsubEndpointBuilderFactory {
*/
enum AckMode {
AUTO,
-NONE;
+ NONE;
}
/**
* Messaging client for Google Cloud Platform PubSub Service Creates a
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GoogleSheetsEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GoogleSheetsEndpointBuilderFactory.java
index e7340ad..76c44ce 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GoogleSheetsEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GoogleSheetsEndpointBuilderFactory.java
@@ -625,7 +625,7 @@ public interface GoogleSheetsEndpointBuilderFactory {
*/
enum GoogleSheetsApiName {
SPREADSHEETS,
-DATA;
+ DATA;
}
/**
* The google-sheets component provides access to Google Sheets. Creates a
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GridFsEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GridFsEndpointBuilderFactory.java
index 19b735a..ce5f00d 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GridFsEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GridFsEndpointBuilderFactory.java
@@ -792,10 +792,10 @@ public interface GridFsEndpointBuilderFactory {
*/
enum QueryStrategy {
TimeStamp,
-PersistentTimestamp,
-FileAttribute,
-TimeStampAndFileAttribute,
-PersistentTimestampAndFileAttribute;
+ PersistentTimestamp,
+ FileAttribute,
+ TimeStampAndFileAttribute,
+ PersistentTimestampAndFileAttribute;
}
/**
* Component for working with MongoDB GridFS. Creates a builder to build
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GrpcEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GrpcEndpointBuilderFactory.java
index 22c2a5b..20518c2 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GrpcEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/GrpcEndpointBuilderFactory.java
@@ -1170,7 +1170,7 @@ public interface GrpcEndpointBuilderFactory {
*/
enum GrpcConsumerStrategy {
AGGREGATION,
-PROPAGATION;
+ PROPAGATION;
}
/**
@@ -1179,7 +1179,7 @@ PROPAGATION;
*/
enum GrpcProducerStrategy {
SIMPLE,
-STREAMING;
+ STREAMING;
}
/**
@@ -1188,8 +1188,8 @@ STREAMING;
*/
enum GrpcAuthType {
NONE,
-GOOGLE,
-JWT;
+ GOOGLE,
+ JWT;
}
/**
@@ -1198,8 +1198,8 @@ JWT;
*/
enum JwtAlgorithm {
HMAC256,
-HMAC384,
-HMAC512;
+ HMAC384,
+ HMAC512;
}
/**
@@ -1207,8 +1207,8 @@ HMAC512;
*/
enum NegotiationType {
TLS,
-PLAINTEXT_UPGRADE,
-PLAINTEXT;
+ PLAINTEXT_UPGRADE,
+ PLAINTEXT;
}
/**
* The gRPC component allows to call and expose remote procedures via HTTP/2
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastAtomicnumberEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastAtomicnumberEndpointBuilderFactory.java
index a6bde33..41cd380 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastAtomicnumberEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastAtomicnumberEndpointBuilderFactory.java
@@ -306,41 +306,41 @@ public interface HazelcastAtomicnumberEndpointBuilderFactory {
*/
enum HazelcastOperation {
put,
-delete,
-get,
-update,
-query,
-getAll,
-clear,
-putIfAbsent,
-allAll,
-removeAll,
-retainAll,
-evict,
-evictAll,
-valueCount,
-containsKey,
-containsValue,
-keySet,
-removevalue,
-increment,
-decrement,
-setvalue,
-destroy,
-compareAndSet,
-getAndAdd,
-add,
-offer,
-peek,
-poll,
-remainingCapacity,
-drainTo,
-removeIf,
-take,
-publish,
-readOnceHeal,
-readOnceTail,
-capacity;
+ delete,
+ get,
+ update,
+ query,
+ getAll,
+ clear,
+ putIfAbsent,
+ allAll,
+ removeAll,
+ retainAll,
+ evict,
+ evictAll,
+ valueCount,
+ containsKey,
+ containsValue,
+ keySet,
+ removevalue,
+ increment,
+ decrement,
+ setvalue,
+ destroy,
+ compareAndSet,
+ getAndAdd,
+ add,
+ offer,
+ peek,
+ poll,
+ remainingCapacity,
+ drainTo,
+ removeIf,
+ take,
+ publish,
+ readOnceHeal,
+ readOnceTail,
+ capacity;
}
/**
* The hazelcast-atomicvalue component is used to access Hazelcast atomic
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastInstanceEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastInstanceEndpointBuilderFactory.java
index d8ac8c7..5722d12 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastInstanceEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastInstanceEndpointBuilderFactory.java
@@ -302,41 +302,41 @@ public interface HazelcastInstanceEndpointBuilderFactory {
*/
enum HazelcastOperation {
put,
-delete,
-get,
-update,
-query,
-getAll,
-clear,
-putIfAbsent,
-allAll,
-removeAll,
-retainAll,
-evict,
-evictAll,
-valueCount,
-containsKey,
-containsValue,
-keySet,
-removevalue,
-increment,
-decrement,
-setvalue,
-destroy,
-compareAndSet,
-getAndAdd,
-add,
-offer,
-peek,
-poll,
-remainingCapacity,
-drainTo,
-removeIf,
-take,
-publish,
-readOnceHeal,
-readOnceTail,
-capacity;
+ delete,
+ get,
+ update,
+ query,
+ getAll,
+ clear,
+ putIfAbsent,
+ allAll,
+ removeAll,
+ retainAll,
+ evict,
+ evictAll,
+ valueCount,
+ containsKey,
+ containsValue,
+ keySet,
+ removevalue,
+ increment,
+ decrement,
+ setvalue,
+ destroy,
+ compareAndSet,
+ getAndAdd,
+ add,
+ offer,
+ peek,
+ poll,
+ remainingCapacity,
+ drainTo,
+ removeIf,
+ take,
+ publish,
+ readOnceHeal,
+ readOnceTail,
+ capacity;
}
/**
@@ -345,7 +345,7 @@ capacity;
*/
enum HazelcastQueueConsumerMode {
listen,
-poll;
+ poll;
}
/**
* The hazelcast-instance component is used to consume join/leave events of
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastListEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastListEndpointBuilderFactory.java
index cf57eb2..919dc2f 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastListEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastListEndpointBuilderFactory.java
@@ -1015,41 +1015,41 @@ public interface HazelcastListEndpointBuilderFactory {
*/
enum HazelcastOperation {
put,
-delete,
-get,
-update,
-query,
-getAll,
-clear,
-putIfAbsent,
-allAll,
-removeAll,
-retainAll,
-evict,
-evictAll,
-valueCount,
-containsKey,
-containsValue,
-keySet,
-removevalue,
-increment,
-decrement,
-setvalue,
-destroy,
-compareAndSet,
-getAndAdd,
-add,
-offer,
-peek,
-poll,
-remainingCapacity,
-drainTo,
-removeIf,
-take,
-publish,
-readOnceHeal,
-readOnceTail,
-capacity;
+ delete,
+ get,
+ update,
+ query,
+ getAll,
+ clear,
+ putIfAbsent,
+ allAll,
+ removeAll,
+ retainAll,
+ evict,
+ evictAll,
+ valueCount,
+ containsKey,
+ containsValue,
+ keySet,
+ removevalue,
+ increment,
+ decrement,
+ setvalue,
+ destroy,
+ compareAndSet,
+ getAndAdd,
+ add,
+ offer,
+ peek,
+ poll,
+ remainingCapacity,
+ drainTo,
+ removeIf,
+ take,
+ publish,
+ readOnceHeal,
+ readOnceTail,
+ capacity;
}
/**
@@ -1058,7 +1058,7 @@ capacity;
*/
enum HazelcastQueueConsumerMode {
listen,
-poll;
+ poll;
}
/**
* The hazelcast-list component is used to access Hazelcast distributed
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastMapEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastMapEndpointBuilderFactory.java
index c56925b..d0bfa26 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastMapEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastMapEndpointBuilderFactory.java
@@ -1013,41 +1013,41 @@ public interface HazelcastMapEndpointBuilderFactory {
*/
enum HazelcastOperation {
put,
-delete,
-get,
-update,
-query,
-getAll,
-clear,
-putIfAbsent,
-allAll,
-removeAll,
-retainAll,
-evict,
-evictAll,
-valueCount,
-containsKey,
-containsValue,
-keySet,
-removevalue,
-increment,
-decrement,
-setvalue,
-destroy,
-compareAndSet,
-getAndAdd,
-add,
-offer,
-peek,
-poll,
-remainingCapacity,
-drainTo,
-removeIf,
-take,
-publish,
-readOnceHeal,
-readOnceTail,
-capacity;
+ delete,
+ get,
+ update,
+ query,
+ getAll,
+ clear,
+ putIfAbsent,
+ allAll,
+ removeAll,
+ retainAll,
+ evict,
+ evictAll,
+ valueCount,
+ containsKey,
+ containsValue,
+ keySet,
+ removevalue,
+ increment,
+ decrement,
+ setvalue,
+ destroy,
+ compareAndSet,
+ getAndAdd,
+ add,
+ offer,
+ peek,
+ poll,
+ remainingCapacity,
+ drainTo,
+ removeIf,
+ take,
+ publish,
+ readOnceHeal,
+ readOnceTail,
+ capacity;
}
/**
@@ -1056,7 +1056,7 @@ capacity;
*/
enum HazelcastQueueConsumerMode {
listen,
-poll;
+ poll;
}
/**
* The hazelcast-map component is used to access Hazelcast distributed map.
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastMultimapEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastMultimapEndpointBuilderFactory.java
index 54bf4cf..39cc767 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastMultimapEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastMultimapEndpointBuilderFactory.java
@@ -1028,41 +1028,41 @@ public interface HazelcastMultimapEndpointBuilderFactory {
*/
enum HazelcastOperation {
put,
-delete,
-get,
-update,
-query,
-getAll,
-clear,
-putIfAbsent,
-allAll,
-removeAll,
-retainAll,
-evict,
-evictAll,
-valueCount,
-containsKey,
-containsValue,
-keySet,
-removevalue,
-increment,
-decrement,
-setvalue,
-destroy,
-compareAndSet,
-getAndAdd,
-add,
-offer,
-peek,
-poll,
-remainingCapacity,
-drainTo,
-removeIf,
-take,
-publish,
-readOnceHeal,
-readOnceTail,
-capacity;
+ delete,
+ get,
+ update,
+ query,
+ getAll,
+ clear,
+ putIfAbsent,
+ allAll,
+ removeAll,
+ retainAll,
+ evict,
+ evictAll,
+ valueCount,
+ containsKey,
+ containsValue,
+ keySet,
+ removevalue,
+ increment,
+ decrement,
+ setvalue,
+ destroy,
+ compareAndSet,
+ getAndAdd,
+ add,
+ offer,
+ peek,
+ poll,
+ remainingCapacity,
+ drainTo,
+ removeIf,
+ take,
+ publish,
+ readOnceHeal,
+ readOnceTail,
+ capacity;
}
/**
@@ -1071,7 +1071,7 @@ capacity;
*/
enum HazelcastQueueConsumerMode {
listen,
-poll;
+ poll;
}
/**
* The hazelcast-multimap component is used to to access Hazelcast
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastQueueEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastQueueEndpointBuilderFactory.java
index fea54a1..dca3342 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastQueueEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastQueueEndpointBuilderFactory.java
@@ -1019,41 +1019,41 @@ public interface HazelcastQueueEndpointBuilderFactory {
*/
enum HazelcastOperation {
put,
-delete,
-get,
-update,
-query,
-getAll,
-clear,
-putIfAbsent,
-allAll,
-removeAll,
-retainAll,
-evict,
-evictAll,
-valueCount,
-containsKey,
-containsValue,
-keySet,
-removevalue,
-increment,
-decrement,
-setvalue,
-destroy,
-compareAndSet,
-getAndAdd,
-add,
-offer,
-peek,
-poll,
-remainingCapacity,
-drainTo,
-removeIf,
-take,
-publish,
-readOnceHeal,
-readOnceTail,
-capacity;
+ delete,
+ get,
+ update,
+ query,
+ getAll,
+ clear,
+ putIfAbsent,
+ allAll,
+ removeAll,
+ retainAll,
+ evict,
+ evictAll,
+ valueCount,
+ containsKey,
+ containsValue,
+ keySet,
+ removevalue,
+ increment,
+ decrement,
+ setvalue,
+ destroy,
+ compareAndSet,
+ getAndAdd,
+ add,
+ offer,
+ peek,
+ poll,
+ remainingCapacity,
+ drainTo,
+ removeIf,
+ take,
+ publish,
+ readOnceHeal,
+ readOnceTail,
+ capacity;
}
/**
@@ -1062,7 +1062,7 @@ capacity;
*/
enum HazelcastQueueConsumerMode {
listen,
-poll;
+ poll;
}
/**
* The hazelcast-queue component is used to access Hazelcast distributed
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastReplicatedmapEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastReplicatedmapEndpointBuilderFactory.java
index 968c9c3..5b54c3f 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastReplicatedmapEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastReplicatedmapEndpointBuilderFactory.java
@@ -1036,41 +1036,41 @@ public interface HazelcastReplicatedmapEndpointBuilderFactory {
*/
enum HazelcastOperation {
put,
-delete,
-get,
-update,
-query,
-getAll,
-clear,
-putIfAbsent,
-allAll,
-removeAll,
-retainAll,
-evict,
-evictAll,
-valueCount,
-containsKey,
-containsValue,
-keySet,
-removevalue,
-increment,
-decrement,
-setvalue,
-destroy,
-compareAndSet,
-getAndAdd,
-add,
-offer,
-peek,
-poll,
-remainingCapacity,
-drainTo,
-removeIf,
-take,
-publish,
-readOnceHeal,
-readOnceTail,
-capacity;
+ delete,
+ get,
+ update,
+ query,
+ getAll,
+ clear,
+ putIfAbsent,
+ allAll,
+ removeAll,
+ retainAll,
+ evict,
+ evictAll,
+ valueCount,
+ containsKey,
+ containsValue,
+ keySet,
+ removevalue,
+ increment,
+ decrement,
+ setvalue,
+ destroy,
+ compareAndSet,
+ getAndAdd,
+ add,
+ offer,
+ peek,
+ poll,
+ remainingCapacity,
+ drainTo,
+ removeIf,
+ take,
+ publish,
+ readOnceHeal,
+ readOnceTail,
+ capacity;
}
/**
@@ -1079,7 +1079,7 @@ capacity;
*/
enum HazelcastQueueConsumerMode {
listen,
-poll;
+ poll;
}
/**
* The hazelcast-replicatedmap component is used to access Hazelcast
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastRingbufferEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastRingbufferEndpointBuilderFactory.java
index 8f198b8..018c424 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastRingbufferEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastRingbufferEndpointBuilderFactory.java
@@ -303,41 +303,41 @@ public interface HazelcastRingbufferEndpointBuilderFactory {
*/
enum HazelcastOperation {
put,
-delete,
-get,
-update,
-query,
-getAll,
-clear,
-putIfAbsent,
-allAll,
-removeAll,
-retainAll,
-evict,
-evictAll,
-valueCount,
-containsKey,
-containsValue,
-keySet,
-removevalue,
-increment,
-decrement,
-setvalue,
-destroy,
-compareAndSet,
-getAndAdd,
-add,
-offer,
-peek,
-poll,
-remainingCapacity,
-drainTo,
-removeIf,
-take,
-publish,
-readOnceHeal,
-readOnceTail,
-capacity;
+ delete,
+ get,
+ update,
+ query,
+ getAll,
+ clear,
+ putIfAbsent,
+ allAll,
+ removeAll,
+ retainAll,
+ evict,
+ evictAll,
+ valueCount,
+ containsKey,
+ containsValue,
+ keySet,
+ removevalue,
+ increment,
+ decrement,
+ setvalue,
+ destroy,
+ compareAndSet,
+ getAndAdd,
+ add,
+ offer,
+ peek,
+ poll,
+ remainingCapacity,
+ drainTo,
+ removeIf,
+ take,
+ publish,
+ readOnceHeal,
+ readOnceTail,
+ capacity;
}
/**
* The hazelcast-ringbuffer component is used to access Hazelcast
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastSedaEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastSedaEndpointBuilderFactory.java
index 0e7803c..57effe5 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastSedaEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastSedaEndpointBuilderFactory.java
@@ -1015,41 +1015,41 @@ public interface HazelcastSedaEndpointBuilderFactory {
*/
enum HazelcastOperation {
put,
-delete,
-get,
-update,
-query,
-getAll,
-clear,
-putIfAbsent,
-allAll,
-removeAll,
-retainAll,
-evict,
-evictAll,
-valueCount,
-containsKey,
-containsValue,
-keySet,
-removevalue,
-increment,
-decrement,
-setvalue,
-destroy,
-compareAndSet,
-getAndAdd,
-add,
-offer,
-peek,
-poll,
-remainingCapacity,
-drainTo,
-removeIf,
-take,
-publish,
-readOnceHeal,
-readOnceTail,
-capacity;
+ delete,
+ get,
+ update,
+ query,
+ getAll,
+ clear,
+ putIfAbsent,
+ allAll,
+ removeAll,
+ retainAll,
+ evict,
+ evictAll,
+ valueCount,
+ containsKey,
+ containsValue,
+ keySet,
+ removevalue,
+ increment,
+ decrement,
+ setvalue,
+ destroy,
+ compareAndSet,
+ getAndAdd,
+ add,
+ offer,
+ peek,
+ poll,
+ remainingCapacity,
+ drainTo,
+ removeIf,
+ take,
+ publish,
+ readOnceHeal,
+ readOnceTail,
+ capacity;
}
/**
@@ -1058,7 +1058,7 @@ capacity;
*/
enum HazelcastQueueConsumerMode {
listen,
-poll;
+ poll;
}
/**
* The hazelcast-seda component is used to access Hazelcast BlockingQueue.
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastSetEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastSetEndpointBuilderFactory.java
index e53a3b2..cb3efc7 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastSetEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastSetEndpointBuilderFactory.java
@@ -1013,41 +1013,41 @@ public interface HazelcastSetEndpointBuilderFactory {
*/
enum HazelcastOperation {
put,
-delete,
-get,
-update,
-query,
-getAll,
-clear,
-putIfAbsent,
-allAll,
-removeAll,
-retainAll,
-evict,
-evictAll,
-valueCount,
-containsKey,
-containsValue,
-keySet,
-removevalue,
-increment,
-decrement,
-setvalue,
-destroy,
-compareAndSet,
-getAndAdd,
-add,
-offer,
-peek,
-poll,
-remainingCapacity,
-drainTo,
-removeIf,
-take,
-publish,
-readOnceHeal,
-readOnceTail,
-capacity;
+ delete,
+ get,
+ update,
+ query,
+ getAll,
+ clear,
+ putIfAbsent,
+ allAll,
+ removeAll,
+ retainAll,
+ evict,
+ evictAll,
+ valueCount,
+ containsKey,
+ containsValue,
+ keySet,
+ removevalue,
+ increment,
+ decrement,
+ setvalue,
+ destroy,
+ compareAndSet,
+ getAndAdd,
+ add,
+ offer,
+ peek,
+ poll,
+ remainingCapacity,
+ drainTo,
+ removeIf,
+ take,
+ publish,
+ readOnceHeal,
+ readOnceTail,
+ capacity;
}
/**
@@ -1056,7 +1056,7 @@ capacity;
*/
enum HazelcastQueueConsumerMode {
listen,
-poll;
+ poll;
}
/**
* The camel Endpoint to access Hazelcast distributed set. Creates a builder
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastTopicEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastTopicEndpointBuilderFactory.java
index cfb4572..7d50fc5 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastTopicEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HazelcastTopicEndpointBuilderFactory.java
@@ -1019,41 +1019,41 @@ public interface HazelcastTopicEndpointBuilderFactory {
*/
enum HazelcastOperation {
put,
-delete,
-get,
-update,
-query,
-getAll,
-clear,
-putIfAbsent,
-allAll,
-removeAll,
-retainAll,
-evict,
-evictAll,
-valueCount,
-containsKey,
-containsValue,
-keySet,
-removevalue,
-increment,
-decrement,
-setvalue,
-destroy,
-compareAndSet,
-getAndAdd,
-add,
-offer,
-peek,
-poll,
-remainingCapacity,
-drainTo,
-removeIf,
-take,
-publish,
-readOnceHeal,
-readOnceTail,
-capacity;
+ delete,
+ get,
+ update,
+ query,
+ getAll,
+ clear,
+ putIfAbsent,
+ allAll,
+ removeAll,
+ retainAll,
+ evict,
+ evictAll,
+ valueCount,
+ containsKey,
+ containsValue,
+ keySet,
+ removevalue,
+ increment,
+ decrement,
+ setvalue,
+ destroy,
+ compareAndSet,
+ getAndAdd,
+ add,
+ offer,
+ peek,
+ poll,
+ remainingCapacity,
+ drainTo,
+ removeIf,
+ take,
+ publish,
+ readOnceHeal,
+ readOnceTail,
+ capacity;
}
/**
@@ -1062,7 +1062,7 @@ capacity;
*/
enum HazelcastQueueConsumerMode {
listen,
-poll;
+ poll;
}
/**
* The hazelcast-topic component is used to access Hazelcast distributed
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HdfsEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HdfsEndpointBuilderFactory.java
index f23ede1..59de244 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HdfsEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HdfsEndpointBuilderFactory.java
@@ -1790,7 +1790,7 @@ public interface HdfsEndpointBuilderFactory {
*/
enum HdfsFileSystemType {
LOCAL,
-HDFS;
+ HDFS;
}
/**
@@ -1799,10 +1799,10 @@ HDFS;
*/
enum HdfsFileType {
NORMAL_FILE,
-SEQUENCE_FILE,
-MAP_FILE,
-BLOOMMAP_FILE,
-ARRAY_FILE;
+ SEQUENCE_FILE,
+ MAP_FILE,
+ BLOOMMAP_FILE,
+ ARRAY_FILE;
}
/**
@@ -1811,14 +1811,14 @@ ARRAY_FILE;
*/
enum WritableType {
NULL,
-BOOLEAN,
-BYTE,
-INT,
-FLOAT,
-LONG,
-DOUBLE,
-TEXT,
-BYTES;
+ BOOLEAN,
+ BYTE,
+ INT,
+ FLOAT,
+ LONG,
+ DOUBLE,
+ TEXT,
+ BYTES;
}
/**
@@ -1827,8 +1827,8 @@ BYTES;
*/
enum HdfsCompressionCodec {
DEFAULT,
-GZIP,
-BZIP2;
+ GZIP,
+ BZIP2;
}
/**
@@ -1837,8 +1837,8 @@ BZIP2;
*/
enum CompressionType {
NONE,
-RECORD,
-BLOCK;
+ RECORD,
+ BLOCK;
}
/**
* For reading/writing from/to an HDFS filesystem using Hadoop 2.x. Creates
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HttpEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HttpEndpointBuilderFactory.java
index 532e4b3..263b73b 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HttpEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/HttpEndpointBuilderFactory.java
@@ -589,13 +589,13 @@ public interface HttpEndpointBuilderFactory {
*/
enum HttpMethods {
GET,
-POST,
-PUT,
-DELETE,
-HEAD,
-OPTIONS,
-TRACE,
-PATCH;
+ POST,
+ PUT,
+ DELETE,
+ HEAD,
+ OPTIONS,
+ TRACE,
+ PATCH;
}
/**
* For calling out to external HTTP servers using Apache HTTP Client 4.x.
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IAMEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IAMEndpointBuilderFactory.java
index b8c1350..abf6d35 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IAMEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IAMEndpointBuilderFactory.java
@@ -116,18 +116,18 @@ public interface IAMEndpointBuilderFactory {
*/
enum IAMOperations {
listAccessKeys,
-createUser,
-deleteUser,
-getUser,
-listUsers,
-createAccessKey,
-deleteAccessKey,
-updateAccessKey,
-createGroup,
-deleteGroup,
-listGroups,
-addUserToGroup,
-removeUserFromGroup;
+ createUser,
+ deleteUser,
+ getUser,
+ listUsers,
+ createAccessKey,
+ deleteAccessKey,
+ updateAccessKey,
+ createGroup,
+ deleteGroup,
+ listGroups,
+ addUserToGroup,
+ removeUserFromGroup;
}
/**
* The aws-iam is used for managing Amazon IAM Creates a builder to build
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteCacheEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteCacheEndpointBuilderFactory.java
index b0fb4ee..5da53c8 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteCacheEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteCacheEndpointBuilderFactory.java
@@ -727,11 +727,11 @@ public interface IgniteCacheEndpointBuilderFactory {
*/
enum CachePeekMode {
ALL,
-NEAR,
-PRIMARY,
-BACKUP,
-ONHEAP,
-OFFHEAP;
+ NEAR,
+ PRIMARY,
+ BACKUP,
+ ONHEAP,
+ OFFHEAP;
}
/**
@@ -741,12 +741,12 @@ OFFHEAP;
*/
enum IgniteCacheOperation {
GET,
-PUT,
-REMOVE,
-SIZE,
-REBALANCE,
-QUERY,
-CLEAR;
+ PUT,
+ REMOVE,
+ SIZE,
+ REBALANCE,
+ QUERY,
+ CLEAR;
}
/**
* The Ignite Cache endpoint is one of camel-ignite endpoints which allows
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteComputeEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteComputeEndpointBuilderFactory.java
index 65c7962..36a9105 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteComputeEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteComputeEndpointBuilderFactory.java
@@ -158,12 +158,12 @@ public interface IgniteComputeEndpointBuilderFactory {
*/
enum IgniteComputeExecutionType {
CALL,
-BROADCAST,
-APPLY,
-EXECUTE,
-RUN,
-AFFINITY_CALL,
-AFFINITY_RUN;
+ BROADCAST,
+ APPLY,
+ EXECUTE,
+ RUN,
+ AFFINITY_CALL,
+ AFFINITY_RUN;
}
/**
* The Ignite Compute endpoint is one of camel-ignite endpoints which allows
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteIdGenEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteIdGenEndpointBuilderFactory.java
index 8a813cb..062f297 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteIdGenEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteIdGenEndpointBuilderFactory.java
@@ -157,10 +157,10 @@ public interface IgniteIdGenEndpointBuilderFactory {
*/
enum IgniteIdGenOperation {
ADD_AND_GET,
-GET,
-GET_AND_ADD,
-GET_AND_INCREMENT,
-INCREMENT_AND_GET;
+ GET,
+ GET_AND_ADD,
+ GET_AND_INCREMENT,
+ INCREMENT_AND_GET;
}
/**
* The Ignite ID Generator endpoint is one of camel-ignite endpoints which
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteMessagingEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteMessagingEndpointBuilderFactory.java
index a49d5cc..75b3a90 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteMessagingEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteMessagingEndpointBuilderFactory.java
@@ -578,7 +578,7 @@ public interface IgniteMessagingEndpointBuilderFactory {
*/
enum IgniteMessagingSendMode {
ORDERED,
-UNORDERED;
+ UNORDERED;
}
/**
* The Ignite Messaging endpoint is one of camel-ignite endpoints which
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteQueueEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteQueueEndpointBuilderFactory.java
index 84d4dc2..d984e91 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteQueueEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteQueueEndpointBuilderFactory.java
@@ -157,20 +157,20 @@ public interface IgniteQueueEndpointBuilderFactory {
*/
enum IgniteQueueOperation {
CONTAINS,
-ADD,
-SIZE,
-REMOVE,
-ITERATOR,
-CLEAR,
-RETAIN_ALL,
-ARRAY,
-DRAIN,
-ELEMENT,
-PEEK,
-OFFER,
-POLL,
-TAKE,
-PUT;
+ ADD,
+ SIZE,
+ REMOVE,
+ ITERATOR,
+ CLEAR,
+ RETAIN_ALL,
+ ARRAY,
+ DRAIN,
+ ELEMENT,
+ PEEK,
+ OFFER,
+ POLL,
+ TAKE,
+ PUT;
}
/**
* The Ignite Queue endpoint is one of camel-ignite endpoints which allows
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteSetEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteSetEndpointBuilderFactory.java
index 09f4fe5..d252946 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteSetEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/IgniteSetEndpointBuilderFactory.java
@@ -153,13 +153,13 @@ public interface IgniteSetEndpointBuilderFactory {
*/
enum IgniteSetOperation {
CONTAINS,
-ADD,
-SIZE,
-REMOVE,
-ITERATOR,
-CLEAR,
-RETAIN_ALL,
-ARRAY;
+ ADD,
+ SIZE,
+ REMOVE,
+ ITERATOR,
+ CLEAR,
+ RETAIN_ALL,
+ ARRAY;
}
/**
* The Ignite Sets endpoint is one of camel-ignite endpoints which allows
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/InfinispanEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/InfinispanEndpointBuilderFactory.java
index fd3cb0f..e7a1972 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/InfinispanEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/InfinispanEndpointBuilderFactory.java
@@ -1078,26 +1078,26 @@ public interface InfinispanEndpointBuilderFactory {
*/
enum InfinispanOperation {
PUT,
-PUTASYNC,
-PUTALL,
-PUTALLASYNC,
-PUTIFABSENT,
-PUTIFABSENTASYNC,
-GET,
-GETORDEFAULT,
-CONTAINSKEY,
-CONTAINSVALUE,
-REMOVE,
-REMOVEASYNC,
-REPLACE,
-REPLACEASYNC,
-SIZE,
-CLEAR,
-CLEARASYNC,
-QUERY,
-STATS,
-COMPUTE,
-COMPUTEASYNC;
+ PUTASYNC,
+ PUTALL,
+ PUTALLASYNC,
+ PUTIFABSENT,
+ PUTIFABSENTASYNC,
+ GET,
+ GETORDEFAULT,
+ CONTAINSKEY,
+ CONTAINSVALUE,
+ REMOVE,
+ REMOVEASYNC,
+ REPLACE,
+ REPLACEASYNC,
+ SIZE,
+ CLEAR,
+ CLEARASYNC,
+ QUERY,
+ STATS,
+ COMPUTE,
+ COMPUTEASYNC;
}
/**
@@ -1105,36 +1105,36 @@ COMPUTEASYNC;
*/
enum Flag {
ZERO_LOCK_ACQUISITION_TIMEOUT,
-CACHE_MODE_LOCAL,
-SKIP_LOCKING,
-FORCE_WRITE_LOCK,
-SKIP_CACHE_STATUS_CHECK,
-FORCE_ASYNCHRONOUS,
-FORCE_SYNCHRONOUS,
-SKIP_CACHE_STORE,
-SKIP_CACHE_LOAD,
-FAIL_SILENTLY,
-SKIP_REMOTE_LOOKUP,
-SKIP_INDEXING,
-PUT_FOR_EXTERNAL_READ,
-PUT_FOR_STATE_TRANSFER,
-PUT_FOR_X_SITE_STATE_TRANSFER,
-SKIP_SHARED_CACHE_STORE,
-REMOVE_DATA_ON_STOP,
-SKIP_OWNERSHIP_CHECK,
-DELTA_WRITE,
-IGNORE_RETURN_VALUES,
-SKIP_XSITE_BACKUP,
-GUARANTEED_DELIVERY,
-SKIP_LISTENER_NOTIFICATION,
-SKIP_STATISTICS,
-OPERATION_HOTROD,
-OPERATION_MEMCACHED,
-SKIP_INDEX_CLEANUP,
-COMMAND_RETRY,
-ROLLING_UPGRADE,
-REMOTE_ITERATION,
-SKIP_SIZE_OPTIMIZATION;
+ CACHE_MODE_LOCAL,
+ SKIP_LOCKING,
+ FORCE_WRITE_LOCK,
+ SKIP_CACHE_STATUS_CHECK,
+ FORCE_ASYNCHRONOUS,
+ FORCE_SYNCHRONOUS,
+ SKIP_CACHE_STORE,
+ SKIP_CACHE_LOAD,
+ FAIL_SILENTLY,
+ SKIP_REMOTE_LOOKUP,
+ SKIP_INDEXING,
+ PUT_FOR_EXTERNAL_READ,
+ PUT_FOR_STATE_TRANSFER,
+ PUT_FOR_X_SITE_STATE_TRANSFER,
+ SKIP_SHARED_CACHE_STORE,
+ REMOVE_DATA_ON_STOP,
+ SKIP_OWNERSHIP_CHECK,
+ DELTA_WRITE,
+ IGNORE_RETURN_VALUES,
+ SKIP_XSITE_BACKUP,
+ GUARANTEED_DELIVERY,
+ SKIP_LISTENER_NOTIFICATION,
+ SKIP_STATISTICS,
+ OPERATION_HOTROD,
+ OPERATION_MEMCACHED,
+ SKIP_INDEX_CLEANUP,
+ COMMAND_RETRY,
+ ROLLING_UPGRADE,
+ REMOTE_ITERATION,
+ SKIP_SIZE_OPTIMIZATION;
}
/**
* For reading/writing from/to Infinispan distributed key/value store and
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JCacheEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JCacheEndpointBuilderFactory.java
index 509a969..9007f5b 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JCacheEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JCacheEndpointBuilderFactory.java
@@ -1219,9 +1219,9 @@ public interface JCacheEndpointBuilderFactory {
*/
enum EventType {
CREATED,
-UPDATED,
-REMOVED,
-EXPIRED;
+ UPDATED,
+ REMOVED,
+ EXPIRED;
}
/**
* The jcache component enables you to perform caching operations using
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JcloudsEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JcloudsEndpointBuilderFactory.java
index 07be95a..b9a8ba8 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JcloudsEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JcloudsEndpointBuilderFactory.java
@@ -563,7 +563,7 @@ public interface JcloudsEndpointBuilderFactory {
*/
enum JcloudsCommand {
blobstore,
-compute;
+ compute;
}
/**
* For interacting with cloud compute & blobstore service via jclouds.
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JdbcEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JdbcEndpointBuilderFactory.java
index 5cd5b9f..d6a8d23 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JdbcEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JdbcEndpointBuilderFactory.java
@@ -386,8 +386,8 @@ public interface JdbcEndpointBuilderFactory {
*/
enum JdbcOutputType {
SelectOne,
-SelectList,
-StreamList;
+ SelectList,
+ StreamList;
}
/**
* The jdbc component enables you to access databases through JDBC, where
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JiraEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JiraEndpointBuilderFactory.java
index f4e1cf5..81766d7 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JiraEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JiraEndpointBuilderFactory.java
@@ -721,14 +721,14 @@ public interface JiraEndpointBuilderFactory {
*/
enum JiraType {
ADDCOMMENT,
-ADDISSUE,
-ATTACH,
-DELETEISSUE,
-NEWISSUES,
-NEWCOMMENTS,
-UPDATEISSUE,
-TRANSITIONISSUE,
-WATCHERS;
+ ADDISSUE,
+ ATTACH,
+ DELETEISSUE,
+ NEWISSUES,
+ NEWCOMMENTS,
+ UPDATEISSUE,
+ TRANSITIONISSUE,
+ WATCHERS;
}
/**
* The jira component interacts with the JIRA issue tracker. Creates a
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JmsEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JmsEndpointBuilderFactory.java
index 5a666cb..4066a54 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JmsEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JmsEndpointBuilderFactory.java
@@ -4600,11 +4600,11 @@ public interface JmsEndpointBuilderFactory {
*/
enum JmsMessageType {
Bytes,
-Map,
-Object,
-Stream,
-Text,
-Blob;
+ Map,
+ Object,
+ Stream,
+ Text,
+ Blob;
}
/**
@@ -4613,8 +4613,8 @@ Blob;
*/
enum ConsumerType {
Simple,
-Default,
-Custom;
+ Default,
+ Custom;
}
/**
@@ -4623,7 +4623,7 @@ Custom;
*/
enum DefaultTaskExecutorType {
ThreadPool,
-SimpleAsync;
+ SimpleAsync;
}
/**
@@ -4632,8 +4632,8 @@ SimpleAsync;
*/
enum ReplyToType {
Temporary,
-Shared,
-Exclusive;
+ Shared,
+ Exclusive;
}
/**
* The jms component allows messages to be sent to (or consumed from) a JMS
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JoltEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JoltEndpointBuilderFactory.java
index 8fc2f6a..1e9e3d4 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JoltEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JoltEndpointBuilderFactory.java
@@ -197,7 +197,7 @@ public interface JoltEndpointBuilderFactory {
*/
enum JoltInputOutputType {
Hydrated,
-JsonString;
+ JsonString;
}
/**
@@ -206,10 +206,10 @@ JsonString;
*/
enum JoltTransformType {
Chainr,
-Shiftr,
-Defaultr,
-Removr,
-Sortr;
+ Shiftr,
+ Defaultr,
+ Removr,
+ Sortr;
}
/**
* The jolt component allows you to process a JSON messages using an JOLT
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JooqEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JooqEndpointBuilderFactory.java
index c218755..981faaf 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JooqEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JooqEndpointBuilderFactory.java
@@ -810,8 +810,8 @@ public interface JooqEndpointBuilderFactory {
*/
enum JooqOperation {
EXECUTE,
-FETCH,
-NONE;
+ FETCH,
+ NONE;
}
/**
* The jooq component enables you to store and retrieve entities from
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JpaEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JpaEndpointBuilderFactory.java
index 908ba4d..e367ff3 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JpaEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/JpaEndpointBuilderFactory.java
@@ -1629,13 +1629,13 @@ public interface JpaEndpointBuilderFactory {
*/
enum LockModeType {
READ,
-WRITE,
-OPTIMISTIC,
-OPTIMISTIC_FORCE_INCREMENT,
-PESSIMISTIC_READ,
-PESSIMISTIC_WRITE,
-PESSIMISTIC_FORCE_INCREMENT,
-NONE;
+ WRITE,
+ OPTIMISTIC,
+ OPTIMISTIC_FORCE_INCREMENT,
+ PESSIMISTIC_READ,
+ PESSIMISTIC_WRITE,
+ PESSIMISTIC_FORCE_INCREMENT,
+ NONE;
}
/**
* The jpa component enables you to store and retrieve Java objects from
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/Jt400EndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/Jt400EndpointBuilderFactory.java
index cb64845..4656674 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/Jt400EndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/Jt400EndpointBuilderFactory.java
@@ -1423,8 +1423,8 @@ public interface Jt400EndpointBuilderFactory {
*/
enum Jt400Type {
DTAQ,
-PGM,
-SRVPGM;
+ PGM,
+ SRVPGM;
}
/**
@@ -1434,7 +1434,7 @@ SRVPGM;
*/
enum Format {
text,
-binary;
+ binary;
}
/**
@@ -1443,11 +1443,11 @@ binary;
*/
enum SearchType {
EQ,
-NE,
-LT,
-LE,
-GT,
-GE;
+ NE,
+ LT,
+ LE,
+ GT,
+ GE;
}
/**
* The jt400 component allows you to exchanges messages with an AS/400
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/KMSEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/KMSEndpointBuilderFactory.java
index aafac0c..7f00064 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/KMSEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/KMSEndpointBuilderFactory.java
@@ -116,11 +116,11 @@ public interface KMSEndpointBuilderFactory {
*/
enum KMSOperations {
listKeys,
-createKey,
-disableKey,
-scheduleKeyDeletion,
-describeKey,
-enableKey;
+ createKey,
+ disableKey,
+ scheduleKeyDeletion,
+ describeKey,
+ enableKey;
}
/**
* The aws-kms is used for managing Amazon KMS Creates a builder to build
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/KinesisEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/KinesisEndpointBuilderFactory.java
index 2a2f6c6..a5131ef 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/KinesisEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/KinesisEndpointBuilderFactory.java
@@ -1058,10 +1058,10 @@ public interface KinesisEndpointBuilderFactory {
*/
enum ShardIteratorType {
AT_SEQUENCE_NUMBER,
-AFTER_SEQUENCE_NUMBER,
-TRIM_HORIZON,
-LATEST,
-AT_TIMESTAMP;
+ AFTER_SEQUENCE_NUMBER,
+ TRIM_HORIZON,
+ LATEST,
+ AT_TIMESTAMP;
}
/**
@@ -1070,8 +1070,8 @@ AT_TIMESTAMP;
*/
enum KinesisShardClosedStrategyEnum {
ignore,
-fail,
-silent;
+ fail,
+ silent;
}
/**
* The aws-kinesis component is for consuming and producing records from
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/LambdaEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/LambdaEndpointBuilderFactory.java
index d1c41d8..0a1aea1 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/LambdaEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/LambdaEndpointBuilderFactory.java
@@ -200,19 +200,19 @@ public interface LambdaEndpointBuilderFactory {
*/
enum LambdaOperations {
listFunctions,
-getFunction,
-createFunction,
-deleteFunction,
-invokeFunction,
-updateFunction,
-createEventSourceMapping,
-deleteEventSourceMapping,
-listEventSourceMapping,
-listTags,
-tagResource,
-untagResource,
-publishVersion,
-listVersions;
+ getFunction,
+ createFunction,
+ deleteFunction,
+ invokeFunction,
+ updateFunction,
+ createEventSourceMapping,
+ deleteEventSourceMapping,
+ listEventSourceMapping,
+ listTags,
+ tagResource,
+ untagResource,
+ publishVersion,
+ listVersions;
}
/**
* The aws-lambda is used for managing and invoking functions from Amazon
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/LinkedInEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/LinkedInEndpointBuilderFactory.java
index 987cf6c..38de1a8 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/LinkedInEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/LinkedInEndpointBuilderFactory.java
@@ -1051,12 +1051,12 @@ public interface LinkedInEndpointBuilderFactory {
*/
enum LinkedInApiName {
COMMENTS,
-COMPANIES,
-GROUPS,
-JOBS,
-PEOPLE,
-POSTS,
-SEARCH;
+ COMPANIES,
+ GROUPS,
+ JOBS,
+ PEOPLE,
+ POSTS,
+ SEARCH;
}
/**
@@ -1065,15 +1065,15 @@ SEARCH;
*/
enum OAuthScope {
R_BASICPROFILE,
-R_FULLPROFILE,
-R_EMAILADDRESS,
-R_NETWORK,
-R_CONTACTINFO,
-RW_NUS,
-RW_COMPANY_ADMIN,
-RW_GROUPS,
-W_MESSAGES,
-W_SHARE;
+ R_FULLPROFILE,
+ R_EMAILADDRESS,
+ R_NETWORK,
+ R_CONTACTINFO,
+ RW_NUS,
+ RW_COMPANY_ADMIN,
+ RW_GROUPS,
+ W_MESSAGES,
+ W_SHARE;
}
/**
* The linkedin component is used for retrieving LinkedIn user profiles,
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/LogEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/LogEndpointBuilderFactory.java
index 4a582d1..66c3206 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/LogEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/LogEndpointBuilderFactory.java
@@ -584,8 +584,8 @@ public interface LogEndpointBuilderFactory {
*/
enum OutputStyle {
Default,
-Tab,
-Fixed;
+ Tab,
+ Fixed;
}
/**
* The log component logs message exchanges to the underlying logging
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/LuceneEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/LuceneEndpointBuilderFactory.java
index 5ab4909..0f5d177 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/LuceneEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/LuceneEndpointBuilderFactory.java
@@ -214,7 +214,7 @@ public interface LuceneEndpointBuilderFactory {
*/
enum LuceneOperation {
insert,
-query;
+ query;
}
/**
* To insert or query from Apache Lucene databases. Creates a builder to
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MQEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MQEndpointBuilderFactory.java
index 5c96fde..6fba8b4 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MQEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MQEndpointBuilderFactory.java
@@ -116,11 +116,11 @@ public interface MQEndpointBuilderFactory {
*/
enum MQOperations {
listBrokers,
-createBroker,
-deleteBroker,
-rebootBroker,
-updateBroker,
-describeBroker;
+ createBroker,
+ deleteBroker,
+ rebootBroker,
+ updateBroker,
+ describeBroker;
}
/**
* The aws-mq is used for managing Amazon MQ instances. Creates a builder to
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MQTTEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MQTTEndpointBuilderFactory.java
index f16c425..d4efac4 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MQTTEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MQTTEndpointBuilderFactory.java
@@ -2262,8 +2262,8 @@ public interface MQTTEndpointBuilderFactory {
*/
enum QoS {
AT_MOST_ONCE,
-AT_LEAST_ONCE,
-EXACTLY_ONCE;
+ AT_LEAST_ONCE,
+ EXACTLY_ONCE;
}
/**
* Component for communicating with MQTT M2M message brokers using
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MSKEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MSKEndpointBuilderFactory.java
index 13e5aa9..cd36825 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MSKEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MSKEndpointBuilderFactory.java
@@ -116,9 +116,9 @@ public interface MSKEndpointBuilderFactory {
*/
enum MSKOperations {
listClusters,
-createCluster,
-deleteCluster,
-describeCluster;
+ createCluster,
+ deleteCluster,
+ describeCluster;
}
/**
* The aws-kms is used for managing Amazon KMS Creates a builder to build
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MetricsEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MetricsEndpointBuilderFactory.java
index 08bde44..d90c1a3 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MetricsEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MetricsEndpointBuilderFactory.java
@@ -240,10 +240,10 @@ public interface MetricsEndpointBuilderFactory {
*/
enum MetricsType {
gauge,
-counter,
-histogram,
-meter,
-timer;
+ counter,
+ histogram,
+ meter,
+ timer;
}
/**
@@ -252,7 +252,7 @@ timer;
*/
enum MetricsTimerAction {
start,
-stop;
+ stop;
}
/**
* To collect various metrics directly from Camel routes using the
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MicrometerEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MicrometerEndpointBuilderFactory.java
index bb5f91a..6fe9d87 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MicrometerEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MicrometerEndpointBuilderFactory.java
@@ -187,11 +187,11 @@ public interface MicrometerEndpointBuilderFactory {
*/
enum Type {
COUNTER,
-GAUGE,
-LONG_TASK_TIMER,
-TIMER,
-DISTRIBUTION_SUMMARY,
-OTHER;
+ GAUGE,
+ LONG_TASK_TIMER,
+ TIMER,
+ DISTRIBUTION_SUMMARY,
+ OTHER;
}
/**
* To collect various metrics directly from Camel routes using the
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/Mina2EndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/Mina2EndpointBuilderFactory.java
index b7bba53..c4f8ed8 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/Mina2EndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/Mina2EndpointBuilderFactory.java
@@ -1734,10 +1734,10 @@ public interface Mina2EndpointBuilderFactory {
*/
enum Mina2TextLineDelimiter {
DEFAULT,
-AUTO,
-UNIX,
-WINDOWS,
-MAC;
+ AUTO,
+ UNIX,
+ WINDOWS,
+ MAC;
}
/**
* Socket level networking using TCP or UDP with the Apache Mina 2.x
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MongoDbEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MongoDbEndpointBuilderFactory.java
index bf97930..82c5af2 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MongoDbEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MongoDbEndpointBuilderFactory.java
@@ -1245,19 +1245,19 @@ public interface MongoDbEndpointBuilderFactory {
*/
enum MongoDbOperation {
findById,
-findOneByQuery,
-findAll,
-findDistinct,
-insert,
-save,
-update,
-remove,
-bulkWrite,
-aggregate,
-getDbStats,
-getColStats,
-count,
-command;
+ findOneByQuery,
+ findAll,
+ findDistinct,
+ insert,
+ save,
+ update,
+ remove,
+ bulkWrite,
+ aggregate,
+ getDbStats,
+ getColStats,
+ count,
+ command;
}
/**
@@ -1266,8 +1266,8 @@ command;
*/
enum MongoDbOutputType {
DocumentList,
-Document,
-MongoIterable;
+ Document,
+ MongoIterable;
}
/**
* Component for working with documents stored in MongoDB database. Creates
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MyBatisBeanEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MyBatisBeanEndpointBuilderFactory.java
index 8733466..89447e9 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MyBatisBeanEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MyBatisBeanEndpointBuilderFactory.java
@@ -121,8 +121,8 @@ public interface MyBatisBeanEndpointBuilderFactory {
*/
enum ExecutorType {
SIMPLE,
-REUSE,
-BATCH;
+ REUSE,
+ BATCH;
}
/**
* Performs a query, insert, update or delete in a relational database using
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MyBatisEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MyBatisEndpointBuilderFactory.java
index be2acb3..e2ab97b 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MyBatisEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/MyBatisEndpointBuilderFactory.java
@@ -934,8 +934,8 @@ public interface MyBatisEndpointBuilderFactory {
*/
enum ExecutorType {
SIMPLE,
-REUSE,
-BATCH;
+ REUSE,
+ BATCH;
}
/**
@@ -944,13 +944,13 @@ BATCH;
*/
enum StatementType {
SelectOne,
-SelectList,
-Insert,
-InsertList,
-Update,
-UpdateList,
-Delete,
-DeleteList;
+ SelectList,
+ Insert,
+ InsertList,
+ Update,
+ UpdateList,
+ Delete,
+ DeleteList;
}
/**
* Performs a query, poll, insert, update or delete in a relational database
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/NagiosEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/NagiosEndpointBuilderFactory.java
index a29077951..b1f630f 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/NagiosEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/NagiosEndpointBuilderFactory.java
@@ -237,12 +237,12 @@ public interface NagiosEndpointBuilderFactory {
*/
enum Encryption {
NONE,
-TRIPLE_DES,
-XOR,
-RIJNDAEL128,
-RIJNDAEL192,
-RIJNDAEL256,
-BLOWFISH;
+ TRIPLE_DES,
+ XOR,
+ RIJNDAEL128,
+ RIJNDAEL192,
+ RIJNDAEL256,
+ BLOWFISH;
}
/**
@@ -252,8 +252,8 @@ BLOWFISH;
*/
enum NagiosEncryptionMethod {
No,
-Xor,
-TripleDes;
+ Xor,
+ TripleDes;
}
/**
* To send passive checks to Nagios using JSendNSCA. Creates a builder to
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/NettyEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/NettyEndpointBuilderFactory.java
index 3b841c5..db3a22b 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/NettyEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/NettyEndpointBuilderFactory.java
@@ -3619,7 +3619,7 @@ public interface NettyEndpointBuilderFactory {
*/
enum TextLineDelimiter {
LINE,
-NULL;
+ NULL;
}
/**
* Socket level networking using TCP or UDP with the Netty 4.x library.
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/PahoEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/PahoEndpointBuilderFactory.java
index a2923c3..19f90bb 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/PahoEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/PahoEndpointBuilderFactory.java
@@ -873,7 +873,7 @@ public interface PahoEndpointBuilderFactory {
*/
enum PahoPersistence {
FILE,
-MEMORY;
+ MEMORY;
}
/**
* Component for communicating with MQTT M2M message brokers using Eclipse
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/PdfEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/PdfEndpointBuilderFactory.java
index 6882396..f156005 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/PdfEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/PdfEndpointBuilderFactory.java
@@ -285,8 +285,8 @@ public interface PdfEndpointBuilderFactory {
*/
enum PdfOperation {
create,
-append,
-extractText;
+ append,
+ extractText;
}
/**
@@ -295,7 +295,7 @@ extractText;
*/
enum TextProcessingFactory {
autoFormatting,
-lineTermination;
+ lineTermination;
}
/**
* The pdf components provides the ability to create, modify or extract
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/PulsarEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/PulsarEndpointBuilderFactory.java
index 8a5aee8..f354909 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/PulsarEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/PulsarEndpointBuilderFactory.java
@@ -463,8 +463,8 @@ public interface PulsarEndpointBuilderFactory {
*/
enum SubscriptionType {
EXCLUSIVE,
-SHARED,
-FAILOVER;
+ SHARED,
+ FAILOVER;
}
/**
* Camel Apache Pulsar Component Creates a builder to build endpoints for
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/QueueServiceEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/QueueServiceEndpointBuilderFactory.java
index 6971bd2..a787bd9 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/QueueServiceEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/QueueServiceEndpointBuilderFactory.java
@@ -590,13 +590,13 @@ public interface QueueServiceEndpointBuilderFactory {
*/
enum QueueServiceOperations {
listQueues,
-createQueue,
-deleteQueue,
-addMessage,
-retrieveMessage,
-peekMessage,
-updateMessage,
-deleteMessage;
+ createQueue,
+ deleteQueue,
+ addMessage,
+ retrieveMessage,
+ peekMessage,
+ updateMessage,
+ deleteMessage;
}
/**
* The azure-queue component is used for storing and retrieving messages
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ReactiveStreamsEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ReactiveStreamsEndpointBuilderFactory.java
index 444439b..5fce233 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ReactiveStreamsEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ReactiveStreamsEndpointBuilderFactory.java
@@ -529,8 +529,8 @@ public interface ReactiveStreamsEndpointBuilderFactory {
*/
enum ReactiveStreamsBackpressureStrategy {
BUFFER,
-OLDEST,
-LATEST;
+ OLDEST,
+ LATEST;
}
/**
* Reactive Camel using reactive streams Creates a builder to build
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/RedisEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/RedisEndpointBuilderFactory.java
index 344fc44..d95e2e6 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/RedisEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/RedisEndpointBuilderFactory.java
@@ -745,134 +745,134 @@ public interface RedisEndpointBuilderFactory {
*/
enum Command {
PING,
-SET,
-GET,
-QUIT,
-EXISTS,
-DEL,
-TYPE,
-FLUSHDB,
-KEYS,
-RANDOMKEY,
-RENAME,
-RENAMENX,
-RENAMEX,
-DBSIZE,
-EXPIRE,
-EXPIREAT,
-TTL,
-SELECT,
-MOVE,
-FLUSHALL,
-GETSET,
-MGET,
-SETNX,
-SETEX,
-MSET,
-MSETNX,
-DECRBY,
-DECR,
-INCRBY,
-INCR,
-APPEND,
-SUBSTR,
-HSET,
-HGET,
-HSETNX,
-HMSET,
-HMGET,
-HINCRBY,
-HEXISTS,
-HDEL,
-HLEN,
-HKEYS,
-HVALS,
-HGETALL,
-RPUSH,
-LPUSH,
-LLEN,
-LRANGE,
-LTRIM,
-LINDEX,
-LSET,
-LREM,
-LPOP,
-RPOP,
-RPOPLPUSH,
-SADD,
-SMEMBERS,
-SREM,
-SPOP,
-SMOVE,
-SCARD,
-SISMEMBER,
-SINTER,
-SINTERSTORE,
-SUNION,
-SUNIONSTORE,
-SDIFF,
-SDIFFSTORE,
-SRANDMEMBER,
-ZADD,
-ZRANGE,
-ZREM,
-ZINCRBY,
-ZRANK,
-ZREVRANK,
-ZREVRANGE,
-ZCARD,
-ZSCORE,
-MULTI,
-DISCARD,
-EXEC,
-WATCH,
-UNWATCH,
-SORT,
-BLPOP,
-BRPOP,
-AUTH,
-SUBSCRIBE,
-PUBLISH,
-UNSUBSCRIBE,
-PSUBSCRIBE,
-PUNSUBSCRIBE,
-ZCOUNT,
-ZRANGEBYSCORE,
-ZREVRANGEBYSCORE,
-ZREMRANGEBYRANK,
-ZREMRANGEBYSCORE,
-ZUNIONSTORE,
-ZINTERSTORE,
-SAVE,
-BGSAVE,
-BGREWRITEAOF,
-LASTSAVE,
-SHUTDOWN,
-INFO,
-MONITOR,
-SLAVEOF,
-CONFIG,
-STRLEN,
-SYNC,
-LPUSHX,
-PERSIST,
-RPUSHX,
-ECHO,
-LINSERT,
-DEBUG,
-BRPOPLPUSH,
-SETBIT,
-GETBIT,
-SETRANGE,
-GETRANGE,
-PEXPIRE,
-PEXPIREAT,
-GEOADD,
-GEODIST,
-GEOHASH,
-GEOPOS,
-GEORADIUS,
-GEORADIUSBYMEMBER;
+ SET,
+ GET,
+ QUIT,
+ EXISTS,
+ DEL,
+ TYPE,
+ FLUSHDB,
+ KEYS,
+ RANDOMKEY,
+ RENAME,
+ RENAMENX,
+ RENAMEX,
+ DBSIZE,
+ EXPIRE,
+ EXPIREAT,
+ TTL,
+ SELECT,
+ MOVE,
+ FLUSHALL,
+ GETSET,
+ MGET,
+ SETNX,
+ SETEX,
+ MSET,
+ MSETNX,
+ DECRBY,
+ DECR,
+ INCRBY,
+ INCR,
+ APPEND,
+ SUBSTR,
+ HSET,
+ HGET,
+ HSETNX,
+ HMSET,
+ HMGET,
+ HINCRBY,
+ HEXISTS,
+ HDEL,
+ HLEN,
+ HKEYS,
+ HVALS,
+ HGETALL,
+ RPUSH,
+ LPUSH,
+ LLEN,
+ LRANGE,
+ LTRIM,
+ LINDEX,
+ LSET,
+ LREM,
+ LPOP,
+ RPOP,
+ RPOPLPUSH,
+ SADD,
+ SMEMBERS,
+ SREM,
+ SPOP,
+ SMOVE,
+ SCARD,
+ SISMEMBER,
+ SINTER,
+ SINTERSTORE,
+ SUNION,
+ SUNIONSTORE,
+ SDIFF,
+ SDIFFSTORE,
+ SRANDMEMBER,
+ ZADD,
+ ZRANGE,
+ ZREM,
+ ZINCRBY,
+ ZRANK,
+ ZREVRANK,
+ ZREVRANGE,
+ ZCARD,
+ ZSCORE,
+ MULTI,
+ DISCARD,
+ EXEC,
+ WATCH,
+ UNWATCH,
+ SORT,
+ BLPOP,
+ BRPOP,
+ AUTH,
+ SUBSCRIBE,
+ PUBLISH,
+ UNSUBSCRIBE,
+ PSUBSCRIBE,
+ PUNSUBSCRIBE,
+ ZCOUNT,
+ ZRANGEBYSCORE,
+ ZREVRANGEBYSCORE,
+ ZREMRANGEBYRANK,
+ ZREMRANGEBYSCORE,
+ ZUNIONSTORE,
+ ZINTERSTORE,
+ SAVE,
+ BGSAVE,
+ BGREWRITEAOF,
+ LASTSAVE,
+ SHUTDOWN,
+ INFO,
+ MONITOR,
+ SLAVEOF,
+ CONFIG,
+ STRLEN,
+ SYNC,
+ LPUSHX,
+ PERSIST,
+ RPUSHX,
+ ECHO,
+ LINSERT,
+ DEBUG,
+ BRPOPLPUSH,
+ SETBIT,
+ GETBIT,
+ SETRANGE,
+ GETRANGE,
+ PEXPIRE,
+ PEXPIREAT,
+ GEOADD,
+ GEODIST,
+ GEOHASH,
+ GEOPOS,
+ GEORADIUS,
+ GEORADIUSBYMEMBER;
}
/**
* The spring-redis component allows sending and receiving messages from
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/RestEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/RestEndpointBuilderFactory.java
index 7227482..db932ac 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/RestEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/RestEndpointBuilderFactory.java
@@ -672,10 +672,10 @@ public interface RestEndpointBuilderFactory {
*/
enum RestBindingMode {
auto,
-off,
-json,
-xml,
-json_xml;
+ off,
+ json,
+ xml,
+ json_xml;
}
/**
* The rest component is used for either hosting REST services (consumer) or
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/S3EndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/S3EndpointBuilderFactory.java
index 4bbb525..5718e9b 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/S3EndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/S3EndpointBuilderFactory.java
@@ -1893,12 +1893,12 @@ public interface S3EndpointBuilderFactory {
*/
enum S3Operations {
copyObject,
-listObjects,
-deleteObject,
-deleteBucket,
-listBuckets,
-downloadLink,
-getObject;
+ listObjects,
+ deleteObject,
+ deleteBucket,
+ listBuckets,
+ downloadLink,
+ getObject;
}
/**
* The aws-s3 component is used for storing and retrieving objecct from
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SagaEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SagaEndpointBuilderFactory.java
index 093b8a3..4aee2db 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SagaEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SagaEndpointBuilderFactory.java
@@ -119,7 +119,7 @@ public interface SagaEndpointBuilderFactory {
*/
enum SagaEndpointAction {
COMPLETE,
-COMPENSATE;
+ COMPENSATE;
}
/**
* The saga component provides access to advanced options for managing the
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SalesforceEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SalesforceEndpointBuilderFactory.java
index b15d811..8806da1 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SalesforceEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SalesforceEndpointBuilderFactory.java
@@ -2321,48 +2321,48 @@ public interface SalesforceEndpointBuilderFactory {
*/
enum OperationName {
GET_VERSIONS,
-GET_RESOURCES,
-GET_GLOBAL_OBJECTS,
-GET_BASIC_INFO,
-GET_DESCRIPTION,
-GET_SOBJECT,
-CREATE_SOBJECT,
-UPDATE_SOBJECT,
-DELETE_SOBJECT,
-GET_SOBJECT_WITH_ID,
-UPSERT_SOBJECT,
-DELETE_SOBJECT_WITH_ID,
-GET_BLOB_FIELD,
-QUERY,
-QUERY_MORE,
-QUERY_ALL,
-SEARCH,
-APEX_CALL,
-RECENT,
-CREATE_JOB,
-GET_JOB,
-CLOSE_JOB,
-ABORT_JOB,
-CREATE_BATCH,
-GET_BATCH,
-GET_ALL_BATCHES,
-GET_REQUEST,
-GET_RESULTS,
-CREATE_BATCH_QUERY,
-GET_QUERY_RESULT_IDS,
-GET_QUERY_RESULT,
-GET_RECENT_REPORTS,
-GET_REPORT_DESCRIPTION,
-EXECUTE_SYNCREPORT,
-EXECUTE_ASYNCREPORT,
-GET_REPORT_INSTANCES,
-GET_REPORT_RESULTS,
-LIMITS,
-APPROVAL,
-APPROVALS,
-COMPOSITE_TREE,
-COMPOSITE_BATCH,
-COMPOSITE;
+ GET_RESOURCES,
+ GET_GLOBAL_OBJECTS,
+ GET_BASIC_INFO,
+ GET_DESCRIPTION,
+ GET_SOBJECT,
+ CREATE_SOBJECT,
+ UPDATE_SOBJECT,
+ DELETE_SOBJECT,
+ GET_SOBJECT_WITH_ID,
+ UPSERT_SOBJECT,
+ DELETE_SOBJECT_WITH_ID,
+ GET_BLOB_FIELD,
+ QUERY,
+ QUERY_MORE,
+ QUERY_ALL,
+ SEARCH,
+ APEX_CALL,
+ RECENT,
+ CREATE_JOB,
+ GET_JOB,
+ CLOSE_JOB,
+ ABORT_JOB,
+ CREATE_BATCH,
+ GET_BATCH,
+ GET_ALL_BATCHES,
+ GET_REQUEST,
+ GET_RESULTS,
+ CREATE_BATCH_QUERY,
+ GET_QUERY_RESULT_IDS,
+ GET_QUERY_RESULT,
+ GET_RECENT_REPORTS,
+ GET_REPORT_DESCRIPTION,
+ EXECUTE_SYNCREPORT,
+ EXECUTE_ASYNCREPORT,
+ GET_REPORT_INSTANCES,
+ GET_REPORT_RESULTS,
+ LIMITS,
+ APPROVAL,
+ APPROVALS,
+ COMPOSITE_TREE,
+ COMPOSITE_BATCH,
+ COMPOSITE;
}
/**
@@ -2371,11 +2371,11 @@ COMPOSITE;
*/
enum ContentType {
XML,
-CSV,
-JSON,
-ZIP_XML,
-ZIP_CSV,
-ZIP_JSON;
+ CSV,
+ JSON,
+ ZIP_XML,
+ ZIP_CSV,
+ ZIP_JSON;
}
/**
@@ -2385,7 +2385,7 @@ ZIP_JSON;
*/
enum PayloadFormat {
JSON,
-XML;
+ XML;
}
/**
@@ -2395,7 +2395,7 @@ XML;
*/
enum NotFoundBehaviour {
EXCEPTION,
-NULL;
+ NULL;
}
/**
@@ -2404,9 +2404,9 @@ NULL;
*/
enum NotifyForFieldsEnum {
ALL,
-REFERENCED,
-SELECT,
-WHERE;
+ REFERENCED,
+ SELECT,
+ WHERE;
}
/**
@@ -2415,9 +2415,9 @@ WHERE;
*/
enum NotifyForOperationsEnum {
ALL,
-CREATE,
-EXTENDED,
-UPDATE;
+ CREATE,
+ EXTENDED,
+ UPDATE;
}
/**
* The salesforce component is used for integrating Camel with the massive
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SdbEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SdbEndpointBuilderFactory.java
index b1bb5548..2b77d6c 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SdbEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SdbEndpointBuilderFactory.java
@@ -244,14 +244,14 @@ public interface SdbEndpointBuilderFactory {
*/
enum SdbOperations {
BatchDeleteAttributes,
-BatchPutAttributes,
-DeleteAttributes,
-DeleteDomain,
-DomainMetadata,
-GetAttributes,
-ListDomains,
-PutAttributes,
-Select;
+ BatchPutAttributes,
+ DeleteAttributes,
+ DeleteDomain,
+ DomainMetadata,
+ GetAttributes,
+ ListDomains,
+ PutAttributes,
+ Select;
}
/**
* The aws-sdb component is for storing and retrieving data from/to Amazon's
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ServerEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ServerEndpointBuilderFactory.java
index 02e6a32..f81aa7e 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ServerEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ServerEndpointBuilderFactory.java
@@ -1353,7 +1353,7 @@ public interface ServerEndpointBuilderFactory {
*/
enum ASDUAddressType {
SIZE_1,
-SIZE_2;
+ SIZE_2;
}
/**
@@ -1362,7 +1362,7 @@ SIZE_2;
*/
enum CauseOfTransmissionType {
SIZE_1,
-SIZE_2;
+ SIZE_2;
}
/**
@@ -1371,8 +1371,8 @@ SIZE_2;
*/
enum InformationObjectAddressType {
SIZE_1,
-SIZE_2,
-SIZE_3;
+ SIZE_2,
+ SIZE_3;
}
/**
* IEC 60870 component used for telecontrol (supervisory control and data
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ServiceNowEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ServiceNowEndpointBuilderFactory.java
index 3510c2c..120d868 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ServiceNowEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ServiceNowEndpointBuilderFactory.java
@@ -836,8 +836,8 @@ public interface ServiceNowEndpointBuilderFactory {
*/
enum ServiceNowRelease {
FUJI,
-GENEVA,
-HELSINKI;
+ GENEVA,
+ HELSINKI;
}
/**
* The servicenow component is used to integrate Camel with ServiceNow cloud
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SftpEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SftpEndpointBuilderFactory.java
index a4d08df..ee9b0f7 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SftpEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SftpEndpointBuilderFactory.java
@@ -4527,8 +4527,8 @@ public interface SftpEndpointBuilderFactory {
*/
enum PathSeparator {
UNIX,
-Windows,
-Auto;
+ Windows,
+ Auto;
}
/**
@@ -4537,11 +4537,11 @@ Auto;
*/
enum GenericFileExist {
Override,
-Append,
-Fail,
-Ignore,
-Move,
-TryRename;
+ Append,
+ Fail,
+ Ignore,
+ Move,
+ TryRename;
}
/**
* The sftp (FTP over SSH) component is used for uploading or downloading
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/Sjms2EndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/Sjms2EndpointBuilderFactory.java
index 3aa1099..65db416 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/Sjms2EndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/Sjms2EndpointBuilderFactory.java
@@ -1852,9 +1852,9 @@ public interface Sjms2EndpointBuilderFactory {
*/
enum SessionAcknowledgementType {
AUTO_ACKNOWLEDGE,
-CLIENT_ACKNOWLEDGE,
-DUPS_OK_ACKNOWLEDGE,
-SESSION_TRANSACTED;
+ CLIENT_ACKNOWLEDGE,
+ DUPS_OK_ACKNOWLEDGE,
+ SESSION_TRANSACTED;
}
/**
* The sjms2 component (simple jms) allows messages to be sent to (or
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SjmsEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SjmsEndpointBuilderFactory.java
index 6b06e91..2b55b26 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SjmsEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SjmsEndpointBuilderFactory.java
@@ -1806,9 +1806,9 @@ public interface SjmsEndpointBuilderFactory {
*/
enum SessionAcknowledgementType {
AUTO_ACKNOWLEDGE,
-CLIENT_ACKNOWLEDGE,
-DUPS_OK_ACKNOWLEDGE,
-SESSION_TRANSACTED;
+ CLIENT_ACKNOWLEDGE,
+ DUPS_OK_ACKNOWLEDGE,
+ SESSION_TRANSACTED;
}
/**
* The sjms component (simple jms) allows messages to be sent to (or
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SmppEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SmppEndpointBuilderFactory.java
index df9908f..8c38502 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SmppEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SmppEndpointBuilderFactory.java
@@ -1835,8 +1835,8 @@ public interface SmppEndpointBuilderFactory {
*/
enum SmppSplittingPolicy {
ALLOW,
-REJECT,
-TRUNCATE;
+ REJECT,
+ TRUNCATE;
}
/**
* To send and receive SMS using a SMSC (Short Message Service Center).
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SnmpEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SnmpEndpointBuilderFactory.java
index aed8e2f..228437d 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SnmpEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SnmpEndpointBuilderFactory.java
@@ -362,8 +362,8 @@ public interface SnmpEndpointBuilderFactory {
*/
enum SnmpActionType {
TRAP,
-POLL,
-GET_NEXT;
+ POLL,
+ GET_NEXT;
}
/**
* The snmp component gives you the ability to poll SNMP capable devices or
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SoroushBotEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SoroushBotEndpointBuilderFactory.java
index 7671f1b..4b8e48f 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SoroushBotEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SoroushBotEndpointBuilderFactory.java
@@ -1425,9 +1425,9 @@ public interface SoroushBotEndpointBuilderFactory {
*/
enum Endpoint {
sendMessage,
-getMessage,
-uploadFile,
-downloadFile;
+ getMessage,
+ uploadFile,
+ downloadFile;
}
/**
* To integrate with the Soroush chat bot. Creates a builder to build
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SplunkEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SplunkEndpointBuilderFactory.java
index 427177e..a31bfca 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SplunkEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SplunkEndpointBuilderFactory.java
@@ -1295,9 +1295,9 @@ public interface SplunkEndpointBuilderFactory {
*/
enum SSLSecurityProtocol {
TLSv1_2,
-TLSv1_1,
-TLSv1,
-SSLv3;
+ TLSv1_1,
+ TLSv1,
+ SSLv3;
}
/**
* The splunk component allows to publish or search for events in Splunk.
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SpringLdapEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SpringLdapEndpointBuilderFactory.java
index 487b357..319615c 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SpringLdapEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SpringLdapEndpointBuilderFactory.java
@@ -142,11 +142,11 @@ public interface SpringLdapEndpointBuilderFactory {
*/
enum LdapOperation {
SEARCH,
-BIND,
-UNBIND,
-AUTHENTICATE,
-MODIFY_ATTRIBUTES,
-FUNCTION_DRIVEN;
+ BIND,
+ UNBIND,
+ AUTHENTICATE,
+ MODIFY_ATTRIBUTES,
+ FUNCTION_DRIVEN;
}
/**
* The spring-ldap component allows you to perform searches in LDAP servers
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SpringWebserviceEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SpringWebserviceEndpointBuilderFactory.java
index c1ed660..ef5dfd4 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SpringWebserviceEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SpringWebserviceEndpointBuilderFactory.java
@@ -950,13 +950,13 @@ public interface SpringWebserviceEndpointBuilderFactory {
*/
enum EndpointMappingType {
ROOT_QNAME,
-ACTION,
-TO,
-SOAP_ACTION,
-XPATHRESULT,
-URI,
-URI_PATH,
-BEANNAME;
+ ACTION,
+ TO,
+ SOAP_ACTION,
+ XPATHRESULT,
+ URI,
+ URI_PATH,
+ BEANNAME;
}
/**
* The spring-ws component is used for SOAP WebServices using Spring
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SqlEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SqlEndpointBuilderFactory.java
index b9209f0..9998abd 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SqlEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SqlEndpointBuilderFactory.java
@@ -1797,8 +1797,8 @@ public interface SqlEndpointBuilderFactory {
*/
enum SqlOutputType {
SelectOne,
-SelectList,
-StreamList;
+ SelectList,
+ StreamList;
}
/**
* The sql component allows you to work with databases using JDBC SQL
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SqsEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SqsEndpointBuilderFactory.java
index 14c7b40..144ceae 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SqsEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/SqsEndpointBuilderFactory.java
@@ -1882,8 +1882,8 @@ public interface SqsEndpointBuilderFactory {
*/
enum SqsOperations {
sendBatchMessage,
-deleteMessage,
-listQueues;
+ deleteMessage,
+ listQueues;
}
/**
* The aws-sqs component is used for sending and receiving messages to
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ThriftEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ThriftEndpointBuilderFactory.java
index 97909c0..6a18f23 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ThriftEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/ThriftEndpointBuilderFactory.java
@@ -806,7 +806,7 @@ public interface ThriftEndpointBuilderFactory {
*/
enum ThriftCompressionType {
NONE,
-ZLIB;
+ ZLIB;
}
/**
@@ -816,9 +816,9 @@ ZLIB;
*/
enum ThriftExchangeProtocol {
BINARY,
-JSON,
-SJSON,
-COMPACT;
+ JSON,
+ SJSON,
+ COMPACT;
}
/**
@@ -828,8 +828,8 @@ COMPACT;
*/
enum ThriftNegotiationType {
PLAINTEXT,
-SSL,
-SASL;
+ SSL,
+ SASL;
}
/**
* The Thrift component allows to call and expose remote procedures (RPC)
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TikaEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TikaEndpointBuilderFactory.java
index ecdbdb8..6016ca0 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TikaEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TikaEndpointBuilderFactory.java
@@ -188,7 +188,7 @@ public interface TikaEndpointBuilderFactory {
*/
enum TikaOperation {
parse,
-detect;
+ detect;
}
/**
@@ -197,9 +197,9 @@ detect;
*/
enum TikaParseOutputFormat {
xml,
-html,
-text,
-textMain;
+ html,
+ text,
+ textMain;
}
/**
* This component integrates with Apache Tika to extract content and
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TwilioEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TwilioEndpointBuilderFactory.java
index 0a3ba94..115a739 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TwilioEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TwilioEndpointBuilderFactory.java
@@ -473,61 +473,61 @@ public interface TwilioEndpointBuilderFactory {
*/
enum TwilioApiName {
ACCOUNT,
-ADDRESS,
-APPLICATION,
-AVAILABLE_PHONE_NUMBER_COUNTRY,
-CALL,
-CONFERENCE,
-CONNECT_APP,
-INCOMING_PHONE_NUMBER,
-KEY,
-MESSAGE,
-NEW_KEY,
-NEW_SIGNING_KEY,
-NOTIFICATION,
-OUTGOING_CALLER_ID,
-QUEUE,
-RECORDING,
-SHORT_CODE,
-SIGNING_KEY,
-TOKEN,
-TRANSCRIPTION,
-VALIDATION_REQUEST,
-ADDRESS_DEPENDENT_PHONE_NUMBER,
-AVAILABLE_PHONE_NUMBER_COUNTRY_LOCAL,
-AVAILABLE_PHONE_NUMBER_COUNTRY_MOBILE,
-AVAILABLE_PHONE_NUMBER_COUNTRY_TOLL_FREE,
-CALL_FEEDBACK,
-CALL_FEEDBACK_SUMMARY,
-CALL_NOTIFICATION,
-CALL_RECORDING,
-CONFERENCE_PARTICIPANT,
-INCOMING_PHONE_NUMBER_LOCAL,
-INCOMING_PHONE_NUMBER_MOBILE,
-INCOMING_PHONE_NUMBER_TOLL_FREE,
-MESSAGE_FEEDBACK,
-MESSAGE_MEDIA,
-QUEUE_MEMBER,
-RECORDING_ADD_ON_RESULT,
-RECORDING_TRANSCRIPTION,
-RECORDING_ADD_ON_RESULT_PAYLOAD,
-SIP_CREDENTIAL_LIST,
-SIP_DOMAIN,
-SIP_IP_ACCESS_CONTROL_LIST,
-SIP_CREDENTIAL_LIST_CREDENTIAL,
-SIP_DOMAIN_CREDENTIAL_LIST_MAPPING,
-SIP_DOMAIN_IP_ACCESS_CONTROL_LIST_MAPPING,
-SIP_IP_ACCESS_CONTROL_LIST_IP_ADDRESS,
-USAGE_RECORD,
-USAGE_TRIGGER,
-USAGE_RECORD_ALL_TIME,
-USAGE_RECORD_DAILY,
-USAGE_RECORD_LAST_MONTH,
-USAGE_RECORD_MONTHLY,
-USAGE_RECORD_THIS_MONTH,
-USAGE_RECORD_TODAY,
-USAGE_RECORD_YEARLY,
-USAGE_RECORD_YESTERDAY;
+ ADDRESS,
+ APPLICATION,
+ AVAILABLE_PHONE_NUMBER_COUNTRY,
+ CALL,
+ CONFERENCE,
+ CONNECT_APP,
+ INCOMING_PHONE_NUMBER,
+ KEY,
+ MESSAGE,
+ NEW_KEY,
+ NEW_SIGNING_KEY,
+ NOTIFICATION,
+ OUTGOING_CALLER_ID,
+ QUEUE,
+ RECORDING,
+ SHORT_CODE,
+ SIGNING_KEY,
+ TOKEN,
+ TRANSCRIPTION,
+ VALIDATION_REQUEST,
+ ADDRESS_DEPENDENT_PHONE_NUMBER,
+ AVAILABLE_PHONE_NUMBER_COUNTRY_LOCAL,
+ AVAILABLE_PHONE_NUMBER_COUNTRY_MOBILE,
+ AVAILABLE_PHONE_NUMBER_COUNTRY_TOLL_FREE,
+ CALL_FEEDBACK,
+ CALL_FEEDBACK_SUMMARY,
+ CALL_NOTIFICATION,
+ CALL_RECORDING,
+ CONFERENCE_PARTICIPANT,
+ INCOMING_PHONE_NUMBER_LOCAL,
+ INCOMING_PHONE_NUMBER_MOBILE,
+ INCOMING_PHONE_NUMBER_TOLL_FREE,
+ MESSAGE_FEEDBACK,
+ MESSAGE_MEDIA,
+ QUEUE_MEMBER,
+ RECORDING_ADD_ON_RESULT,
+ RECORDING_TRANSCRIPTION,
+ RECORDING_ADD_ON_RESULT_PAYLOAD,
+ SIP_CREDENTIAL_LIST,
+ SIP_DOMAIN,
+ SIP_IP_ACCESS_CONTROL_LIST,
+ SIP_CREDENTIAL_LIST_CREDENTIAL,
+ SIP_DOMAIN_CREDENTIAL_LIST_MAPPING,
+ SIP_DOMAIN_IP_ACCESS_CONTROL_LIST_MAPPING,
+ SIP_IP_ACCESS_CONTROL_LIST_IP_ADDRESS,
+ USAGE_RECORD,
+ USAGE_TRIGGER,
+ USAGE_RECORD_ALL_TIME,
+ USAGE_RECORD_DAILY,
+ USAGE_RECORD_LAST_MONTH,
+ USAGE_RECORD_MONTHLY,
+ USAGE_RECORD_THIS_MONTH,
+ USAGE_RECORD_TODAY,
+ USAGE_RECORD_YEARLY,
+ USAGE_RECORD_YESTERDAY;
}
/**
* The Twilio component allows you to interact with the Twilio REST APIs
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TwitterDirectMessageEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TwitterDirectMessageEndpointBuilderFactory.java
index 83a264a..e919548 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TwitterDirectMessageEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TwitterDirectMessageEndpointBuilderFactory.java
@@ -1328,8 +1328,8 @@ public interface TwitterDirectMessageEndpointBuilderFactory {
*/
enum EndpointType {
POLLING,
-DIRECT,
-EVENT;
+ DIRECT,
+ EVENT;
}
/**
* The Twitter Direct Message Component consumes/produces user's direct
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TwitterSearchEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TwitterSearchEndpointBuilderFactory.java
index 10472de..08aef69 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TwitterSearchEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TwitterSearchEndpointBuilderFactory.java
@@ -1308,8 +1308,8 @@ public interface TwitterSearchEndpointBuilderFactory {
*/
enum EndpointType {
POLLING,
-DIRECT,
-EVENT;
+ DIRECT,
+ EVENT;
}
/**
* The Twitter Search component consumes search results. Creates a builder
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TwitterStreamingEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TwitterStreamingEndpointBuilderFactory.java
index 19d98df..b85d416 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TwitterStreamingEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TwitterStreamingEndpointBuilderFactory.java
@@ -225,9 +225,9 @@ public interface TwitterStreamingEndpointBuilderFactory {
*/
enum StreamingType {
SAMPLE,
-FILTER,
-USER,
-UNKNOWN;
+ FILTER,
+ USER,
+ UNKNOWN;
}
/**
@@ -236,8 +236,8 @@ UNKNOWN;
*/
enum EndpointType {
POLLING,
-DIRECT,
-EVENT;
+ DIRECT,
+ EVENT;
}
/**
* The Twitter Streaming component consumes twitter statuses using Streaming
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TwitterTimelineEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TwitterTimelineEndpointBuilderFactory.java
index 1e5ee4a..413e7ac 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TwitterTimelineEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/TwitterTimelineEndpointBuilderFactory.java
@@ -1387,11 +1387,11 @@ public interface TwitterTimelineEndpointBuilderFactory {
*/
enum TimelineType {
PUBLIC,
-HOME,
-USER,
-MENTIONS,
-RETWEETSOFME,
-UNKNOWN;
+ HOME,
+ USER,
+ MENTIONS,
+ RETWEETSOFME,
+ UNKNOWN;
}
/**
@@ -1400,8 +1400,8 @@ UNKNOWN;
*/
enum EndpointType {
POLLING,
-DIRECT,
-EVENT;
+ DIRECT,
+ EVENT;
}
/**
* The Twitter Timeline component consumes twitter timeline or update the
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/WeatherEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/WeatherEndpointBuilderFactory.java
index abab9c7..547b2aa 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/WeatherEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/WeatherEndpointBuilderFactory.java
@@ -1819,28 +1819,28 @@ public interface WeatherEndpointBuilderFactory {
*/
enum WeatherLanguage {
en,
-ru,
-it,
-es,
-sp,
-uk,
-ua,
-de,
-pt,
-ro,
-pl,
-fi,
-nl,
-fr,
-bg,
-sv,
-se,
-zh_tw,
-zh,
-zh_cn,
-tr,
-hr,
-ca;
+ ru,
+ it,
+ es,
+ sp,
+ uk,
+ ua,
+ de,
+ pt,
+ ro,
+ pl,
+ fi,
+ nl,
+ fr,
+ bg,
+ sv,
+ se,
+ zh_tw,
+ zh,
+ zh_cn,
+ tr,
+ hr,
+ ca;
}
/**
@@ -1849,8 +1849,8 @@ ca;
*/
enum WeatherMode {
HTML,
-JSON,
-XML;
+ JSON,
+ XML;
}
/**
@@ -1859,7 +1859,7 @@ XML;
*/
enum WeatherUnits {
IMPERIAL,
-METRIC;
+ METRIC;
}
/**
@@ -1868,9 +1868,9 @@ METRIC;
*/
enum WeatherApi {
Current,
-Station,
-Hourly,
-Daily;
+ Station,
+ Hourly,
+ Daily;
}
/**
* Polls the weather information from Open Weather Map. Creates a builder to
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/XChangeEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/XChangeEndpointBuilderFactory.java
index 33e0700..67119dc 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/XChangeEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/XChangeEndpointBuilderFactory.java
@@ -188,13 +188,13 @@ public interface XChangeEndpointBuilderFactory {
*/
enum XChangeMethod {
balances,
-fundingHistory,
-wallets,
-currencies,
-currencyMetaData,
-currencyPairs,
-currencyPairMetaData,
-ticker;
+ fundingHistory,
+ wallets,
+ currencies,
+ currencyMetaData,
+ currencyPairs,
+ currencyPairMetaData,
+ ticker;
}
/**
@@ -203,8 +203,8 @@ ticker;
*/
enum XChangeService {
marketdata,
-metadata,
-account;
+ metadata,
+ account;
}
/**
* The camel-xchange component provide access to many bitcoin and altcoin
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/XQueryEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/XQueryEndpointBuilderFactory.java
index 5fb8af2..b27d523 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/XQueryEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/XQueryEndpointBuilderFactory.java
@@ -1462,12 +1462,12 @@ public interface XQueryEndpointBuilderFactory {
*/
enum ResultFormat {
Bytes,
-BytesSource,
-DOM,
-DOMSource,
-List,
-String,
-StringSource;
+ BytesSource,
+ DOM,
+ DOMSource,
+ List,
+ String,
+ StringSource;
}
/**
* Transforms the message using a XQuery template using Saxon. Creates a
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/XmlSignatureEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/XmlSignatureEndpointBuilderFactory.java
index 7bd3258..f760533 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/XmlSignatureEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/XmlSignatureEndpointBuilderFactory.java
@@ -927,7 +927,7 @@ public interface XmlSignatureEndpointBuilderFactory {
*/
enum XmlCommand {
sign,
-verify;
+ verify;
}
/**
* Used to sign and verify exchanges using the XML signature specification.
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/XsltEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/XsltEndpointBuilderFactory.java
index 9e097b9..52f4261 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/XsltEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/XsltEndpointBuilderFactory.java
@@ -452,9 +452,9 @@ public interface XsltEndpointBuilderFactory {
*/
enum XsltOutput {
string,
-bytes,
-DOM,
-file;
+ bytes,
+ DOM,
+ file;
}
/**
* Transforms the message using a XSLT template. Creates a builder to build
diff --git a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/YammerEndpointBuilderFactory.java b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/YammerEndpointBuilderFactory.java
index 0877b8f..184a40b 100644
--- a/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/YammerEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/main/java/org/apache/camel/builder/endpoint/dsl/YammerEndpointBuilderFactory.java
@@ -1009,14 +1009,14 @@ public interface YammerEndpointBuilderFactory {
*/
enum YammerFunctionType {
MESSAGES,
-MY_FEED,
-ALGO,
-FOLLOWING,
-SENT,
-PRIVATE,
-RECEIVED,
-USERS,
-CURRENT;
+ MY_FEED,
+ ALGO,
+ FOLLOWING,
+ SENT,
+ PRIVATE,
+ RECEIVED,
+ USERS,
+ CURRENT;
}
/**
* The yammer component allows you to interact with the Yammer enterprise
diff --git a/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/srcgen/JavaClass.java b/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/srcgen/JavaClass.java
index ef72d53..d18ca62 100644
--- a/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/srcgen/JavaClass.java
+++ b/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/srcgen/JavaClass.java
@@ -266,7 +266,7 @@ public class JavaClass {
.append("enum ").append(name).append(" {\n")
.append(indent)
.append(" ")
- .append(Strings.join(values, ",\n"))
+ .append(Strings.join(values, ",\n" + indent + " "))
.append(";\n")
.append(indent)
.append("}");
[camel] 01/05: Use a dedicated method to cast
Posted by gn...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
gnodet pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 5c086e3753bfcffdd36e4c63e3d361ca5b43b616
Author: Guillaume Nodet <gn...@gmail.com>
AuthorDate: Fri Jun 14 10:37:24 2019 +0200
Use a dedicated method to cast
---
.../apache/camel/model/ProcessorDefinition.java | 218 ++++++++-------------
1 file changed, 80 insertions(+), 138 deletions(-)
diff --git a/core/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java b/core/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
index d9e0f54..7ee70d0 100644
--- a/core/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
+++ b/core/camel-core/src/main/java/org/apache/camel/model/ProcessorDefinition.java
@@ -230,13 +230,12 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param value the value
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type attribute(QName name, Object value) {
if (otherAttributes == null) {
otherAttributes = new HashMap<>();
}
otherAttributes.put(name, value);
- return (Type) this;
+ return asType();
}
/**
@@ -245,10 +244,9 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param uri the endpoint to send to
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type to(@AsEndpointUri String uri) {
addOutput(new ToDefinition(uri));
- return (Type) this;
+ return asType();
}
/**
@@ -257,12 +255,11 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param uri the dynamic endpoint to send to (resolved using simple language by default)
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type toD(@AsEndpointUri String uri) {
ToDynamicDefinition answer = new ToDynamicDefinition();
answer.setUri(uri);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -273,13 +270,12 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
*
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type toD(@AsEndpointUri String uri, int cacheSize) {
ToDynamicDefinition answer = new ToDynamicDefinition();
answer.setUri(uri);
answer.setCacheSize(cacheSize);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -289,13 +285,12 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param ignoreInvalidEndpoint ignore the invalidate endpoint exception when try to create a producer with that endpoint
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type toD(@AsEndpointUri String uri, boolean ignoreInvalidEndpoint) {
ToDynamicDefinition answer = new ToDynamicDefinition();
answer.setUri(uri);
answer.setIgnoreInvalidEndpoint(ignoreInvalidEndpoint);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -305,10 +300,9 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param args arguments for the string formatting of the uri
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type toF(@AsEndpointUri String uri, Object... args) {
addOutput(new ToDefinition(String.format(uri, args)));
- return (Type) this;
+ return asType();
}
/**
@@ -328,12 +322,11 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param name the service name
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type serviceCall(String name) {
ServiceCallDefinition answer = new ServiceCallDefinition();
answer.setName(name);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -343,13 +336,12 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param uri the endpoint uri to use for calling the service
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type serviceCall(String name, @AsEndpointUri String uri) {
ServiceCallDefinition answer = new ServiceCallDefinition();
answer.setName(name);
answer.setUri(uri);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -358,16 +350,14 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param endpoint the endpoint to send to
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type to(Endpoint endpoint) {
addOutput(new ToDefinition(endpoint));
- return (Type) this;
+ return asType();
}
- @SuppressWarnings("unchecked")
public Type to(EndpointProducerBuilder endpoint) {
addOutput(new ToDefinition(endpoint));
- return (Type) this;
+ return asType();
}
/**
@@ -379,10 +369,9 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param uri the endpoint to send to
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type to(ExchangePattern pattern, @AsEndpointUri String uri) {
addOutput(new ToDefinition(uri, pattern));
- return (Type) this;
+ return asType();
}
/**
@@ -394,10 +383,9 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param endpoint the endpoint to send to
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type to(ExchangePattern pattern, Endpoint endpoint) {
addOutput(new ToDefinition(endpoint, pattern));
- return (Type) this;
+ return asType();
}
/**
@@ -406,12 +394,11 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param uris list of endpoints to send to
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type to(@AsEndpointUri String... uris) {
for (String uri : uris) {
addOutput(new ToDefinition(uri));
}
- return (Type) this;
+ return asType();
}
/**
@@ -420,12 +407,11 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param endpoints list of endpoints to send to
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type to(Endpoint... endpoints) {
for (Endpoint endpoint : endpoints) {
addOutput(new ToDefinition(endpoint));
}
- return (Type) this;
+ return asType();
}
/**
@@ -434,12 +420,11 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param endpoints list of endpoints to send to
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type to(Iterable<Endpoint> endpoints) {
for (Endpoint endpoint : endpoints) {
addOutput(new ToDefinition(endpoint));
}
- return (Type) this;
+ return asType();
}
/**
@@ -451,12 +436,11 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param uris list of endpoints to send to
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type to(ExchangePattern pattern, @AsEndpointUri String... uris) {
for (String uri : uris) {
addOutput(new ToDefinition(uri, pattern));
}
- return (Type) this;
+ return asType();
}
/**
@@ -468,12 +452,11 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param endpoints list of endpoints to send to
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type to(ExchangePattern pattern, Endpoint... endpoints) {
for (Endpoint endpoint : endpoints) {
addOutput(new ToDefinition(endpoint, pattern));
}
- return (Type) this;
+ return asType();
}
/**
@@ -483,12 +466,11 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param endpoints list of endpoints to send to
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type to(ExchangePattern pattern, Iterable<Endpoint> endpoints) {
for (Endpoint endpoint : endpoints) {
addOutput(new ToDefinition(endpoint, pattern));
}
- return (Type) this;
+ return asType();
}
/**
@@ -500,10 +482,9 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param exchangePattern instance of {@link ExchangePattern}
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type setExchangePattern(ExchangePattern exchangePattern) {
addOutput(new SetExchangePatternDefinition(exchangePattern));
- return (Type) this;
+ return asType();
}
/**
@@ -655,7 +636,6 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param id the id
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type id(String id) {
if (isOutputSupported() && getOutputs().isEmpty()) {
// set id on this
@@ -682,7 +662,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
}
}
- return (Type) this;
+ return asType();
}
/**
@@ -695,7 +675,6 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param id the route id, should be unique
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type routeId(String id) {
ProcessorDefinition<?> def = this;
@@ -707,7 +686,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
route.setId(id);
}
- return (Type) this;
+ return asType();
}
/**
@@ -716,7 +695,6 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param group the route group
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type routeGroup(String group) {
ProcessorDefinition<?> def = this;
@@ -725,7 +703,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
route.setGroup(group);
}
- return (Type) this;
+ return asType();
}
/**
@@ -734,7 +712,6 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param description the route description
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type routeDescription(String description) {
ProcessorDefinition<?> def = this;
@@ -745,7 +722,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
route.setDescription(desc);
}
- return (Type) this;
+ return asType();
}
/**
@@ -848,7 +825,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
PipelineDefinition answer = new PipelineDefinition();
addOutput(answer);
answer.to(uris);
- return (Type) this;
+ return asType();
}
/**
@@ -864,7 +841,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
PipelineDefinition answer = new PipelineDefinition();
addOutput(answer);
answer.to(endpoints);
- return (Type) this;
+ return asType();
}
/**
@@ -880,7 +857,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
PipelineDefinition answer = new PipelineDefinition();
addOutput(answer);
answer.to(endpoints);
- return (Type) this;
+ return asType();
}
/**
@@ -1251,11 +1228,10 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param message the log message, (you can use {@link org.apache.camel.language.simple.SimpleLanguage} syntax)
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type log(String message) {
LogDefinition answer = new LogDefinition(message);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -1265,12 +1241,11 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param message the log message, (you can use {@link org.apache.camel.language.simple.SimpleLanguage} syntax)
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type log(LoggingLevel loggingLevel, String message) {
LogDefinition answer = new LogDefinition(message);
answer.setLoggingLevel(loggingLevel);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -1281,13 +1256,12 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param message the log message, (you can use {@link org.apache.camel.language.simple.SimpleLanguage} syntax)
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type log(LoggingLevel loggingLevel, String logName, String message) {
LogDefinition answer = new LogDefinition(message);
answer.setLoggingLevel(loggingLevel);
answer.setLogName(logName);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -1298,13 +1272,12 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param message the log message, (you can use {@link org.apache.camel.language.simple.SimpleLanguage} syntax)
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type log(LoggingLevel loggingLevel, Logger logger, String message) {
LogDefinition answer = new LogDefinition(message);
answer.setLoggingLevel(loggingLevel);
answer.setLogger(logger);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -1317,14 +1290,13 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param message the log message, (you can use {@link org.apache.camel.language.simple.SimpleLanguage} syntax)
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type log(LoggingLevel loggingLevel, String logName, String marker, String message) {
LogDefinition answer = new LogDefinition(message);
answer.setLoggingLevel(loggingLevel);
answer.setLogName(logName);
answer.setMarker(marker);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -1337,14 +1309,13 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param message the log message, (you can use {@link org.apache.camel.language.simple.SimpleLanguage} syntax)
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type log(LoggingLevel loggingLevel, Logger logger, String marker, String message) {
LogDefinition answer = new LogDefinition(message);
answer.setLoggingLevel(loggingLevel);
answer.setLogger(logger);
answer.setMarker(marker);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -1906,7 +1877,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
ThrowExceptionDefinition answer = new ThrowExceptionDefinition();
answer.setException(exception);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -1921,7 +1892,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
answer.setExceptionClass(type);
answer.setMessage(message);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -1938,7 +1909,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
RollbackDefinition answer = new RollbackDefinition();
answer.setMarkRollbackOnly(true);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -1958,7 +1929,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
RollbackDefinition answer = new RollbackDefinition();
answer.setMarkRollbackOnlyLast(true);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -1987,7 +1958,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
public Type rollback(String message) {
RollbackDefinition answer = new RollbackDefinition(message);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2040,7 +2011,6 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
return blocks.isEmpty() ? null : blocks.removeLast();
}
- @SuppressWarnings("unchecked")
public Type startupOrder(int startupOrder) {
ProcessorDefinition<?> def = this;
@@ -2049,7 +2019,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
route.startupOrder(startupOrder);
}
- return (Type) this;
+ return asType();
}
/**
@@ -2057,11 +2027,10 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
*
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type stop() {
StopDefinition stop = new StopDefinition();
addOutput(stop);
- return (Type) this;
+ return asType();
}
/**
@@ -2167,11 +2136,10 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param processor the custom {@link Processor}
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type process(Processor processor) {
ProcessDefinition answer = new ProcessDefinition(processor);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2182,12 +2150,11 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param ref reference to a {@link Processor} to lookup in the registry
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type process(String ref) {
ProcessDefinition answer = new ProcessDefinition();
answer.setRef(ref);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2212,7 +2179,6 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param bean the bean to invoke, or a reference to a bean if the type is a String
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type bean(Object bean) {
BeanDefinition answer = new BeanDefinition();
if (bean instanceof String) {
@@ -2221,7 +2187,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
answer.setBean(bean);
}
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2232,7 +2198,6 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param method the method name to invoke on the bean (can be used to avoid ambiguity)
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type bean(Object bean, String method) {
BeanDefinition answer = new BeanDefinition();
if (bean instanceof String) {
@@ -2242,7 +2207,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
}
answer.setMethod(method);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2255,7 +2220,6 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* the multi parameter
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type bean(Object bean, boolean cache) {
BeanDefinition answer = new BeanDefinition();
if (bean instanceof String) {
@@ -2265,7 +2229,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
}
answer.setCache(cache);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2279,7 +2243,6 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* the multi parameter
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type bean(Object bean, String method, boolean cache) {
BeanDefinition answer = new BeanDefinition();
if (bean instanceof String) {
@@ -2290,7 +2253,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
answer.setMethod(method);
answer.setCache(cache);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2300,12 +2263,11 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param beanType the bean class, Camel will instantiate an object at runtime
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type bean(Class<?> beanType) {
BeanDefinition answer = new BeanDefinition();
answer.setBeanType(beanType);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2316,13 +2278,12 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param method the method name to invoke on the bean (can be used to avoid ambiguity)
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type bean(Class<?> beanType, String method) {
BeanDefinition answer = new BeanDefinition();
answer.setBeanType(beanType);
answer.setMethod(method);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2336,14 +2297,13 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* the multi parameter
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type bean(Class<?> beanType, String method, boolean cache) {
BeanDefinition answer = new BeanDefinition();
answer.setBeanType(beanType);
answer.setMethod(method);
answer.setCache(cache);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2366,11 +2326,10 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param expression the expression used to set the body
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type setBody(Expression expression) {
SetBodyDefinition answer = new SetBodyDefinition(expression);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2388,7 +2347,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
}
});
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2406,7 +2365,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
}
});
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2416,11 +2375,10 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param expression the expression used to set the body
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type transform(Expression expression) {
TransformDefinition answer = new TransformDefinition(expression);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2442,11 +2400,10 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param expression the expression used as the script.
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type script(Expression expression) {
ScriptDefinition answer = new ScriptDefinition(expression);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2470,7 +2427,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
public Type setFaultBody(Expression expression) {
SetFaultBodyDefinition answer = new SetFaultBodyDefinition(expression);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2493,11 +2450,10 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param expression the expression used to set the header
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type setHeader(String name, Expression expression) {
SetHeaderDefinition answer = new SetHeaderDefinition(name, expression);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2507,7 +2463,6 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param supplier the supplier used to set the header
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type setHeader(String name, final Supplier<Object> supplier) {
SetHeaderDefinition answer = new SetHeaderDefinition(name, new ExpressionAdapter() {
@Override
@@ -2517,7 +2472,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
});
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2527,11 +2482,10 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param expression the expression used to set the property
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type setProperty(String name, Expression expression) {
SetPropertyDefinition answer = new SetPropertyDefinition(name, expression);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2553,11 +2507,10 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param name the header name
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type removeHeader(String name) {
RemoveHeaderDefinition answer = new RemoveHeaderDefinition(name);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2566,11 +2519,10 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param pattern a pattern to match header names to be removed
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type removeHeaders(String pattern) {
RemoveHeadersDefinition answer = new RemoveHeadersDefinition(pattern);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2580,11 +2532,10 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param excludePatterns one or more pattern of header names that should be excluded (= preserved)
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type removeHeaders(String pattern, String... excludePatterns) {
RemoveHeadersDefinition answer = new RemoveHeadersDefinition(pattern, excludePatterns);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2593,11 +2544,10 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param name the property name
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type removeProperty(String name) {
RemovePropertyDefinition answer = new RemovePropertyDefinition(name);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2606,11 +2556,10 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param pattern a pattern to match properties names to be removed
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type removeProperties(String pattern) {
RemovePropertiesDefinition answer = new RemovePropertiesDefinition(pattern);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2620,11 +2569,10 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param excludePatterns one or more pattern of properties names that should be excluded (= preserved)
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type removeProperties(String pattern, String... excludePatterns) {
RemovePropertiesDefinition answer = new RemovePropertiesDefinition(pattern, excludePatterns);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2633,10 +2581,9 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param type the type to convert to
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type convertBodyTo(Class<?> type) {
addOutput(new ConvertBodyDefinition(type));
- return (Type) this;
+ return asType();
}
/**
@@ -2646,10 +2593,9 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param charset the charset to use by type converters (not all converters support specifc charset)
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type convertBodyTo(Class<?> type, String charset) {
addOutput(new ConvertBodyDefinition(type, charset));
- return (Type) this;
+ return asType();
}
/**
@@ -2669,10 +2615,9 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param comparator the comparator to use for sorting
* @return the builder
*/
- @SuppressWarnings("unchecked")
public <T> Type sort(Expression expression, Comparator<T> comparator) {
addOutput(new SortDefinition<>(expression, comparator));
- return (Type) this;
+ return asType();
}
/**
@@ -2708,7 +2653,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
ClaimCheckDefinition answer = new ClaimCheckDefinition();
answer.setOperation(operation);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2738,7 +2683,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
answer.setKey(key);
answer.setFilter(filter);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -2839,7 +2784,6 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @return the builder
* @see org.apache.camel.processor.Enricher
*/
- @SuppressWarnings("unchecked")
public Type enrich(@AsEndpointUri String resourceUri, AggregationStrategy aggregationStrategy, boolean aggregateOnException, boolean shareUnitOfWork) {
EnrichDefinition answer = new EnrichDefinition();
answer.setExpression(new ConstantExpression(resourceUri));
@@ -2847,7 +2791,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
answer.setAggregateOnException(aggregateOnException);
answer.setShareUnitOfWork(shareUnitOfWork);
addOutput(answer);
- return (Type) this;
+ return asType();
}
/**
@@ -3006,7 +2950,6 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @return the builder
* @see org.apache.camel.processor.PollEnricher
*/
- @SuppressWarnings("unchecked")
public Type pollEnrich(@AsEndpointUri String resourceUri, long timeout, AggregationStrategy aggregationStrategy, boolean aggregateOnException) {
PollEnrichDefinition pollEnrich = new PollEnrichDefinition();
pollEnrich.setExpression(new ConstantExpression(resourceUri));
@@ -3014,7 +2957,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
pollEnrich.setAggregationStrategy(aggregationStrategy);
pollEnrich.setAggregateOnException(aggregateOnException);
addOutput(pollEnrich);
- return (Type) this;
+ return asType();
}
/**
@@ -3037,7 +2980,6 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @return the builder
* @see org.apache.camel.processor.PollEnricher
*/
- @SuppressWarnings("unchecked")
public Type pollEnrich(@AsEndpointUri String resourceUri, long timeout, String aggregationStrategyRef, boolean aggregateOnException) {
PollEnrichDefinition pollEnrich = new PollEnrichDefinition();
pollEnrich.setExpression(new ConstantExpression(resourceUri));
@@ -3045,7 +2987,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
pollEnrich.setAggregationStrategyRef(aggregationStrategyRef);
pollEnrich.setAggregateOnException(aggregateOnException);
addOutput(pollEnrich);
- return (Type) this;
+ return asType();
}
/**
@@ -3089,7 +3031,6 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @return the builder
* @see org.apache.camel.processor.PollEnricher
*/
- @SuppressWarnings("unchecked")
public Type pollEnrich(@AsEndpointUri Expression expression, long timeout, String aggregationStrategyRef, boolean aggregateOnException) {
PollEnrichDefinition pollEnrich = new PollEnrichDefinition();
pollEnrich.setExpression(new ExpressionDefinition(expression));
@@ -3097,7 +3038,7 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
pollEnrich.setAggregationStrategyRef(aggregationStrategyRef);
pollEnrich.setAggregateOnException(aggregateOnException);
addOutput(pollEnrich);
- return (Type) this;
+ return asType();
}
/**
@@ -3171,10 +3112,9 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param dataFormatType the dataformat
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type unmarshal(DataFormatDefinition dataFormatType) {
addOutput(new UnmarshalDefinition(dataFormatType));
- return (Type) this;
+ return asType();
}
/**
@@ -3221,10 +3161,9 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param dataFormatType the dataformat
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type marshal(DataFormatDefinition dataFormatType) {
addOutput(new MarshalDefinition(dataFormatType));
- return (Type) this;
+ return asType();
}
/**
@@ -3248,10 +3187,9 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param dataTypeRef reference to a {@link DataFormat} to lookup in the registry
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type marshal(String dataTypeRef) {
addOutput(new MarshalDefinition(new CustomDataFormat(dataTypeRef)));
- return (Type) this;
+ return asType();
}
/**
@@ -3265,7 +3203,6 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
* @param inheritErrorHandler whether to not to inherit the error handler for this node
* @return the builder
*/
- @SuppressWarnings("unchecked")
public Type inheritErrorHandler(boolean inheritErrorHandler) {
// set on last output
int size = getOutputs().size();
@@ -3279,6 +3216,11 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
output.setInheritErrorHandler(inheritErrorHandler);
}
}
+ return asType();
+ }
+
+ @SuppressWarnings("unchecked")
+ Type asType() {
return (Type) this;
}