You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2019/08/21 05:16:40 UTC
[camel] branch CAMEL-13870 updated (8ca15bc -> 9d969b9)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch CAMEL-13870
in repository https://gitbox.apache.org/repos/asf/camel.git.
from 8ca15bc CAMEL-13870: Fast property configuration of Camel endpoints. Work in progress.
new d00b92c CAMEL-13870: Fast property configuration of Camel endpoints. Work in progress.
new 5b4be28 CAMEL-13870: Fast property configuration of Camel endpoints. Work in progress.
new b6553d2 CAMEL-13870: Fast property configuration of Camel endpoints. Work in progress.
new 676ea6b CAMEL-13870: Fast property configuration of Camel endpoints. Work in progress.
new 9d969b9 CAMEL-13870: Fast property configuration of Camel endpoints. Work in progress.
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:
.../camel/component/cmis/CMISSessionFacade.java | 28 ++
.../camel-ftp/src/main/docs/ftps-component.adoc | 2 +-
.../camel/component/file/remote/FtpEndpoint.java | 8 +
.../component/file/remote/FtpsConfiguration.java | 10 +-
.../camel/component/file/remote/FtpsEndpoint.java | 16 +
...LWithClientAuthAndSSLContextParametersTest.java | 2 +-
.../FileToFtpsExplicitSSLWithClientAuthTest.java | 2 +-
...lientAuthAndGlobalSSLContextParametersTest.java | 2 +-
...thoutClientAuthAndSSLContextParametersTest.java | 2 +-
...FileToFtpsExplicitSSLWithoutClientAuthTest.java | 2 +-
...SWithClientAuthAndSSLContextParametersTest.java | 2 +-
.../FileToFtpsExplicitTLSWithClientAuthTest.java | 2 +-
...thoutClientAuthAndSSLContextParametersTest.java | 2 +-
...FileToFtpsExplicitTLSWithoutClientAuthTest.java | 2 +-
...LWithClientAuthAndSSLContextParametersTest.java | 2 +-
.../FileToFtpsImplicitSSLWithClientAuthTest.java | 2 +-
...thoutClientAuthAndSSLContextParametersTest.java | 2 +-
...FileToFtpsImplicitSSLWithoutClientAuthTest.java | 2 +-
...SWithClientAuthAndSSLContextParametersTest.java | 2 +-
.../FileToFtpsImplicitTLSWithClientAuthTest.java | 2 +-
...thoutClientAuthAndSSLContextParametersTest.java | 2 +-
...FileToFtpsImplicitTLSWithoutClientAuthTest.java | 2 +-
...psWithCustomKeyAndTrustStorePropertiesTest.java | 2 +-
...leToFtpsWithCustomTrustStorePropertiesTest.java | 2 +-
.../file/remote/UriConfigurationTest.java | 4 +-
.../camel/component/geocoder/GeoCoderEndpoint.java | 7 +-
.../google/sheets/GoogleSheetsEndpoint.java | 8 +-
.../apache/camel/component/grpc/GrpcEndpoint.java | 4 +
.../main/docs/hazelcast-atomicvalue-component.adoc | 8 +-
.../main/docs/hazelcast-instance-component.adoc | 11 +-
.../src/main/docs/hazelcast-list-component.adoc | 11 +-
.../src/main/docs/hazelcast-map-component.adoc | 11 +-
.../main/docs/hazelcast-multimap-component.adoc | 11 +-
.../src/main/docs/hazelcast-queue-component.adoc | 8 +-
.../docs/hazelcast-replicatedmap-component.adoc | 11 +-
.../main/docs/hazelcast-ringbuffer-component.adoc | 8 +-
.../src/main/docs/hazelcast-seda-component.adoc | 6 +-
.../src/main/docs/hazelcast-set-component.adoc | 11 +-
.../src/main/docs/hazelcast-topic-component.adoc | 10 +-
.../hazelcast/HazelcastDefaultEndpoint.java | 6 -
.../hazelcast/queue/HazelcastQueueEndpoint.java | 8 +-
.../hazelcast/seda/HazelcastSedaEndpoint.java | 3 +
.../hazelcast/topic/HazelcastTopicEndpoint.java | 6 +
.../component/iec60870/AbstractIecEndpoint.java | 2 +
.../src/main/docs/ignite-events-component.adoc | 2 +-
.../ignite/events/IgniteEventsConsumer.java | 12 +-
.../ignite/events/IgniteEventsEndpoint.java | 66 ++-
.../camel/component/ignite/IgniteEventsTest.java | 29 --
.../camel/component/jcache/JCacheEndpoint.java | 12 +-
.../camel/component/jetty/JettyHttpComponent.java | 2 +-
.../camel/component/jetty/JettyHttpEndpoint.java | 9 +-
.../camel-jetty/src/main/docs/jetty-component.adoc | 4 +-
.../camel/component/jetty/CustomFiltersTest.java | 2 +-
.../apache/camel/component/jira/JiraEndpoint.java | 4 +
.../apache/camel/component/jmx/JMXConsumer.java | 4 +-
.../apache/camel/component/jmx/JMXEndpoint.java | 4 +-
.../apache/camel/component/jpa/JpaEndpoint.java | 4 +-
.../camel/component/jt400/Jt400Endpoint.java | 4 +
.../camel/component/kafka/KafkaConfiguration.java | 8 +-
.../camel/component/kafka/KafkaConsumer.java | 2 +-
.../kubernetes/AbstractKubernetesEndpoint.java | 4 +
.../camel-netty/src/main/docs/netty-component.adoc | 9 +-
.../camel/component/netty/NettyConfiguration.java | 10 +-
.../camel/component/netty/NettyEndpoint.java | 3 -
.../apache/camel/component/ssh/SshEndpoint.java | 8 +-
.../endpoint/dsl/FtpsEndpointBuilderFactory.java | 36 +-
...azelcastAtomicnumberEndpointBuilderFactory.java | 155 ------
.../HazelcastInstanceEndpointBuilderFactory.java | 160 ------
.../dsl/HazelcastListEndpointBuilderFactory.java | 541 --------------------
.../dsl/HazelcastMapEndpointBuilderFactory.java | 539 --------------------
.../HazelcastMultimapEndpointBuilderFactory.java | 549 --------------------
.../dsl/HazelcastQueueEndpointBuilderFactory.java | 462 -----------------
...zelcastReplicatedmapEndpointBuilderFactory.java | 555 ---------------------
.../HazelcastRingbufferEndpointBuilderFactory.java | 152 ------
.../dsl/HazelcastSedaEndpointBuilderFactory.java | 147 ------
.../dsl/HazelcastSetEndpointBuilderFactory.java | 539 --------------------
.../dsl/HazelcastTopicEndpointBuilderFactory.java | 477 ------------------
.../endpoint/dsl/NettyEndpointBuilderFactory.java | 240 ---------
.../springboot/NettyComponentConfiguration.java | 8 -
79 files changed, 222 insertions(+), 4796 deletions(-)
[camel] 02/05: CAMEL-13870: Fast property configuration of Camel
endpoints. Work in progress.
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch CAMEL-13870
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 5b4be28217d8d64616b6a5979f4bcf80f9cae180
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Wed Aug 21 06:23:12 2019 +0200
CAMEL-13870: Fast property configuration of Camel endpoints. Work in progress.
---
.../camel/component/file/remote/FtpEndpoint.java | 8 +
.../component/file/remote/FtpsConfiguration.java | 10 +-
.../camel/component/file/remote/FtpsEndpoint.java | 16 ++
...LWithClientAuthAndSSLContextParametersTest.java | 2 +-
.../FileToFtpsExplicitSSLWithClientAuthTest.java | 2 +-
...lientAuthAndGlobalSSLContextParametersTest.java | 2 +-
...thoutClientAuthAndSSLContextParametersTest.java | 2 +-
...FileToFtpsExplicitSSLWithoutClientAuthTest.java | 2 +-
...SWithClientAuthAndSSLContextParametersTest.java | 2 +-
.../FileToFtpsExplicitTLSWithClientAuthTest.java | 2 +-
...thoutClientAuthAndSSLContextParametersTest.java | 2 +-
...FileToFtpsExplicitTLSWithoutClientAuthTest.java | 2 +-
...LWithClientAuthAndSSLContextParametersTest.java | 2 +-
.../FileToFtpsImplicitSSLWithClientAuthTest.java | 2 +-
...thoutClientAuthAndSSLContextParametersTest.java | 2 +-
...FileToFtpsImplicitSSLWithoutClientAuthTest.java | 2 +-
...SWithClientAuthAndSSLContextParametersTest.java | 2 +-
.../FileToFtpsImplicitTLSWithClientAuthTest.java | 2 +-
...thoutClientAuthAndSSLContextParametersTest.java | 2 +-
...FileToFtpsImplicitTLSWithoutClientAuthTest.java | 2 +-
...psWithCustomKeyAndTrustStorePropertiesTest.java | 2 +-
...leToFtpsWithCustomTrustStorePropertiesTest.java | 2 +-
.../file/remote/UriConfigurationTest.java | 4 +-
.../camel-netty/src/main/docs/netty-component.adoc | 9 +-
.../camel/component/netty/NettyConfiguration.java | 10 +-
.../camel/component/netty/NettyEndpoint.java | 3 -
.../apache/camel/component/ssh/SshEndpoint.java | 8 +-
.../endpoint/dsl/NettyEndpointBuilderFactory.java | 240 ---------------------
.../springboot/NettyComponentConfiguration.java | 8 -
29 files changed, 59 insertions(+), 295 deletions(-)
diff --git a/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/FtpEndpoint.java b/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/FtpEndpoint.java
index 649688a..af058ab 100644
--- a/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/FtpEndpoint.java
+++ b/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/FtpEndpoint.java
@@ -255,6 +255,10 @@ public class FtpEndpoint<T extends FTPFile> extends RemoteFileEndpoint<FTPFile>
this.ftpClientConfig = ftpClientConfig;
}
+ public Map<String, Object> getFtpClientParameters() {
+ return ftpClientParameters;
+ }
+
/**
* Used by FtpComponent to provide additional parameters for the FTPClient
*/
@@ -262,6 +266,10 @@ public class FtpEndpoint<T extends FTPFile> extends RemoteFileEndpoint<FTPFile>
this.ftpClientParameters = ftpClientParameters;
}
+ public Map<String, Object> getFtpClientConfigParameters() {
+ return ftpClientConfigParameters;
+ }
+
/**
* Used by FtpComponent to provide additional parameters for the FTPClientConfig
*/
diff --git a/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/FtpsConfiguration.java b/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/FtpsConfiguration.java
index e37f3ed..763fff5 100644
--- a/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/FtpsConfiguration.java
+++ b/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/FtpsConfiguration.java
@@ -31,7 +31,7 @@ public class FtpsConfiguration extends FtpConfiguration {
// TODO : switch to TLSv1.3 when we fully upgrade to JDK11
private String securityProtocol = "TLSv1.2";
@UriParam(label = "security")
- private boolean isImplicit;
+ private boolean implicit;
@UriParam(label = "security")
private boolean disableSecureDataChannelDefaults;
@UriParam(label = "security")
@@ -66,15 +66,15 @@ public class FtpsConfiguration extends FtpConfiguration {
* true - Implicit Mode / False - Explicit Mode
*/
public boolean isImplicit() {
- return isImplicit;
+ return implicit;
}
/**
- * Set the security mode(Implicit/Explicit).
+ * Set the security mode (Implicit/Explicit).
* true - Implicit Mode / False - Explicit Mode
*/
- public void setIsImplicit(boolean isImplicit) {
- this.isImplicit = isImplicit;
+ public void setImplicit(boolean implicit) {
+ this.implicit = implicit;
}
public boolean isDisableSecureDataChannelDefaults() {
diff --git a/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/FtpsEndpoint.java b/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/FtpsEndpoint.java
index a89ae92..b1328d8 100644
--- a/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/FtpsEndpoint.java
+++ b/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/FtpsEndpoint.java
@@ -64,6 +64,14 @@ public class FtpsEndpoint extends FtpEndpoint<FTPFile> {
}
@Override
+ public FtpsConfiguration getConfiguration() {
+ if (configuration == null) {
+ configuration = new FtpsConfiguration();
+ }
+ return configuration;
+ }
+
+ @Override
public String getScheme() {
return getFtpsConfiguration().getProtocol();
}
@@ -224,6 +232,10 @@ public class FtpsEndpoint extends FtpEndpoint<FTPFile> {
return (FtpsConfiguration) getConfiguration();
}
+ public Map<String, Object> getFtpClientKeyStoreParameters() {
+ return ftpClientKeyStoreParameters;
+ }
+
/**
* Set the key store parameters
*/
@@ -231,6 +243,10 @@ public class FtpsEndpoint extends FtpEndpoint<FTPFile> {
this.ftpClientKeyStoreParameters = param;
}
+ public Map<String, Object> getFtpClientTrustStoreParameters() {
+ return ftpClientTrustStoreParameters;
+ }
+
/**
* Set the trust store parameters
*/
diff --git a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitSSLWithClientAuthAndSSLContextParametersTest.java b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitSSLWithClientAuthAndSSLContextParametersTest.java
index 0a01bff..b4c51b2 100644
--- a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitSSLWithClientAuthAndSSLContextParametersTest.java
+++ b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitSSLWithClientAuthAndSSLContextParametersTest.java
@@ -48,6 +48,6 @@ public class FileToFtpsExplicitSSLWithClientAuthAndSSLContextParametersTest exte
@Override
protected String getFtpUrl() {
return "ftps://admin@localhost:" + getPort() + "/tmp2/camel?password=admin&consumer.initialDelay=2000&disableSecureDataChannelDefaults=true"
- + "&isImplicit=false&sslContextParameters=#sslContextParameters&delete=true";
+ + "&implicit=false&sslContextParameters=#sslContextParameters&delete=true";
}
}
diff --git a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitSSLWithClientAuthTest.java b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitSSLWithClientAuthTest.java
index 4c876a8..4f05426 100644
--- a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitSSLWithClientAuthTest.java
+++ b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitSSLWithClientAuthTest.java
@@ -27,7 +27,7 @@ public class FileToFtpsExplicitSSLWithClientAuthTest extends FtpsServerExplicitS
protected String getFtpUrl() {
return "ftps://admin@localhost:" + getPort() + "/tmp2/camel?password=admin&consumer.initialDelay=2000&disableSecureDataChannelDefaults=true"
- + "&securityProtocol=SSLv3&isImplicit=false&ftpClient.keyStore.file=./src/test/resources/server.jks&ftpClient.keyStore.type=JKS"
+ + "&securityProtocol=SSLv3&implicit=false&ftpClient.keyStore.file=./src/test/resources/server.jks&ftpClient.keyStore.type=JKS"
+ "&ftpClient.keyStore.algorithm=SunX509&ftpClient.keyStore.password=password&ftpClient.keyStore.keyPassword=password&delete=true";
}
diff --git a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitSSLWithoutClientAuthAndGlobalSSLContextParametersTest.java b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitSSLWithoutClientAuthAndGlobalSSLContextParametersTest.java
index 48b4e11..89f60dd 100644
--- a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitSSLWithoutClientAuthAndGlobalSSLContextParametersTest.java
+++ b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitSSLWithoutClientAuthAndGlobalSSLContextParametersTest.java
@@ -46,6 +46,6 @@ public class FileToFtpsExplicitSSLWithoutClientAuthAndGlobalSSLContextParameters
@Override
protected String getFtpUrl() {
return "ftps://admin@localhost:" + getPort() + "/tmp2/camel?password=admin&consumer.initialDelay=2000&disableSecureDataChannelDefaults=true"
- + "&isImplicit=false&delete=true";
+ + "&implicit=false&delete=true";
}
}
diff --git a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitSSLWithoutClientAuthAndSSLContextParametersTest.java b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitSSLWithoutClientAuthAndSSLContextParametersTest.java
index f1508ce..3c4835e 100644
--- a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitSSLWithoutClientAuthAndSSLContextParametersTest.java
+++ b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitSSLWithoutClientAuthAndSSLContextParametersTest.java
@@ -42,6 +42,6 @@ public class FileToFtpsExplicitSSLWithoutClientAuthAndSSLContextParametersTest e
@Override
protected String getFtpUrl() {
return "ftps://admin@localhost:" + getPort() + "/tmp2/camel?password=admin&consumer.initialDelay=2000&disableSecureDataChannelDefaults=true"
- + "&isImplicit=false&sslContextParameters=#sslContextParameters&delete=true";
+ + "&implicit=false&sslContextParameters=#sslContextParameters&delete=true";
}
}
diff --git a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitSSLWithoutClientAuthTest.java b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitSSLWithoutClientAuthTest.java
index d4d6300..ecdf54f 100644
--- a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitSSLWithoutClientAuthTest.java
+++ b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitSSLWithoutClientAuthTest.java
@@ -27,7 +27,7 @@ public class FileToFtpsExplicitSSLWithoutClientAuthTest extends FtpsServerExplic
protected String getFtpUrl() {
return "ftps://admin@localhost:" + getPort() + "/tmp2/camel?password=admin&consumer.initialDelay=2000&disableSecureDataChannelDefaults=true&delete=true"
- + "&securityProtocol=SSLv3&isImplicit=false";
+ + "&securityProtocol=SSLv3&implicit=false";
}
@Test
diff --git a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitTLSWithClientAuthAndSSLContextParametersTest.java b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitTLSWithClientAuthAndSSLContextParametersTest.java
index 49d67fb..2f3ef64 100644
--- a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitTLSWithClientAuthAndSSLContextParametersTest.java
+++ b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitTLSWithClientAuthAndSSLContextParametersTest.java
@@ -48,6 +48,6 @@ public class FileToFtpsExplicitTLSWithClientAuthAndSSLContextParametersTest exte
@Override
protected String getFtpUrl() {
return "ftps://admin@localhost:" + getPort() + "/tmp2/camel?password=admin&consumer.initialDelay=2000&disableSecureDataChannelDefaults=true"
- + "&isImplicit=false&sslContextParameters=#sslContextParameters&delete=true";
+ + "&implicit=false&sslContextParameters=#sslContextParameters&delete=true";
}
}
diff --git a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitTLSWithClientAuthTest.java b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitTLSWithClientAuthTest.java
index 96a95f4..8a903e7 100644
--- a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitTLSWithClientAuthTest.java
+++ b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitTLSWithClientAuthTest.java
@@ -27,7 +27,7 @@ public class FileToFtpsExplicitTLSWithClientAuthTest extends FtpsServerExplicitT
protected String getFtpUrl() {
return "ftps://admin@localhost:" + getPort() + "/tmp2/camel?password=admin&consumer.initialDelay=2000&disableSecureDataChannelDefaults=true"
- + "&securityProtocol=TLSv1.2&isImplicit=false&ftpClient.keyStore.file=./src/test/resources/server.jks&ftpClient.keyStore.type=JKS"
+ + "&securityProtocol=TLSv1.2&implicit=false&ftpClient.keyStore.file=./src/test/resources/server.jks&ftpClient.keyStore.type=JKS"
+ "&ftpClient.keyStore.algorithm=SunX509&ftpClient.keyStore.password=password&ftpClient.keyStore.keyPassword=password&delete=true";
}
diff --git a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitTLSWithoutClientAuthAndSSLContextParametersTest.java b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitTLSWithoutClientAuthAndSSLContextParametersTest.java
index 400c17d..939a751 100644
--- a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitTLSWithoutClientAuthAndSSLContextParametersTest.java
+++ b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitTLSWithoutClientAuthAndSSLContextParametersTest.java
@@ -41,6 +41,6 @@ public class FileToFtpsExplicitTLSWithoutClientAuthAndSSLContextParametersTest e
@Override
protected String getFtpUrl() {
return "ftps://admin@localhost:" + getPort() + "/tmp2/camel?password=admin&consumer.initialDelay=2000&disableSecureDataChannelDefaults=true"
- + "&isImplicit=false&sslContextParameters=#sslContextParameters&delete=true";
+ + "&implicit=false&sslContextParameters=#sslContextParameters&delete=true";
}
}
diff --git a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitTLSWithoutClientAuthTest.java b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitTLSWithoutClientAuthTest.java
index eeb4f2b..d47f08a 100644
--- a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitTLSWithoutClientAuthTest.java
+++ b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsExplicitTLSWithoutClientAuthTest.java
@@ -27,7 +27,7 @@ public class FileToFtpsExplicitTLSWithoutClientAuthTest extends FtpsServerExplic
protected String getFtpUrl() {
return "ftps://admin@localhost:" + getPort() + "/tmp2/camel?password=admin&consumer.initialDelay=2000&disableSecureDataChannelDefaults=true"
- + "&securityProtocol=TLSv1.2&isImplicit=false&delete=true";
+ + "&securityProtocol=TLSv1.2&implicit=false&delete=true";
}
@Test
diff --git a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitSSLWithClientAuthAndSSLContextParametersTest.java b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitSSLWithClientAuthAndSSLContextParametersTest.java
index c021585..d02153f 100644
--- a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitSSLWithClientAuthAndSSLContextParametersTest.java
+++ b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitSSLWithClientAuthAndSSLContextParametersTest.java
@@ -47,6 +47,6 @@ public class FileToFtpsImplicitSSLWithClientAuthAndSSLContextParametersTest exte
@Override
protected String getFtpUrl() {
return "ftps://admin@localhost:" + getPort() + "/tmp2/camel?password=admin&consumer.initialDelay=2000&disableSecureDataChannelDefaults=true"
- + "&isImplicit=true&sslContextParameters=#sslContextParameters&delete=true";
+ + "&implicit=true&sslContextParameters=#sslContextParameters&delete=true";
}
}
diff --git a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitSSLWithClientAuthTest.java b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitSSLWithClientAuthTest.java
index 55af194..4fefde3 100644
--- a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitSSLWithClientAuthTest.java
+++ b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitSSLWithClientAuthTest.java
@@ -27,7 +27,7 @@ public class FileToFtpsImplicitSSLWithClientAuthTest extends FtpsServerImplicitS
protected String getFtpUrl() {
return "ftps://admin@localhost:" + getPort() + "/tmp2/camel?password=admin&consumer.initialDelay=2000&disableSecureDataChannelDefaults=true"
- + "&securityProtocol=SSLv3&isImplicit=true&ftpClient.keyStore.file=./src/test/resources/server.jks&ftpClient.keyStore.type=JKS"
+ + "&securityProtocol=SSLv3&implicit=true&ftpClient.keyStore.file=./src/test/resources/server.jks&ftpClient.keyStore.type=JKS"
+ "&ftpClient.keyStore.algorithm=SunX509&ftpClient.keyStore.password=password&ftpClient.keyStore.keyPassword=password&delete=true";
}
diff --git a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitSSLWithoutClientAuthAndSSLContextParametersTest.java b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitSSLWithoutClientAuthAndSSLContextParametersTest.java
index 79f46b0..43c9e09 100644
--- a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitSSLWithoutClientAuthAndSSLContextParametersTest.java
+++ b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitSSLWithoutClientAuthAndSSLContextParametersTest.java
@@ -41,6 +41,6 @@ public class FileToFtpsImplicitSSLWithoutClientAuthAndSSLContextParametersTest e
@Override
protected String getFtpUrl() {
return "ftps://admin@localhost:" + getPort() + "/tmp2/camel?password=admin&consumer.initialDelay=2000&disableSecureDataChannelDefaults=true"
- + "&isImplicit=true&sslContextParameters=#sslContextParameters&delete=true";
+ + "&implicit=true&sslContextParameters=#sslContextParameters&delete=true";
}
}
diff --git a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitSSLWithoutClientAuthTest.java b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitSSLWithoutClientAuthTest.java
index 40ba73e..5cda433 100644
--- a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitSSLWithoutClientAuthTest.java
+++ b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitSSLWithoutClientAuthTest.java
@@ -27,7 +27,7 @@ public class FileToFtpsImplicitSSLWithoutClientAuthTest extends FtpsServerImplic
protected String getFtpUrl() {
return "ftps://admin@localhost:" + getPort() + "/tmp2/camel?password=admin&consumer.initialDelay=2000&disableSecureDataChannelDefaults=true"
- + "&securityProtocol=SSLv3&isImplicit=true&delete=true";
+ + "&securityProtocol=SSLv3&implicit=true&delete=true";
}
@Test
diff --git a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitTLSWithClientAuthAndSSLContextParametersTest.java b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitTLSWithClientAuthAndSSLContextParametersTest.java
index e8322d6..65baf8a 100644
--- a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitTLSWithClientAuthAndSSLContextParametersTest.java
+++ b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitTLSWithClientAuthAndSSLContextParametersTest.java
@@ -47,6 +47,6 @@ public class FileToFtpsImplicitTLSWithClientAuthAndSSLContextParametersTest exte
@Override
protected String getFtpUrl() {
return "ftps://admin@localhost:" + getPort() + "/tmp2/camel?password=admin&consumer.initialDelay=2000&disableSecureDataChannelDefaults=true"
- + "&isImplicit=true&sslContextParameters=#sslContextParameters&delete=true";
+ + "&implicit=true&sslContextParameters=#sslContextParameters&delete=true";
}
}
diff --git a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitTLSWithClientAuthTest.java b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitTLSWithClientAuthTest.java
index 10fca47..326419f 100644
--- a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitTLSWithClientAuthTest.java
+++ b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitTLSWithClientAuthTest.java
@@ -27,7 +27,7 @@ public class FileToFtpsImplicitTLSWithClientAuthTest extends FtpsServerImplicitT
protected String getFtpUrl() {
return "ftps://admin@localhost:" + getPort() + "/tmp2/camel?password=admin&consumer.initialDelay=2000&disableSecureDataChannelDefaults=true"
- + "&securityProtocol=TLSv1.2&isImplicit=true&ftpClient.keyStore.file=./src/test/resources/server.jks&ftpClient.keyStore.type=JKS"
+ + "&securityProtocol=TLSv1.2&implicit=true&ftpClient.keyStore.file=./src/test/resources/server.jks&ftpClient.keyStore.type=JKS"
+ "&ftpClient.keyStore.algorithm=SunX509&ftpClient.keyStore.password=password&ftpClient.keyStore.keyPassword=password&delete=true";
}
diff --git a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitTLSWithoutClientAuthAndSSLContextParametersTest.java b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitTLSWithoutClientAuthAndSSLContextParametersTest.java
index d2e9065..7da9a6e 100644
--- a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitTLSWithoutClientAuthAndSSLContextParametersTest.java
+++ b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitTLSWithoutClientAuthAndSSLContextParametersTest.java
@@ -41,6 +41,6 @@ public class FileToFtpsImplicitTLSWithoutClientAuthAndSSLContextParametersTest e
@Override
protected String getFtpUrl() {
return "ftps://admin@localhost:" + getPort() + "/tmp2/camel?password=admin&consumer.initialDelay=2000&disableSecureDataChannelDefaults=true"
- + "&isImplicit=true&sslContextParameters=#sslContextParameters&delete=true";
+ + "&implicit=true&sslContextParameters=#sslContextParameters&delete=true";
}
}
diff --git a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitTLSWithoutClientAuthTest.java b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitTLSWithoutClientAuthTest.java
index cb519b4..6f960e3 100644
--- a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitTLSWithoutClientAuthTest.java
+++ b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsImplicitTLSWithoutClientAuthTest.java
@@ -27,7 +27,7 @@ public class FileToFtpsImplicitTLSWithoutClientAuthTest extends FtpsServerImplic
protected String getFtpUrl() {
return "ftps://admin@localhost:" + getPort() + "/tmp2/camel?password=admin&consumer.initialDelay=2000&disableSecureDataChannelDefaults=true"
- + "&securityProtocol=TLSv1.2&isImplicit=true&delete=true";
+ + "&securityProtocol=TLSv1.2&implicit=true&delete=true";
}
@Test
diff --git a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsWithCustomKeyAndTrustStorePropertiesTest.java b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsWithCustomKeyAndTrustStorePropertiesTest.java
index e5d4749..b542f02 100644
--- a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsWithCustomKeyAndTrustStorePropertiesTest.java
+++ b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsWithCustomKeyAndTrustStorePropertiesTest.java
@@ -27,7 +27,7 @@ public class FileToFtpsWithCustomKeyAndTrustStorePropertiesTest extends FtpsServ
private String getFtpUrl() {
return "ftps://admin@localhost:" + getPort() + "/tmp2/camel?password=admin&consumer.initialDelay=2000&disableSecureDataChannelDefaults=true"
- + "&securityProtocol=SSLv3&isImplicit=false&ftpClient.keyStore.file=./src/test/resources/server.jks&ftpClient.keyStore.type=JKS"
+ + "&securityProtocol=SSLv3&implicit=false&ftpClient.keyStore.file=./src/test/resources/server.jks&ftpClient.keyStore.type=JKS"
+ "&ftpClient.keyStore.algorithm=SunX509&ftpClient.keyStore.password=password&ftpClient.keyStore.keyPassword=password"
+ "&ftpClient.trustStore.file=./src/test/resources/server.jks&ftpClient.trustStore.type=JKS"
+ "&ftpClient.trustStore.algorithm=SunX509&ftpClient.trustStore.password=password&delete=true";
diff --git a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsWithCustomTrustStorePropertiesTest.java b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsWithCustomTrustStorePropertiesTest.java
index 0f1d15c..f0f523a 100644
--- a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsWithCustomTrustStorePropertiesTest.java
+++ b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/FileToFtpsWithCustomTrustStorePropertiesTest.java
@@ -27,7 +27,7 @@ public class FileToFtpsWithCustomTrustStorePropertiesTest extends FtpsServerExpl
private String getFtpUrl() {
return "ftps://admin@localhost:" + getPort() + "/tmp2/camel?password=admin&consumer.initialDelay=2000&disableSecureDataChannelDefaults=true"
- + "&securityProtocol=SSLv3&isImplicit=false&ftpClient.trustStore.file=./src/test/resources/server.jks&ftpClient.trustStore.type=JKS"
+ + "&securityProtocol=SSLv3&implicit=false&ftpClient.trustStore.file=./src/test/resources/server.jks&ftpClient.trustStore.type=JKS"
+ "&ftpClient.trustStore.algorithm=SunX509&ftpClient.trustStore.password=password&delete=true";
}
diff --git a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/UriConfigurationTest.java b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/UriConfigurationTest.java
index c71bacb..e16d9ed 100644
--- a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/UriConfigurationTest.java
+++ b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/UriConfigurationTest.java
@@ -69,7 +69,7 @@ public class UriConfigurationTest extends CamelTestSupport {
@Test
public void testFtpsExplicitConfigurationDefaults() {
- FtpsEndpoint endpoint = context.getEndpoint("ftps://hostname:990?isImplicit=true", FtpsEndpoint.class);
+ FtpsEndpoint endpoint = context.getEndpoint("ftps://hostname:990?implicit=true", FtpsEndpoint.class);
FtpsConfiguration config = endpoint.getFtpsConfiguration();
assertEquals("ftps", config.getProtocol());
@@ -110,7 +110,7 @@ public class UriConfigurationTest extends CamelTestSupport {
@Test
public void testFtpsExplicitConfiguration() {
- FtpsEndpoint endpoint = context.getEndpoint("ftps://user@hostname:1021/some/file?password=secret&binary=true&securityProtocol=SSL&isImplicit=true", FtpsEndpoint.class);
+ FtpsEndpoint endpoint = context.getEndpoint("ftps://user@hostname:1021/some/file?password=secret&binary=true&securityProtocol=SSL&implicit=true", FtpsEndpoint.class);
FtpsConfiguration config = endpoint.getFtpsConfiguration();
assertEquals("ftps", config.getProtocol());
diff --git a/components/camel-netty/src/main/docs/netty-component.adoc b/components/camel-netty/src/main/docs/netty-component.adoc
index 0283a38..4c99a51 100644
--- a/components/camel-netty/src/main/docs/netty-component.adoc
+++ b/components/camel-netty/src/main/docs/netty-component.adoc
@@ -88,7 +88,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (74 parameters):
+=== Query Parameters (71 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -133,7 +133,6 @@ with the following path and query parameters:
| *useByteBuf* (producer) | If the useByteBuf is true, netty producer will turn the message body into ByteBuf before sending it out. | false | boolean
| *allowSerializedHeaders* (advanced) | Only used for TCP when transferExchange is true. When set to true, serializable objects in headers and properties will be added to the exchange. Otherwise Camel will exclude any non-serializable objects and log it at WARN level. | false | boolean
| *basicPropertyBinding* (advanced) | Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities | false | boolean
-| *bootstrapConfiguration* (advanced) | To use a custom configured NettyServerBootstrapConfiguration for configuring this endpoint. | | NettyServerBootstrap Configuration
| *channelGroup* (advanced) | To use a explicit ChannelGroup. | | ChannelGroup
| *nativeTransport* (advanced) | Whether to use native transport instead of NIO. Native transport takes advantage of the host operating system and is only supported on some platforms. You need to add the netty JAR for the host operating system you are using. See more details at: \http://netty.io/wiki/native-transports.html | false | boolean
| *options* (advanced) | Allows to configure additional netty options using option. as prefix. For example option.child.keepAlive=false to set the netty option child.keepAlive=false. See the Netty documentation for possible options that can be used. | | Map
@@ -147,12 +146,10 @@ with the following path and query parameters:
| *workerGroup* (advanced) | To use a explicit EventLoopGroup as the boss thread pool. For example to share a thread pool with multiple consumers or producers. By default each consumer or producer has their own worker pool with 2 x cpu count core threads. | | EventLoopGroup
| *allowDefaultCodec* (codec) | The netty component installs a default codec if both, encoder/decoder is null and textline is false. Setting allowDefaultCodec to false prevents the netty component from installing a default codec as the first element in the filter chain. | true | boolean
| *autoAppendDelimiter* (codec) | Whether or not to auto append missing end delimiter when sending using the textline codec. | true | boolean
-| *decoder* (codec) | *Deprecated* A custom ChannelHandler class that can be used to perform special marshalling of inbound payloads. | | ChannelHandler
| *decoderMaxLineLength* (codec) | The max line length to use for the textline codec. | 1024 | int
-| *decoders* (codec) | A list of decoders to be used. You can use a String which have values separated by comma, and have the values be looked up in the Registry. Just remember to prefix the value with # so Camel knows it should lookup. | | String
+| *decoders* (codec) | A list of decoders to be used. You can use a String which have values separated by comma, and have the values be looked up in the Registry. Just remember to prefix the value with # so Camel knows it should lookup. | | List
| *delimiter* (codec) | The delimiter to use for the textline codec. Possible values are LINE and NULL. | LINE | TextLineDelimiter
-| *encoder* (codec) | *Deprecated* A custom ChannelHandler class that can be used to perform special marshalling of outbound payloads. | | ChannelHandler
-| *encoders* (codec) | A list of encoders to be used. You can use a String which have values separated by comma, and have the values be looked up in the Registry. Just remember to prefix the value with # so Camel knows it should lookup. | | String
+| *encoders* (codec) | A list of encoders to be used. You can use a String which have values separated by comma, and have the values be looked up in the Registry. Just remember to prefix the value with # so Camel knows it should lookup. | | List
| *encoding* (codec) | The encoding (a charset name) to use for the textline codec. If not provided, Camel will use the JVM default Charset. | | String
| *textline* (codec) | Only used for TCP. If no codec is specified, you can use this flag to indicate a text line based codec; if not specified or the value is false, then Object Serialization is assumed over TCP. | false | boolean
| *enabledProtocols* (security) | Which protocols to enable when using SSL | TLSv1,TLSv1.1,TLSv1.2 | String
diff --git a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
index ec9bacf..9c5a69e 100644
--- a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
+++ b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyConfiguration.java
@@ -61,15 +61,9 @@ public class NettyConfiguration extends NettyServerBootstrapConfiguration implem
private int decoderMaxLineLength = 1024;
@UriParam(label = "codec")
private String encoding;
- @UriParam(label = "codec", description = "To use a single encoder. This options is deprecated use encoders instead.")
- @Deprecated
- private ChannelHandler encoder;
- @UriParam(label = "codec", javaType = "java.lang.String")
+ @UriParam(label = "codec")
private List<ChannelHandler> encoders = new ArrayList<>();
- @UriParam(label = "codec", description = "To use a single decoder. This options is deprecated use encoders instead.")
- @Deprecated
- private ChannelHandler decoder;
- @UriParam(label = "codec", javaType = "java.lang.String")
+ @UriParam(label = "codec")
private List<ChannelHandler> decoders = new ArrayList<>();
@UriParam
private boolean disconnect;
diff --git a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java
index 9ae5ed6..5f0fd97 100644
--- a/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java
+++ b/components/camel-netty/src/main/java/org/apache/camel/component/netty/NettyEndpoint.java
@@ -44,9 +44,6 @@ import org.apache.camel.util.ObjectHelper;
public class NettyEndpoint extends DefaultEndpoint implements AsyncEndpoint {
@UriParam
private NettyConfiguration configuration;
- @UriParam(label = "advanced", javaType = "org.apache.camel.component.netty.NettyServerBootstrapConfiguration",
- description = "To use a custom configured NettyServerBootstrapConfiguration for configuring this endpoint.")
- private Object bootstrapConfiguration; // to include in component docs as NettyServerBootstrapConfiguration is a @UriParams class
public NettyEndpoint(String endpointUri, NettyComponent component, NettyConfiguration configuration) {
super(endpointUri, component);
diff --git a/components/camel-ssh/src/main/java/org/apache/camel/component/ssh/SshEndpoint.java b/components/camel-ssh/src/main/java/org/apache/camel/component/ssh/SshEndpoint.java
index 041226e..2180257 100644
--- a/components/camel-ssh/src/main/java/org/apache/camel/component/ssh/SshEndpoint.java
+++ b/components/camel-ssh/src/main/java/org/apache/camel/component/ssh/SshEndpoint.java
@@ -35,7 +35,7 @@ public class SshEndpoint extends ScheduledPollEndpoint {
protected final Logger log = LoggerFactory.getLogger(getClass());
@UriParam
- private SshConfiguration sshConfiguration;
+ private SshConfiguration configuration;
public SshEndpoint() {
}
@@ -46,7 +46,7 @@ public class SshEndpoint extends ScheduledPollEndpoint {
public SshEndpoint(String uri, SshComponent component, SshConfiguration configuration) {
super(uri, component);
- this.sshConfiguration = configuration;
+ this.configuration = configuration;
}
@Override
@@ -68,11 +68,11 @@ public class SshEndpoint extends ScheduledPollEndpoint {
}
public SshConfiguration getConfiguration() {
- return sshConfiguration;
+ return configuration;
}
public void setConfiguration(SshConfiguration configuration) {
- this.sshConfiguration = configuration;
+ this.configuration = configuration;
}
public String getHost() {
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 068abcf..eabfefd 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
@@ -384,33 +384,6 @@ public interface NettyEndpointBuilderFactory {
return this;
}
/**
- * A custom ChannelHandler class that can be used to perform special
- * marshalling of inbound payloads.
- *
- * The option is a: <code>io.netty.channel.ChannelHandler</code> type.
- *
- * Group: codec
- */
- @Deprecated
- default NettyEndpointConsumerBuilder decoder(Object decoder) {
- setProperty("decoder", decoder);
- return this;
- }
- /**
- * A custom ChannelHandler class that can be used to perform special
- * marshalling of inbound payloads.
- *
- * The option will be converted to a
- * <code>io.netty.channel.ChannelHandler</code> type.
- *
- * Group: codec
- */
- @Deprecated
- default NettyEndpointConsumerBuilder decoder(String decoder) {
- setProperty("decoder", decoder);
- return this;
- }
- /**
* The max line length to use for the textline codec.
*
* The option is a: <code>int</code> type.
@@ -494,33 +467,6 @@ public interface NettyEndpointBuilderFactory {
return this;
}
/**
- * A custom ChannelHandler class that can be used to perform special
- * marshalling of outbound payloads.
- *
- * The option is a: <code>io.netty.channel.ChannelHandler</code> type.
- *
- * Group: codec
- */
- @Deprecated
- default NettyEndpointConsumerBuilder encoder(Object encoder) {
- setProperty("encoder", encoder);
- return this;
- }
- /**
- * A custom ChannelHandler class that can be used to perform special
- * marshalling of outbound payloads.
- *
- * The option will be converted to a
- * <code>io.netty.channel.ChannelHandler</code> type.
- *
- * Group: codec
- */
- @Deprecated
- default NettyEndpointConsumerBuilder encoder(String encoder) {
- setProperty("encoder", encoder);
- return this;
- }
- /**
* A list of encoders to be used. You can use a String which have values
* separated by comma, and have the values be looked up in the Registry.
* Just remember to prefix the value with # so Camel knows it should
@@ -1252,32 +1198,6 @@ public interface NettyEndpointBuilderFactory {
return this;
}
/**
- * To use a custom configured NettyServerBootstrapConfiguration for
- * configuring this endpoint.
- *
- * The option is a: <code>java.lang.Object</code> type.
- *
- * Group: advanced
- */
- default AdvancedNettyEndpointConsumerBuilder bootstrapConfiguration(
- Object bootstrapConfiguration) {
- setProperty("bootstrapConfiguration", bootstrapConfiguration);
- return this;
- }
- /**
- * To use a custom configured NettyServerBootstrapConfiguration for
- * configuring this endpoint.
- *
- * The option will be converted to a <code>java.lang.Object</code> type.
- *
- * Group: advanced
- */
- default AdvancedNettyEndpointConsumerBuilder bootstrapConfiguration(
- String bootstrapConfiguration) {
- setProperty("bootstrapConfiguration", bootstrapConfiguration);
- return this;
- }
- /**
* To use a explicit ChannelGroup.
*
* The option is a: <code>io.netty.channel.group.ChannelGroup</code>
@@ -1901,33 +1821,6 @@ public interface NettyEndpointBuilderFactory {
return this;
}
/**
- * A custom ChannelHandler class that can be used to perform special
- * marshalling of inbound payloads.
- *
- * The option is a: <code>io.netty.channel.ChannelHandler</code> type.
- *
- * Group: codec
- */
- @Deprecated
- default NettyEndpointProducerBuilder decoder(Object decoder) {
- setProperty("decoder", decoder);
- return this;
- }
- /**
- * A custom ChannelHandler class that can be used to perform special
- * marshalling of inbound payloads.
- *
- * The option will be converted to a
- * <code>io.netty.channel.ChannelHandler</code> type.
- *
- * Group: codec
- */
- @Deprecated
- default NettyEndpointProducerBuilder decoder(String decoder) {
- setProperty("decoder", decoder);
- return this;
- }
- /**
* The max line length to use for the textline codec.
*
* The option is a: <code>int</code> type.
@@ -2011,33 +1904,6 @@ public interface NettyEndpointBuilderFactory {
return this;
}
/**
- * A custom ChannelHandler class that can be used to perform special
- * marshalling of outbound payloads.
- *
- * The option is a: <code>io.netty.channel.ChannelHandler</code> type.
- *
- * Group: codec
- */
- @Deprecated
- default NettyEndpointProducerBuilder encoder(Object encoder) {
- setProperty("encoder", encoder);
- return this;
- }
- /**
- * A custom ChannelHandler class that can be used to perform special
- * marshalling of outbound payloads.
- *
- * The option will be converted to a
- * <code>io.netty.channel.ChannelHandler</code> type.
- *
- * Group: codec
- */
- @Deprecated
- default NettyEndpointProducerBuilder encoder(String encoder) {
- setProperty("encoder", encoder);
- return this;
- }
- /**
* A list of encoders to be used. You can use a String which have values
* separated by comma, and have the values be looked up in the Registry.
* Just remember to prefix the value with # so Camel knows it should
@@ -2707,32 +2573,6 @@ public interface NettyEndpointBuilderFactory {
return this;
}
/**
- * To use a custom configured NettyServerBootstrapConfiguration for
- * configuring this endpoint.
- *
- * The option is a: <code>java.lang.Object</code> type.
- *
- * Group: advanced
- */
- default AdvancedNettyEndpointProducerBuilder bootstrapConfiguration(
- Object bootstrapConfiguration) {
- setProperty("bootstrapConfiguration", bootstrapConfiguration);
- return this;
- }
- /**
- * To use a custom configured NettyServerBootstrapConfiguration for
- * configuring this endpoint.
- *
- * The option will be converted to a <code>java.lang.Object</code> type.
- *
- * Group: advanced
- */
- default AdvancedNettyEndpointProducerBuilder bootstrapConfiguration(
- String bootstrapConfiguration) {
- setProperty("bootstrapConfiguration", bootstrapConfiguration);
- return this;
- }
- /**
* To use a explicit ChannelGroup.
*
* The option is a: <code>io.netty.channel.group.ChannelGroup</code>
@@ -3260,33 +3100,6 @@ public interface NettyEndpointBuilderFactory {
return this;
}
/**
- * A custom ChannelHandler class that can be used to perform special
- * marshalling of inbound payloads.
- *
- * The option is a: <code>io.netty.channel.ChannelHandler</code> type.
- *
- * Group: codec
- */
- @Deprecated
- default NettyEndpointBuilder decoder(Object decoder) {
- setProperty("decoder", decoder);
- return this;
- }
- /**
- * A custom ChannelHandler class that can be used to perform special
- * marshalling of inbound payloads.
- *
- * The option will be converted to a
- * <code>io.netty.channel.ChannelHandler</code> type.
- *
- * Group: codec
- */
- @Deprecated
- default NettyEndpointBuilder decoder(String decoder) {
- setProperty("decoder", decoder);
- return this;
- }
- /**
* The max line length to use for the textline codec.
*
* The option is a: <code>int</code> type.
@@ -3369,33 +3182,6 @@ public interface NettyEndpointBuilderFactory {
return this;
}
/**
- * A custom ChannelHandler class that can be used to perform special
- * marshalling of outbound payloads.
- *
- * The option is a: <code>io.netty.channel.ChannelHandler</code> type.
- *
- * Group: codec
- */
- @Deprecated
- default NettyEndpointBuilder encoder(Object encoder) {
- setProperty("encoder", encoder);
- return this;
- }
- /**
- * A custom ChannelHandler class that can be used to perform special
- * marshalling of outbound payloads.
- *
- * The option will be converted to a
- * <code>io.netty.channel.ChannelHandler</code> type.
- *
- * Group: codec
- */
- @Deprecated
- default NettyEndpointBuilder encoder(String encoder) {
- setProperty("encoder", encoder);
- return this;
- }
- /**
* A list of encoders to be used. You can use a String which have values
* separated by comma, and have the values be looked up in the Registry.
* Just remember to prefix the value with # so Camel knows it should
@@ -3754,32 +3540,6 @@ public interface NettyEndpointBuilderFactory {
return this;
}
/**
- * To use a custom configured NettyServerBootstrapConfiguration for
- * configuring this endpoint.
- *
- * The option is a: <code>java.lang.Object</code> type.
- *
- * Group: advanced
- */
- default AdvancedNettyEndpointBuilder bootstrapConfiguration(
- Object bootstrapConfiguration) {
- setProperty("bootstrapConfiguration", bootstrapConfiguration);
- return this;
- }
- /**
- * To use a custom configured NettyServerBootstrapConfiguration for
- * configuring this endpoint.
- *
- * The option will be converted to a <code>java.lang.Object</code> type.
- *
- * Group: advanced
- */
- default AdvancedNettyEndpointBuilder bootstrapConfiguration(
- String bootstrapConfiguration) {
- setProperty("bootstrapConfiguration", bootstrapConfiguration);
- return this;
- }
- /**
* To use a explicit ChannelGroup.
*
* The option is a: <code>io.netty.channel.group.ChannelGroup</code>
diff --git a/platforms/spring-boot/components-starter/camel-netty-starter/src/main/java/org/apache/camel/component/netty/springboot/NettyComponentConfiguration.java b/platforms/spring-boot/components-starter/camel-netty-starter/src/main/java/org/apache/camel/component/netty/springboot/NettyComponentConfiguration.java
index cebf1ce..82069c1 100644
--- a/platforms/spring-boot/components-starter/camel-netty-starter/src/main/java/org/apache/camel/component/netty/springboot/NettyComponentConfiguration.java
+++ b/platforms/spring-boot/components-starter/camel-netty-starter/src/main/java/org/apache/camel/component/netty/springboot/NettyComponentConfiguration.java
@@ -186,13 +186,11 @@ public class NettyComponentConfiguration
* A custom ChannelHandler class that can be used to perform special
* marshalling of outbound payloads.
*/
- @Deprecated
private ChannelHandler encoder;
/**
* A custom ChannelHandler class that can be used to perform special
* marshalling of inbound payloads.
*/
- @Deprecated
private ChannelHandler decoder;
/**
* Whether or not to disconnect(close) from Netty Channel right after
@@ -610,24 +608,18 @@ public class NettyComponentConfiguration
this.encoders = encoders;
}
- @Deprecated
- @DeprecatedConfigurationProperty
public ChannelHandler getEncoder() {
return encoder;
}
- @Deprecated
public void setEncoder(ChannelHandler encoder) {
this.encoder = encoder;
}
- @Deprecated
- @DeprecatedConfigurationProperty
public ChannelHandler getDecoder() {
return decoder;
}
- @Deprecated
public void setDecoder(ChannelHandler decoder) {
this.decoder = decoder;
}
[camel] 04/05: CAMEL-13870: Fast property configuration of Camel
endpoints. Work in progress.
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch CAMEL-13870
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 676ea6b21ab4e4a86e40a63d413d24f7794b6166
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Wed Aug 21 06:42:27 2019 +0200
CAMEL-13870: Fast property configuration of Camel endpoints. Work in progress.
---
.../apache/camel/component/grpc/GrpcEndpoint.java | 4 +
.../main/docs/hazelcast-atomicvalue-component.adoc | 8 +-
.../main/docs/hazelcast-instance-component.adoc | 11 +-
.../src/main/docs/hazelcast-list-component.adoc | 11 +-
.../src/main/docs/hazelcast-map-component.adoc | 11 +-
.../main/docs/hazelcast-multimap-component.adoc | 11 +-
.../src/main/docs/hazelcast-queue-component.adoc | 8 +-
.../docs/hazelcast-replicatedmap-component.adoc | 11 +-
.../main/docs/hazelcast-ringbuffer-component.adoc | 8 +-
.../src/main/docs/hazelcast-seda-component.adoc | 6 +-
.../src/main/docs/hazelcast-set-component.adoc | 11 +-
.../src/main/docs/hazelcast-topic-component.adoc | 10 +-
.../hazelcast/HazelcastDefaultEndpoint.java | 6 -
.../hazelcast/queue/HazelcastQueueEndpoint.java | 8 +-
.../hazelcast/seda/HazelcastSedaEndpoint.java | 3 +
.../hazelcast/topic/HazelcastTopicEndpoint.java | 6 +
...azelcastAtomicnumberEndpointBuilderFactory.java | 155 ------
.../HazelcastInstanceEndpointBuilderFactory.java | 160 ------
.../dsl/HazelcastListEndpointBuilderFactory.java | 541 --------------------
.../dsl/HazelcastMapEndpointBuilderFactory.java | 539 --------------------
.../HazelcastMultimapEndpointBuilderFactory.java | 549 --------------------
.../dsl/HazelcastQueueEndpointBuilderFactory.java | 462 -----------------
...zelcastReplicatedmapEndpointBuilderFactory.java | 555 ---------------------
.../HazelcastRingbufferEndpointBuilderFactory.java | 152 ------
.../dsl/HazelcastSedaEndpointBuilderFactory.java | 147 ------
.../dsl/HazelcastSetEndpointBuilderFactory.java | 539 --------------------
.../dsl/HazelcastTopicEndpointBuilderFactory.java | 477 ------------------
27 files changed, 31 insertions(+), 4378 deletions(-)
diff --git a/components/camel-grpc/src/main/java/org/apache/camel/component/grpc/GrpcEndpoint.java b/components/camel-grpc/src/main/java/org/apache/camel/component/grpc/GrpcEndpoint.java
index 31fdc04..e15dad0 100644
--- a/components/camel-grpc/src/main/java/org/apache/camel/component/grpc/GrpcEndpoint.java
+++ b/components/camel-grpc/src/main/java/org/apache/camel/component/grpc/GrpcEndpoint.java
@@ -51,6 +51,10 @@ public class GrpcEndpoint extends DefaultEndpoint {
}
}
+ public GrpcConfiguration getConfiguration() {
+ return configuration;
+ }
+
@Override
public Producer createProducer() throws Exception {
GrpcProducer producer = new GrpcProducer(this, configuration);
diff --git a/components/camel-hazelcast/src/main/docs/hazelcast-atomicvalue-component.adoc b/components/camel-hazelcast/src/main/docs/hazelcast-atomicvalue-component.adoc
index d9908ba..3819c9f 100644
--- a/components/camel-hazelcast/src/main/docs/hazelcast-atomicvalue-component.adoc
+++ b/components/camel-hazelcast/src/main/docs/hazelcast-atomicvalue-component.adoc
@@ -44,24 +44,18 @@ with the following path and query parameters:
|===
-=== Query Parameters (12 parameters):
+=== Query Parameters (6 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
-| *reliable* (common) | Define if the endpoint will use a reliable Topic struct or not. | false | boolean
| *defaultOperation* (producer) | To specify a default operation to use, if no operation header has been provided. | | HazelcastOperation
| *hazelcastInstance* (producer) | The hazelcast instance reference which can be used for hazelcast endpoint. | | HazelcastInstance
| *hazelcastInstanceName* (producer) | The hazelcast instance reference name which can be used for hazelcast endpoint. If you don't specify the instance reference, camel use the default hazelcast instance from the camel-hazelcast instance. | | String
| *lazyStartProducer* (producer) | Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and [...]
| *basicPropertyBinding* (advanced) | Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities | false | boolean
| *synchronous* (advanced) | Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). | false | boolean
-| *concurrentConsumers* (seda) | To use concurrent consumers polling from the SEDA queue. | 1 | int
-| *onErrorDelay* (seda) | Milliseconds before consumer continues polling after an error has occurred. | 1000 | int
-| *pollTimeout* (seda) | The timeout used when consuming from the SEDA queue. When a timeout occurs, the consumer can check whether it is allowed to continue running. Setting a lower value allows the consumer to react more quickly upon shutdown. | 1000 | int
-| *transacted* (seda) | If set to true then the consumer runs in transaction mode, where the messages in the seda queue will only be removed if the transaction commits, which happens when the processing is complete. | false | boolean
-| *transferExchange* (seda) | If set to true the whole Exchange will be transfered. If header or body contains not serializable objects, they will be skipped. | false | boolean
|===
// endpoint options: END
// spring-boot-auto-configure options: START
diff --git a/components/camel-hazelcast/src/main/docs/hazelcast-instance-component.adoc b/components/camel-hazelcast/src/main/docs/hazelcast-instance-component.adoc
index 2e36e3c..1c75eab 100644
--- a/components/camel-hazelcast/src/main/docs/hazelcast-instance-component.adoc
+++ b/components/camel-hazelcast/src/main/docs/hazelcast-instance-component.adoc
@@ -43,29 +43,20 @@ with the following path and query parameters:
|===
-=== Query Parameters (17 parameters):
+=== Query Parameters (8 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
-| *reliable* (common) | Define if the endpoint will use a reliable Topic struct or not. | false | boolean
| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored. | false | boolean
| *defaultOperation* (consumer) | To specify a default operation to use, if no operation header has been provided. | | HazelcastOperation
| *hazelcastInstance* (consumer) | The hazelcast instance reference which can be used for hazelcast endpoint. | | HazelcastInstance
| *hazelcastInstanceName* (consumer) | The hazelcast instance reference name which can be used for hazelcast endpoint. If you don't specify the instance reference, camel use the default hazelcast instance from the camel-hazelcast instance. | | String
-| *pollingTimeout* (consumer) | Define the polling timeout of the Queue consumer in Poll mode | 10000 | long
-| *poolSize* (consumer) | Define the Pool size for Queue Consumer Executor | 1 | int
-| *queueConsumerMode* (consumer) | Define the Queue Consumer mode: Listen or Poll | Listen | HazelcastQueueConsumer Mode
| *exceptionHandler* (consumer) | To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
| *exchangePattern* (consumer) | Sets the exchange pattern when the consumer creates an exchange. | | ExchangePattern
| *basicPropertyBinding* (advanced) | Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities | false | boolean
| *synchronous* (advanced) | Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). | false | boolean
-| *concurrentConsumers* (seda) | To use concurrent consumers polling from the SEDA queue. | 1 | int
-| *onErrorDelay* (seda) | Milliseconds before consumer continues polling after an error has occurred. | 1000 | int
-| *pollTimeout* (seda) | The timeout used when consuming from the SEDA queue. When a timeout occurs, the consumer can check whether it is allowed to continue running. Setting a lower value allows the consumer to react more quickly upon shutdown. | 1000 | int
-| *transacted* (seda) | If set to true then the consumer runs in transaction mode, where the messages in the seda queue will only be removed if the transaction commits, which happens when the processing is complete. | false | boolean
-| *transferExchange* (seda) | If set to true the whole Exchange will be transfered. If header or body contains not serializable objects, they will be skipped. | false | boolean
|===
// endpoint options: END
// spring-boot-auto-configure options: START
diff --git a/components/camel-hazelcast/src/main/docs/hazelcast-list-component.adoc b/components/camel-hazelcast/src/main/docs/hazelcast-list-component.adoc
index 13289a7..39915b9 100644
--- a/components/camel-hazelcast/src/main/docs/hazelcast-list-component.adoc
+++ b/components/camel-hazelcast/src/main/docs/hazelcast-list-component.adoc
@@ -39,7 +39,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (18 parameters):
+=== Query Parameters (9 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -48,21 +48,12 @@ with the following path and query parameters:
| *defaultOperation* (common) | To specify a default operation to use, if no operation header has been provided. | | HazelcastOperation
| *hazelcastInstance* (common) | The hazelcast instance reference which can be used for hazelcast endpoint. | | HazelcastInstance
| *hazelcastInstanceName* (common) | The hazelcast instance reference name which can be used for hazelcast endpoint. If you don't specify the instance reference, camel use the default hazelcast instance from the camel-hazelcast instance. | | String
-| *reliable* (common) | Define if the endpoint will use a reliable Topic struct or not. | false | boolean
| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored. | false | boolean
-| *pollingTimeout* (consumer) | Define the polling timeout of the Queue consumer in Poll mode | 10000 | long
-| *poolSize* (consumer) | Define the Pool size for Queue Consumer Executor | 1 | int
-| *queueConsumerMode* (consumer) | Define the Queue Consumer mode: Listen or Poll | Listen | HazelcastQueueConsumer Mode
| *exceptionHandler* (consumer) | To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
| *exchangePattern* (consumer) | Sets the exchange pattern when the consumer creates an exchange. | | ExchangePattern
| *lazyStartProducer* (producer) | Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and [...]
| *basicPropertyBinding* (advanced) | Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities | false | boolean
| *synchronous* (advanced) | Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). | false | boolean
-| *concurrentConsumers* (seda) | To use concurrent consumers polling from the SEDA queue. | 1 | int
-| *onErrorDelay* (seda) | Milliseconds before consumer continues polling after an error has occurred. | 1000 | int
-| *pollTimeout* (seda) | The timeout used when consuming from the SEDA queue. When a timeout occurs, the consumer can check whether it is allowed to continue running. Setting a lower value allows the consumer to react more quickly upon shutdown. | 1000 | int
-| *transacted* (seda) | If set to true then the consumer runs in transaction mode, where the messages in the seda queue will only be removed if the transaction commits, which happens when the processing is complete. | false | boolean
-| *transferExchange* (seda) | If set to true the whole Exchange will be transfered. If header or body contains not serializable objects, they will be skipped. | false | boolean
|===
// endpoint options: END
// spring-boot-auto-configure options: START
diff --git a/components/camel-hazelcast/src/main/docs/hazelcast-map-component.adoc b/components/camel-hazelcast/src/main/docs/hazelcast-map-component.adoc
index 81f7e96..14ef52b 100644
--- a/components/camel-hazelcast/src/main/docs/hazelcast-map-component.adoc
+++ b/components/camel-hazelcast/src/main/docs/hazelcast-map-component.adoc
@@ -40,7 +40,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (18 parameters):
+=== Query Parameters (9 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -49,21 +49,12 @@ with the following path and query parameters:
| *defaultOperation* (common) | To specify a default operation to use, if no operation header has been provided. | | HazelcastOperation
| *hazelcastInstance* (common) | The hazelcast instance reference which can be used for hazelcast endpoint. | | HazelcastInstance
| *hazelcastInstanceName* (common) | The hazelcast instance reference name which can be used for hazelcast endpoint. If you don't specify the instance reference, camel use the default hazelcast instance from the camel-hazelcast instance. | | String
-| *reliable* (common) | Define if the endpoint will use a reliable Topic struct or not. | false | boolean
| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored. | false | boolean
-| *pollingTimeout* (consumer) | Define the polling timeout of the Queue consumer in Poll mode | 10000 | long
-| *poolSize* (consumer) | Define the Pool size for Queue Consumer Executor | 1 | int
-| *queueConsumerMode* (consumer) | Define the Queue Consumer mode: Listen or Poll | Listen | HazelcastQueueConsumer Mode
| *exceptionHandler* (consumer) | To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
| *exchangePattern* (consumer) | Sets the exchange pattern when the consumer creates an exchange. | | ExchangePattern
| *lazyStartProducer* (producer) | Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and [...]
| *basicPropertyBinding* (advanced) | Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities | false | boolean
| *synchronous* (advanced) | Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). | false | boolean
-| *concurrentConsumers* (seda) | To use concurrent consumers polling from the SEDA queue. | 1 | int
-| *onErrorDelay* (seda) | Milliseconds before consumer continues polling after an error has occurred. | 1000 | int
-| *pollTimeout* (seda) | The timeout used when consuming from the SEDA queue. When a timeout occurs, the consumer can check whether it is allowed to continue running. Setting a lower value allows the consumer to react more quickly upon shutdown. | 1000 | int
-| *transacted* (seda) | If set to true then the consumer runs in transaction mode, where the messages in the seda queue will only be removed if the transaction commits, which happens when the processing is complete. | false | boolean
-| *transferExchange* (seda) | If set to true the whole Exchange will be transfered. If header or body contains not serializable objects, they will be skipped. | false | boolean
|===
// endpoint options: END
// spring-boot-auto-configure options: START
diff --git a/components/camel-hazelcast/src/main/docs/hazelcast-multimap-component.adoc b/components/camel-hazelcast/src/main/docs/hazelcast-multimap-component.adoc
index 1971f0f..52f9654 100644
--- a/components/camel-hazelcast/src/main/docs/hazelcast-multimap-component.adoc
+++ b/components/camel-hazelcast/src/main/docs/hazelcast-multimap-component.adoc
@@ -41,7 +41,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (18 parameters):
+=== Query Parameters (9 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -50,21 +50,12 @@ with the following path and query parameters:
| *defaultOperation* (common) | To specify a default operation to use, if no operation header has been provided. | | HazelcastOperation
| *hazelcastInstance* (common) | The hazelcast instance reference which can be used for hazelcast endpoint. | | HazelcastInstance
| *hazelcastInstanceName* (common) | The hazelcast instance reference name which can be used for hazelcast endpoint. If you don't specify the instance reference, camel use the default hazelcast instance from the camel-hazelcast instance. | | String
-| *reliable* (common) | Define if the endpoint will use a reliable Topic struct or not. | false | boolean
| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored. | false | boolean
-| *pollingTimeout* (consumer) | Define the polling timeout of the Queue consumer in Poll mode | 10000 | long
-| *poolSize* (consumer) | Define the Pool size for Queue Consumer Executor | 1 | int
-| *queueConsumerMode* (consumer) | Define the Queue Consumer mode: Listen or Poll | Listen | HazelcastQueueConsumer Mode
| *exceptionHandler* (consumer) | To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
| *exchangePattern* (consumer) | Sets the exchange pattern when the consumer creates an exchange. | | ExchangePattern
| *lazyStartProducer* (producer) | Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and [...]
| *basicPropertyBinding* (advanced) | Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities | false | boolean
| *synchronous* (advanced) | Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). | false | boolean
-| *concurrentConsumers* (seda) | To use concurrent consumers polling from the SEDA queue. | 1 | int
-| *onErrorDelay* (seda) | Milliseconds before consumer continues polling after an error has occurred. | 1000 | int
-| *pollTimeout* (seda) | The timeout used when consuming from the SEDA queue. When a timeout occurs, the consumer can check whether it is allowed to continue running. Setting a lower value allows the consumer to react more quickly upon shutdown. | 1000 | int
-| *transacted* (seda) | If set to true then the consumer runs in transaction mode, where the messages in the seda queue will only be removed if the transaction commits, which happens when the processing is complete. | false | boolean
-| *transferExchange* (seda) | If set to true the whole Exchange will be transfered. If header or body contains not serializable objects, they will be skipped. | false | boolean
|===
// endpoint options: END
// spring-boot-auto-configure options: START
diff --git a/components/camel-hazelcast/src/main/docs/hazelcast-queue-component.adoc b/components/camel-hazelcast/src/main/docs/hazelcast-queue-component.adoc
index fb22502..df41f41 100644
--- a/components/camel-hazelcast/src/main/docs/hazelcast-queue-component.adoc
+++ b/components/camel-hazelcast/src/main/docs/hazelcast-queue-component.adoc
@@ -40,7 +40,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (18 parameters):
+=== Query Parameters (12 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -49,7 +49,6 @@ with the following path and query parameters:
| *defaultOperation* (common) | To specify a default operation to use, if no operation header has been provided. | | HazelcastOperation
| *hazelcastInstance* (common) | The hazelcast instance reference which can be used for hazelcast endpoint. | | HazelcastInstance
| *hazelcastInstanceName* (common) | The hazelcast instance reference name which can be used for hazelcast endpoint. If you don't specify the instance reference, camel use the default hazelcast instance from the camel-hazelcast instance. | | String
-| *reliable* (common) | Define if the endpoint will use a reliable Topic struct or not. | false | boolean
| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored. | false | boolean
| *pollingTimeout* (consumer) | Define the polling timeout of the Queue consumer in Poll mode | 10000 | long
| *poolSize* (consumer) | Define the Pool size for Queue Consumer Executor | 1 | int
@@ -59,11 +58,6 @@ with the following path and query parameters:
| *lazyStartProducer* (producer) | Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and [...]
| *basicPropertyBinding* (advanced) | Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities | false | boolean
| *synchronous* (advanced) | Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). | false | boolean
-| *concurrentConsumers* (seda) | To use concurrent consumers polling from the SEDA queue. | 1 | int
-| *onErrorDelay* (seda) | Milliseconds before consumer continues polling after an error has occurred. | 1000 | int
-| *pollTimeout* (seda) | The timeout used when consuming from the SEDA queue. When a timeout occurs, the consumer can check whether it is allowed to continue running. Setting a lower value allows the consumer to react more quickly upon shutdown. | 1000 | int
-| *transacted* (seda) | If set to true then the consumer runs in transaction mode, where the messages in the seda queue will only be removed if the transaction commits, which happens when the processing is complete. | false | boolean
-| *transferExchange* (seda) | If set to true the whole Exchange will be transfered. If header or body contains not serializable objects, they will be skipped. | false | boolean
|===
// endpoint options: END
// spring-boot-auto-configure options: START
diff --git a/components/camel-hazelcast/src/main/docs/hazelcast-replicatedmap-component.adoc b/components/camel-hazelcast/src/main/docs/hazelcast-replicatedmap-component.adoc
index 3b3344b..cb3b8a4 100644
--- a/components/camel-hazelcast/src/main/docs/hazelcast-replicatedmap-component.adoc
+++ b/components/camel-hazelcast/src/main/docs/hazelcast-replicatedmap-component.adoc
@@ -41,7 +41,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (18 parameters):
+=== Query Parameters (9 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -50,21 +50,12 @@ with the following path and query parameters:
| *defaultOperation* (common) | To specify a default operation to use, if no operation header has been provided. | | HazelcastOperation
| *hazelcastInstance* (common) | The hazelcast instance reference which can be used for hazelcast endpoint. | | HazelcastInstance
| *hazelcastInstanceName* (common) | The hazelcast instance reference name which can be used for hazelcast endpoint. If you don't specify the instance reference, camel use the default hazelcast instance from the camel-hazelcast instance. | | String
-| *reliable* (common) | Define if the endpoint will use a reliable Topic struct or not. | false | boolean
| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored. | false | boolean
-| *pollingTimeout* (consumer) | Define the polling timeout of the Queue consumer in Poll mode | 10000 | long
-| *poolSize* (consumer) | Define the Pool size for Queue Consumer Executor | 1 | int
-| *queueConsumerMode* (consumer) | Define the Queue Consumer mode: Listen or Poll | Listen | HazelcastQueueConsumer Mode
| *exceptionHandler* (consumer) | To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
| *exchangePattern* (consumer) | Sets the exchange pattern when the consumer creates an exchange. | | ExchangePattern
| *lazyStartProducer* (producer) | Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and [...]
| *basicPropertyBinding* (advanced) | Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities | false | boolean
| *synchronous* (advanced) | Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). | false | boolean
-| *concurrentConsumers* (seda) | To use concurrent consumers polling from the SEDA queue. | 1 | int
-| *onErrorDelay* (seda) | Milliseconds before consumer continues polling after an error has occurred. | 1000 | int
-| *pollTimeout* (seda) | The timeout used when consuming from the SEDA queue. When a timeout occurs, the consumer can check whether it is allowed to continue running. Setting a lower value allows the consumer to react more quickly upon shutdown. | 1000 | int
-| *transacted* (seda) | If set to true then the consumer runs in transaction mode, where the messages in the seda queue will only be removed if the transaction commits, which happens when the processing is complete. | false | boolean
-| *transferExchange* (seda) | If set to true the whole Exchange will be transfered. If header or body contains not serializable objects, they will be skipped. | false | boolean
|===
// endpoint options: END
// spring-boot-auto-configure options: START
diff --git a/components/camel-hazelcast/src/main/docs/hazelcast-ringbuffer-component.adoc b/components/camel-hazelcast/src/main/docs/hazelcast-ringbuffer-component.adoc
index dc9b3ba..d1d65af3 100644
--- a/components/camel-hazelcast/src/main/docs/hazelcast-ringbuffer-component.adoc
+++ b/components/camel-hazelcast/src/main/docs/hazelcast-ringbuffer-component.adoc
@@ -41,24 +41,18 @@ with the following path and query parameters:
|===
-=== Query Parameters (12 parameters):
+=== Query Parameters (6 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
-| *reliable* (common) | Define if the endpoint will use a reliable Topic struct or not. | false | boolean
| *defaultOperation* (producer) | To specify a default operation to use, if no operation header has been provided. | | HazelcastOperation
| *hazelcastInstance* (producer) | The hazelcast instance reference which can be used for hazelcast endpoint. | | HazelcastInstance
| *hazelcastInstanceName* (producer) | The hazelcast instance reference name which can be used for hazelcast endpoint. If you don't specify the instance reference, camel use the default hazelcast instance from the camel-hazelcast instance. | | String
| *lazyStartProducer* (producer) | Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and [...]
| *basicPropertyBinding* (advanced) | Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities | false | boolean
| *synchronous* (advanced) | Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). | false | boolean
-| *concurrentConsumers* (seda) | To use concurrent consumers polling from the SEDA queue. | 1 | int
-| *onErrorDelay* (seda) | Milliseconds before consumer continues polling after an error has occurred. | 1000 | int
-| *pollTimeout* (seda) | The timeout used when consuming from the SEDA queue. When a timeout occurs, the consumer can check whether it is allowed to continue running. Setting a lower value allows the consumer to react more quickly upon shutdown. | 1000 | int
-| *transacted* (seda) | If set to true then the consumer runs in transaction mode, where the messages in the seda queue will only be removed if the transaction commits, which happens when the processing is complete. | false | boolean
-| *transferExchange* (seda) | If set to true the whole Exchange will be transfered. If header or body contains not serializable objects, they will be skipped. | false | boolean
|===
// endpoint options: END
// spring-boot-auto-configure options: START
diff --git a/components/camel-hazelcast/src/main/docs/hazelcast-seda-component.adoc b/components/camel-hazelcast/src/main/docs/hazelcast-seda-component.adoc
index e70800e..ac19543 100644
--- a/components/camel-hazelcast/src/main/docs/hazelcast-seda-component.adoc
+++ b/components/camel-hazelcast/src/main/docs/hazelcast-seda-component.adoc
@@ -41,7 +41,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (18 parameters):
+=== Query Parameters (14 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -50,11 +50,7 @@ with the following path and query parameters:
| *defaultOperation* (common) | To specify a default operation to use, if no operation header has been provided. | | HazelcastOperation
| *hazelcastInstance* (common) | The hazelcast instance reference which can be used for hazelcast endpoint. | | HazelcastInstance
| *hazelcastInstanceName* (common) | The hazelcast instance reference name which can be used for hazelcast endpoint. If you don't specify the instance reference, camel use the default hazelcast instance from the camel-hazelcast instance. | | String
-| *reliable* (common) | Define if the endpoint will use a reliable Topic struct or not. | false | boolean
| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored. | false | boolean
-| *pollingTimeout* (consumer) | Define the polling timeout of the Queue consumer in Poll mode | 10000 | long
-| *poolSize* (consumer) | Define the Pool size for Queue Consumer Executor | 1 | int
-| *queueConsumerMode* (consumer) | Define the Queue Consumer mode: Listen or Poll | Listen | HazelcastQueueConsumer Mode
| *exceptionHandler* (consumer) | To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
| *exchangePattern* (consumer) | Sets the exchange pattern when the consumer creates an exchange. | | ExchangePattern
| *lazyStartProducer* (producer) | Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and [...]
diff --git a/components/camel-hazelcast/src/main/docs/hazelcast-set-component.adoc b/components/camel-hazelcast/src/main/docs/hazelcast-set-component.adoc
index 07d69d7..fe5fef9 100644
--- a/components/camel-hazelcast/src/main/docs/hazelcast-set-component.adoc
+++ b/components/camel-hazelcast/src/main/docs/hazelcast-set-component.adoc
@@ -40,7 +40,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (18 parameters):
+=== Query Parameters (9 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -49,21 +49,12 @@ with the following path and query parameters:
| *defaultOperation* (common) | To specify a default operation to use, if no operation header has been provided. | | HazelcastOperation
| *hazelcastInstance* (common) | The hazelcast instance reference which can be used for hazelcast endpoint. | | HazelcastInstance
| *hazelcastInstanceName* (common) | The hazelcast instance reference name which can be used for hazelcast endpoint. If you don't specify the instance reference, camel use the default hazelcast instance from the camel-hazelcast instance. | | String
-| *reliable* (common) | Define if the endpoint will use a reliable Topic struct or not. | false | boolean
| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored. | false | boolean
-| *pollingTimeout* (consumer) | Define the polling timeout of the Queue consumer in Poll mode | 10000 | long
-| *poolSize* (consumer) | Define the Pool size for Queue Consumer Executor | 1 | int
-| *queueConsumerMode* (consumer) | Define the Queue Consumer mode: Listen or Poll | Listen | HazelcastQueueConsumer Mode
| *exceptionHandler* (consumer) | To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
| *exchangePattern* (consumer) | Sets the exchange pattern when the consumer creates an exchange. | | ExchangePattern
| *lazyStartProducer* (producer) | Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and [...]
| *basicPropertyBinding* (advanced) | Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities | false | boolean
| *synchronous* (advanced) | Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). | false | boolean
-| *concurrentConsumers* (seda) | To use concurrent consumers polling from the SEDA queue. | 1 | int
-| *onErrorDelay* (seda) | Milliseconds before consumer continues polling after an error has occurred. | 1000 | int
-| *pollTimeout* (seda) | The timeout used when consuming from the SEDA queue. When a timeout occurs, the consumer can check whether it is allowed to continue running. Setting a lower value allows the consumer to react more quickly upon shutdown. | 1000 | int
-| *transacted* (seda) | If set to true then the consumer runs in transaction mode, where the messages in the seda queue will only be removed if the transaction commits, which happens when the processing is complete. | false | boolean
-| *transferExchange* (seda) | If set to true the whole Exchange will be transfered. If header or body contains not serializable objects, they will be skipped. | false | boolean
|===
// endpoint options: END
// spring-boot-auto-configure options: START
diff --git a/components/camel-hazelcast/src/main/docs/hazelcast-topic-component.adoc b/components/camel-hazelcast/src/main/docs/hazelcast-topic-component.adoc
index f5e72c2..028a9cc 100644
--- a/components/camel-hazelcast/src/main/docs/hazelcast-topic-component.adoc
+++ b/components/camel-hazelcast/src/main/docs/hazelcast-topic-component.adoc
@@ -40,7 +40,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (18 parameters):
+=== Query Parameters (10 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -51,19 +51,11 @@ with the following path and query parameters:
| *hazelcastInstanceName* (common) | The hazelcast instance reference name which can be used for hazelcast endpoint. If you don't specify the instance reference, camel use the default hazelcast instance from the camel-hazelcast instance. | | String
| *reliable* (common) | Define if the endpoint will use a reliable Topic struct or not. | false | boolean
| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored. | false | boolean
-| *pollingTimeout* (consumer) | Define the polling timeout of the Queue consumer in Poll mode | 10000 | long
-| *poolSize* (consumer) | Define the Pool size for Queue Consumer Executor | 1 | int
-| *queueConsumerMode* (consumer) | Define the Queue Consumer mode: Listen or Poll | Listen | HazelcastQueueConsumer Mode
| *exceptionHandler* (consumer) | To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
| *exchangePattern* (consumer) | Sets the exchange pattern when the consumer creates an exchange. | | ExchangePattern
| *lazyStartProducer* (producer) | Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and [...]
| *basicPropertyBinding* (advanced) | Whether the endpoint should use basic property binding (Camel 2.x) or the newer property binding with additional capabilities | false | boolean
| *synchronous* (advanced) | Sets whether synchronous processing should be strictly used, or Camel is allowed to use asynchronous processing (if supported). | false | boolean
-| *concurrentConsumers* (seda) | To use concurrent consumers polling from the SEDA queue. | 1 | int
-| *onErrorDelay* (seda) | Milliseconds before consumer continues polling after an error has occurred. | 1000 | int
-| *pollTimeout* (seda) | The timeout used when consuming from the SEDA queue. When a timeout occurs, the consumer can check whether it is allowed to continue running. Setting a lower value allows the consumer to react more quickly upon shutdown. | 1000 | int
-| *transacted* (seda) | If set to true then the consumer runs in transaction mode, where the messages in the seda queue will only be removed if the transaction commits, which happens when the processing is complete. | false | boolean
-| *transferExchange* (seda) | If set to true the whole Exchange will be transfered. If header or body contains not serializable objects, they will be skipped. | false | boolean
|===
// endpoint options: END
// spring-boot-auto-configure options: START
diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastDefaultEndpoint.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastDefaultEndpoint.java
index 972688e..1560e66 100644
--- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastDefaultEndpoint.java
+++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastDefaultEndpoint.java
@@ -43,12 +43,6 @@ public abstract class HazelcastDefaultEndpoint extends DefaultEndpoint {
protected String hazelcastInstanceName;
@UriParam
private HazelcastOperation defaultOperation;
- @UriParam
- private HazelcastSedaConfiguration hazelcastSedaConfiguration; // to include component schema docs
- @UriParam
- private HazelcastTopicConfiguration hazelcastTopicConfiguration;
- @UriParam
- private HazelcastQueueConfiguration hazelcastQueueConfiguration;
public HazelcastDefaultEndpoint(HazelcastInstance hazelcastInstance, String endpointUri, Component component) {
this(hazelcastInstance, endpointUri, component, null);
diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueEndpoint.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueEndpoint.java
index d1a9241..7629262 100644
--- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueEndpoint.java
+++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueEndpoint.java
@@ -28,13 +28,15 @@ import org.apache.camel.component.hazelcast.HazelcastCommand;
import org.apache.camel.component.hazelcast.HazelcastDefaultEndpoint;
import org.apache.camel.component.hazelcast.HazelcastOperation;
import org.apache.camel.spi.UriEndpoint;
+import org.apache.camel.spi.UriParam;
/**
* The hazelcast-queue component is used to access <a href="http://www.hazelcast.com/">Hazelcast</a> distributed queue.
*/
@UriEndpoint(firstVersion = "2.7.0", scheme = "hazelcast-queue", title = "Hazelcast Queue", syntax = "hazelcast-queue:cacheName", label = "cache,datagrid")
public class HazelcastQueueEndpoint extends HazelcastDefaultEndpoint {
-
+
+ @UriParam
private final HazelcastQueueConfiguration configuration;
public HazelcastQueueEndpoint(HazelcastInstance hazelcastInstance, String endpointUri, Component component, String cacheName, final HazelcastQueueConfiguration configuration) {
@@ -44,6 +46,10 @@ public class HazelcastQueueEndpoint extends HazelcastDefaultEndpoint {
setDefaultOperation(HazelcastOperation.ADD);
}
+ public HazelcastQueueConfiguration getConfiguration() {
+ return configuration;
+ }
+
@Override
public Consumer createConsumer(Processor processor) throws Exception {
HazelcastQueueConsumer answer = new HazelcastQueueConsumer(hazelcastInstance, this, processor, cacheName, configuration);
diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaEndpoint.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaEndpoint.java
index bb95a74..c648aa4 100644
--- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaEndpoint.java
+++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaEndpoint.java
@@ -26,6 +26,7 @@ import org.apache.camel.component.hazelcast.HazelcastCommand;
import org.apache.camel.component.hazelcast.HazelcastDefaultComponent;
import org.apache.camel.component.hazelcast.HazelcastDefaultEndpoint;
import org.apache.camel.spi.UriEndpoint;
+import org.apache.camel.spi.UriParam;
import org.apache.camel.util.ObjectHelper;
/**
@@ -35,6 +36,8 @@ import org.apache.camel.util.ObjectHelper;
public class HazelcastSedaEndpoint extends HazelcastDefaultEndpoint {
private final BlockingQueue<Object> queue;
+
+ @UriParam
private final HazelcastSedaConfiguration configuration;
public HazelcastSedaEndpoint(final HazelcastInstance hazelcastInstance, final String uri, final HazelcastDefaultComponent component, final HazelcastSedaConfiguration configuration) {
diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/topic/HazelcastTopicEndpoint.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/topic/HazelcastTopicEndpoint.java
index 50eb1b5..a526a3c 100644
--- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/topic/HazelcastTopicEndpoint.java
+++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/topic/HazelcastTopicEndpoint.java
@@ -26,6 +26,7 @@ import org.apache.camel.component.hazelcast.HazelcastCommand;
import org.apache.camel.component.hazelcast.HazelcastDefaultEndpoint;
import org.apache.camel.component.hazelcast.HazelcastOperation;
import org.apache.camel.spi.UriEndpoint;
+import org.apache.camel.spi.UriParam;
/**
* The hazelcast-topic component is used to access <a href="http://www.hazelcast.com/">Hazelcast</a> distributed topic.
@@ -33,6 +34,7 @@ import org.apache.camel.spi.UriEndpoint;
@UriEndpoint(firstVersion = "2.15.0", scheme = "hazelcast-topic", title = "Hazelcast Topic", syntax = "hazelcast-topic:cacheName", label = "cache,datagrid")
public class HazelcastTopicEndpoint extends HazelcastDefaultEndpoint implements MultipleConsumersSupport {
+ @UriParam
private final HazelcastTopicConfiguration configuration;
public HazelcastTopicEndpoint(HazelcastInstance hazelcastInstance, String endpointUri, Component component, String cacheName, final HazelcastTopicConfiguration configuration) {
@@ -42,6 +44,10 @@ public class HazelcastTopicEndpoint extends HazelcastDefaultEndpoint implements
setDefaultOperation(HazelcastOperation.PUBLISH);
}
+ public HazelcastTopicConfiguration getConfiguration() {
+ return configuration;
+ }
+
@Override
public Consumer createConsumer(Processor processor) throws Exception {
HazelcastTopicConsumer answer = new HazelcastTopicConsumer(hazelcastInstance, this, processor, cacheName, configuration.isReliable());
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 7e9aa36..d575483 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
@@ -41,28 +41,6 @@ public interface HazelcastAtomicnumberEndpointBuilderFactory {
return (AdvancedHazelcastAtomicnumberEndpointBuilder) this;
}
/**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastAtomicnumberEndpointBuilder reliable(boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastAtomicnumberEndpointBuilder reliable(String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
* To specify a default operation to use, if no operation header has
* been provided.
*
@@ -134,139 +112,6 @@ public interface HazelcastAtomicnumberEndpointBuilderFactory {
setProperty("hazelcastInstanceName", hazelcastInstanceName);
return this;
}
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastAtomicnumberEndpointBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastAtomicnumberEndpointBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastAtomicnumberEndpointBuilder onErrorDelay(
- int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastAtomicnumberEndpointBuilder onErrorDelay(
- String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastAtomicnumberEndpointBuilder pollTimeout(int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastAtomicnumberEndpointBuilder pollTimeout(
- String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastAtomicnumberEndpointBuilder transacted(
- boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastAtomicnumberEndpointBuilder transacted(
- String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastAtomicnumberEndpointBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastAtomicnumberEndpointBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
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 492e9bf..bde2e84 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
@@ -41,28 +41,6 @@ public interface HazelcastInstanceEndpointBuilderFactory {
return (AdvancedHazelcastInstanceEndpointBuilder) this;
}
/**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastInstanceEndpointBuilder reliable(boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastInstanceEndpointBuilder reliable(String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
* To specify a default operation to use, if no operation header has
* been provided.
*
@@ -134,135 +112,6 @@ public interface HazelcastInstanceEndpointBuilderFactory {
setProperty("hazelcastInstanceName", hazelcastInstanceName);
return this;
}
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastInstanceEndpointBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastInstanceEndpointBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastInstanceEndpointBuilder onErrorDelay(int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastInstanceEndpointBuilder onErrorDelay(
- String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastInstanceEndpointBuilder pollTimeout(int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastInstanceEndpointBuilder pollTimeout(String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastInstanceEndpointBuilder transacted(boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastInstanceEndpointBuilder transacted(String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastInstanceEndpointBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastInstanceEndpointBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
@@ -371,15 +220,6 @@ public interface HazelcastInstanceEndpointBuilderFactory {
readOnceTail,
capacity;
}
-
- /**
- * Proxy enum for
- * <code>org.apache.camel.component.hazelcast.queue.HazelcastQueueConsumerMode</code> enum.
- */
- enum HazelcastQueueConsumerMode {
- listen,
- poll;
- }
/**
* Hazelcast Instance (camel-hazelcast)
* 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 723ac7e..b82a1cb 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
@@ -114,28 +114,6 @@ public interface HazelcastListEndpointBuilderFactory {
return this;
}
/**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastListEndpointConsumerBuilder reliable(boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastListEndpointConsumerBuilder reliable(String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
* Allows for bridging the consumer to the Camel routing Error Handler,
* which mean any exceptions occurred while the consumer is trying to
* pickup incoming messages, or the likes, will now be processed as a
@@ -171,211 +149,6 @@ public interface HazelcastListEndpointBuilderFactory {
setProperty("bridgeErrorHandler", bridgeErrorHandler);
return this;
}
- /**
- * Define the polling timeout of the Queue consumer in Poll mode.
- *
- * The option is a: <code>long</code> type.
- *
- * Group: consumer
- */
- default HazelcastListEndpointConsumerBuilder pollingTimeout(
- long pollingTimeout) {
- setProperty("pollingTimeout", pollingTimeout);
- return this;
- }
- /**
- * Define the polling timeout of the Queue consumer in Poll mode.
- *
- * The option will be converted to a <code>long</code> type.
- *
- * Group: consumer
- */
- default HazelcastListEndpointConsumerBuilder pollingTimeout(
- String pollingTimeout) {
- setProperty("pollingTimeout", pollingTimeout);
- return this;
- }
- /**
- * Define the Pool size for Queue Consumer Executor.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: consumer
- */
- default HazelcastListEndpointConsumerBuilder poolSize(int poolSize) {
- setProperty("poolSize", poolSize);
- return this;
- }
- /**
- * Define the Pool size for Queue Consumer Executor.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: consumer
- */
- default HazelcastListEndpointConsumerBuilder poolSize(String poolSize) {
- setProperty("poolSize", poolSize);
- return this;
- }
- /**
- * Define the Queue Consumer mode: Listen or Poll.
- *
- * The option is a:
- * <code>org.apache.camel.component.hazelcast.queue.HazelcastQueueConsumerMode</code> type.
- *
- * Group: consumer
- */
- default HazelcastListEndpointConsumerBuilder queueConsumerMode(
- HazelcastQueueConsumerMode queueConsumerMode) {
- setProperty("queueConsumerMode", queueConsumerMode);
- return this;
- }
- /**
- * Define the Queue Consumer mode: Listen or Poll.
- *
- * The option will be converted to a
- * <code>org.apache.camel.component.hazelcast.queue.HazelcastQueueConsumerMode</code> type.
- *
- * Group: consumer
- */
- default HazelcastListEndpointConsumerBuilder queueConsumerMode(
- String queueConsumerMode) {
- setProperty("queueConsumerMode", queueConsumerMode);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointConsumerBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointConsumerBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointConsumerBuilder onErrorDelay(
- int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointConsumerBuilder onErrorDelay(
- String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointConsumerBuilder pollTimeout(int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointConsumerBuilder pollTimeout(
- String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointConsumerBuilder transacted(
- boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointConsumerBuilder transacted(
- String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointConsumerBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointConsumerBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
@@ -580,28 +353,6 @@ public interface HazelcastListEndpointBuilderFactory {
return this;
}
/**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastListEndpointProducerBuilder reliable(boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastListEndpointProducerBuilder reliable(String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
* Whether the producer should be started lazy (on the first message).
* By starting lazy you can use this to allow CamelContext and routes to
* startup in situations where a producer may otherwise fail during
@@ -641,139 +392,6 @@ public interface HazelcastListEndpointBuilderFactory {
setProperty("lazyStartProducer", lazyStartProducer);
return this;
}
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointProducerBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointProducerBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointProducerBuilder onErrorDelay(
- int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointProducerBuilder onErrorDelay(
- String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointProducerBuilder pollTimeout(int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointProducerBuilder pollTimeout(
- String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointProducerBuilder transacted(
- boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointProducerBuilder transacted(
- String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointProducerBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointProducerBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
@@ -920,156 +538,6 @@ public interface HazelcastListEndpointBuilderFactory {
setProperty("hazelcastInstanceName", hazelcastInstanceName);
return this;
}
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastListEndpointBuilder reliable(boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastListEndpointBuilder reliable(String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointBuilder onErrorDelay(int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointBuilder onErrorDelay(String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointBuilder pollTimeout(int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointBuilder pollTimeout(String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointBuilder transacted(boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointBuilder transacted(String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastListEndpointBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
@@ -1178,15 +646,6 @@ public interface HazelcastListEndpointBuilderFactory {
readOnceTail,
capacity;
}
-
- /**
- * Proxy enum for
- * <code>org.apache.camel.component.hazelcast.queue.HazelcastQueueConsumerMode</code> enum.
- */
- enum HazelcastQueueConsumerMode {
- listen,
- poll;
- }
/**
* Hazelcast List (camel-hazelcast)
* 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 34807a3..5320be2 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
@@ -114,28 +114,6 @@ public interface HazelcastMapEndpointBuilderFactory {
return this;
}
/**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastMapEndpointConsumerBuilder reliable(boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastMapEndpointConsumerBuilder reliable(String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
* Allows for bridging the consumer to the Camel routing Error Handler,
* which mean any exceptions occurred while the consumer is trying to
* pickup incoming messages, or the likes, will now be processed as a
@@ -171,210 +149,6 @@ public interface HazelcastMapEndpointBuilderFactory {
setProperty("bridgeErrorHandler", bridgeErrorHandler);
return this;
}
- /**
- * Define the polling timeout of the Queue consumer in Poll mode.
- *
- * The option is a: <code>long</code> type.
- *
- * Group: consumer
- */
- default HazelcastMapEndpointConsumerBuilder pollingTimeout(
- long pollingTimeout) {
- setProperty("pollingTimeout", pollingTimeout);
- return this;
- }
- /**
- * Define the polling timeout of the Queue consumer in Poll mode.
- *
- * The option will be converted to a <code>long</code> type.
- *
- * Group: consumer
- */
- default HazelcastMapEndpointConsumerBuilder pollingTimeout(
- String pollingTimeout) {
- setProperty("pollingTimeout", pollingTimeout);
- return this;
- }
- /**
- * Define the Pool size for Queue Consumer Executor.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: consumer
- */
- default HazelcastMapEndpointConsumerBuilder poolSize(int poolSize) {
- setProperty("poolSize", poolSize);
- return this;
- }
- /**
- * Define the Pool size for Queue Consumer Executor.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: consumer
- */
- default HazelcastMapEndpointConsumerBuilder poolSize(String poolSize) {
- setProperty("poolSize", poolSize);
- return this;
- }
- /**
- * Define the Queue Consumer mode: Listen or Poll.
- *
- * The option is a:
- * <code>org.apache.camel.component.hazelcast.queue.HazelcastQueueConsumerMode</code> type.
- *
- * Group: consumer
- */
- default HazelcastMapEndpointConsumerBuilder queueConsumerMode(
- HazelcastQueueConsumerMode queueConsumerMode) {
- setProperty("queueConsumerMode", queueConsumerMode);
- return this;
- }
- /**
- * Define the Queue Consumer mode: Listen or Poll.
- *
- * The option will be converted to a
- * <code>org.apache.camel.component.hazelcast.queue.HazelcastQueueConsumerMode</code> type.
- *
- * Group: consumer
- */
- default HazelcastMapEndpointConsumerBuilder queueConsumerMode(
- String queueConsumerMode) {
- setProperty("queueConsumerMode", queueConsumerMode);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointConsumerBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointConsumerBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointConsumerBuilder onErrorDelay(
- int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointConsumerBuilder onErrorDelay(
- String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointConsumerBuilder pollTimeout(int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointConsumerBuilder pollTimeout(
- String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointConsumerBuilder transacted(
- boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointConsumerBuilder transacted(String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointConsumerBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointConsumerBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
@@ -579,28 +353,6 @@ public interface HazelcastMapEndpointBuilderFactory {
return this;
}
/**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastMapEndpointProducerBuilder reliable(boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastMapEndpointProducerBuilder reliable(String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
* Whether the producer should be started lazy (on the first message).
* By starting lazy you can use this to allow CamelContext and routes to
* startup in situations where a producer may otherwise fail during
@@ -640,138 +392,6 @@ public interface HazelcastMapEndpointBuilderFactory {
setProperty("lazyStartProducer", lazyStartProducer);
return this;
}
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointProducerBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointProducerBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointProducerBuilder onErrorDelay(
- int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointProducerBuilder onErrorDelay(
- String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointProducerBuilder pollTimeout(int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointProducerBuilder pollTimeout(
- String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointProducerBuilder transacted(
- boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointProducerBuilder transacted(String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointProducerBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointProducerBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
@@ -918,156 +538,6 @@ public interface HazelcastMapEndpointBuilderFactory {
setProperty("hazelcastInstanceName", hazelcastInstanceName);
return this;
}
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastMapEndpointBuilder reliable(boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastMapEndpointBuilder reliable(String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointBuilder onErrorDelay(int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointBuilder onErrorDelay(String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointBuilder pollTimeout(int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointBuilder pollTimeout(String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointBuilder transacted(boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointBuilder transacted(String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMapEndpointBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
@@ -1176,15 +646,6 @@ public interface HazelcastMapEndpointBuilderFactory {
readOnceTail,
capacity;
}
-
- /**
- * Proxy enum for
- * <code>org.apache.camel.component.hazelcast.queue.HazelcastQueueConsumerMode</code> enum.
- */
- enum HazelcastQueueConsumerMode {
- listen,
- poll;
- }
/**
* Hazelcast Map (camel-hazelcast)
* 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 42c030f..09eaf60 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
@@ -115,30 +115,6 @@ public interface HazelcastMultimapEndpointBuilderFactory {
return this;
}
/**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastMultimapEndpointConsumerBuilder reliable(
- boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastMultimapEndpointConsumerBuilder reliable(
- String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
* Allows for bridging the consumer to the Camel routing Error Handler,
* which mean any exceptions occurred while the consumer is trying to
* pickup incoming messages, or the likes, will now be processed as a
@@ -174,213 +150,6 @@ public interface HazelcastMultimapEndpointBuilderFactory {
setProperty("bridgeErrorHandler", bridgeErrorHandler);
return this;
}
- /**
- * Define the polling timeout of the Queue consumer in Poll mode.
- *
- * The option is a: <code>long</code> type.
- *
- * Group: consumer
- */
- default HazelcastMultimapEndpointConsumerBuilder pollingTimeout(
- long pollingTimeout) {
- setProperty("pollingTimeout", pollingTimeout);
- return this;
- }
- /**
- * Define the polling timeout of the Queue consumer in Poll mode.
- *
- * The option will be converted to a <code>long</code> type.
- *
- * Group: consumer
- */
- default HazelcastMultimapEndpointConsumerBuilder pollingTimeout(
- String pollingTimeout) {
- setProperty("pollingTimeout", pollingTimeout);
- return this;
- }
- /**
- * Define the Pool size for Queue Consumer Executor.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: consumer
- */
- default HazelcastMultimapEndpointConsumerBuilder poolSize(int poolSize) {
- setProperty("poolSize", poolSize);
- return this;
- }
- /**
- * Define the Pool size for Queue Consumer Executor.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: consumer
- */
- default HazelcastMultimapEndpointConsumerBuilder poolSize(
- String poolSize) {
- setProperty("poolSize", poolSize);
- return this;
- }
- /**
- * Define the Queue Consumer mode: Listen or Poll.
- *
- * The option is a:
- * <code>org.apache.camel.component.hazelcast.queue.HazelcastQueueConsumerMode</code> type.
- *
- * Group: consumer
- */
- default HazelcastMultimapEndpointConsumerBuilder queueConsumerMode(
- HazelcastQueueConsumerMode queueConsumerMode) {
- setProperty("queueConsumerMode", queueConsumerMode);
- return this;
- }
- /**
- * Define the Queue Consumer mode: Listen or Poll.
- *
- * The option will be converted to a
- * <code>org.apache.camel.component.hazelcast.queue.HazelcastQueueConsumerMode</code> type.
- *
- * Group: consumer
- */
- default HazelcastMultimapEndpointConsumerBuilder queueConsumerMode(
- String queueConsumerMode) {
- setProperty("queueConsumerMode", queueConsumerMode);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointConsumerBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointConsumerBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointConsumerBuilder onErrorDelay(
- int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointConsumerBuilder onErrorDelay(
- String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointConsumerBuilder pollTimeout(
- int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointConsumerBuilder pollTimeout(
- String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointConsumerBuilder transacted(
- boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointConsumerBuilder transacted(
- String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointConsumerBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointConsumerBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
@@ -586,30 +355,6 @@ public interface HazelcastMultimapEndpointBuilderFactory {
return this;
}
/**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastMultimapEndpointProducerBuilder reliable(
- boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastMultimapEndpointProducerBuilder reliable(
- String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
* Whether the producer should be started lazy (on the first message).
* By starting lazy you can use this to allow CamelContext and routes to
* startup in situations where a producer may otherwise fail during
@@ -649,140 +394,6 @@ public interface HazelcastMultimapEndpointBuilderFactory {
setProperty("lazyStartProducer", lazyStartProducer);
return this;
}
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointProducerBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointProducerBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointProducerBuilder onErrorDelay(
- int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointProducerBuilder onErrorDelay(
- String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointProducerBuilder pollTimeout(
- int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointProducerBuilder pollTimeout(
- String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointProducerBuilder transacted(
- boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointProducerBuilder transacted(
- String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointProducerBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointProducerBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
@@ -930,157 +541,6 @@ public interface HazelcastMultimapEndpointBuilderFactory {
setProperty("hazelcastInstanceName", hazelcastInstanceName);
return this;
}
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastMultimapEndpointBuilder reliable(boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastMultimapEndpointBuilder reliable(String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointBuilder onErrorDelay(int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointBuilder onErrorDelay(
- String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointBuilder pollTimeout(int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointBuilder pollTimeout(String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointBuilder transacted(boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointBuilder transacted(String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastMultimapEndpointBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
@@ -1189,15 +649,6 @@ public interface HazelcastMultimapEndpointBuilderFactory {
readOnceTail,
capacity;
}
-
- /**
- * Proxy enum for
- * <code>org.apache.camel.component.hazelcast.queue.HazelcastQueueConsumerMode</code> enum.
- */
- enum HazelcastQueueConsumerMode {
- listen,
- poll;
- }
/**
* Hazelcast Multimap (camel-hazelcast)
* 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 54dcba8..fcea042 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
@@ -114,28 +114,6 @@ public interface HazelcastQueueEndpointBuilderFactory {
return this;
}
/**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastQueueEndpointConsumerBuilder reliable(boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastQueueEndpointConsumerBuilder reliable(String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
* Allows for bridging the consumer to the Camel routing Error Handler,
* which mean any exceptions occurred while the consumer is trying to
* pickup incoming messages, or the likes, will now be processed as a
@@ -243,140 +221,6 @@ public interface HazelcastQueueEndpointBuilderFactory {
setProperty("queueConsumerMode", queueConsumerMode);
return this;
}
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointConsumerBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointConsumerBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointConsumerBuilder onErrorDelay(
- int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointConsumerBuilder onErrorDelay(
- String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointConsumerBuilder pollTimeout(
- int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointConsumerBuilder pollTimeout(
- String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointConsumerBuilder transacted(
- boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointConsumerBuilder transacted(
- String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointConsumerBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointConsumerBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
@@ -582,28 +426,6 @@ public interface HazelcastQueueEndpointBuilderFactory {
return this;
}
/**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastQueueEndpointProducerBuilder reliable(boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastQueueEndpointProducerBuilder reliable(String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
* Whether the producer should be started lazy (on the first message).
* By starting lazy you can use this to allow CamelContext and routes to
* startup in situations where a producer may otherwise fail during
@@ -643,140 +465,6 @@ public interface HazelcastQueueEndpointBuilderFactory {
setProperty("lazyStartProducer", lazyStartProducer);
return this;
}
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointProducerBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointProducerBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointProducerBuilder onErrorDelay(
- int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointProducerBuilder onErrorDelay(
- String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointProducerBuilder pollTimeout(
- int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointProducerBuilder pollTimeout(
- String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointProducerBuilder transacted(
- boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointProducerBuilder transacted(
- String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointProducerBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointProducerBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
@@ -924,156 +612,6 @@ public interface HazelcastQueueEndpointBuilderFactory {
setProperty("hazelcastInstanceName", hazelcastInstanceName);
return this;
}
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastQueueEndpointBuilder reliable(boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastQueueEndpointBuilder reliable(String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointBuilder onErrorDelay(int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointBuilder onErrorDelay(String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointBuilder pollTimeout(int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointBuilder pollTimeout(String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointBuilder transacted(boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointBuilder transacted(String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastQueueEndpointBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
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 7566ac6..01b2d16 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
@@ -116,30 +116,6 @@ public interface HazelcastReplicatedmapEndpointBuilderFactory {
return this;
}
/**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastReplicatedmapEndpointConsumerBuilder reliable(
- boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastReplicatedmapEndpointConsumerBuilder reliable(
- String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
* Allows for bridging the consumer to the Camel routing Error Handler,
* which mean any exceptions occurred while the consumer is trying to
* pickup incoming messages, or the likes, will now be processed as a
@@ -175,214 +151,6 @@ public interface HazelcastReplicatedmapEndpointBuilderFactory {
setProperty("bridgeErrorHandler", bridgeErrorHandler);
return this;
}
- /**
- * Define the polling timeout of the Queue consumer in Poll mode.
- *
- * The option is a: <code>long</code> type.
- *
- * Group: consumer
- */
- default HazelcastReplicatedmapEndpointConsumerBuilder pollingTimeout(
- long pollingTimeout) {
- setProperty("pollingTimeout", pollingTimeout);
- return this;
- }
- /**
- * Define the polling timeout of the Queue consumer in Poll mode.
- *
- * The option will be converted to a <code>long</code> type.
- *
- * Group: consumer
- */
- default HazelcastReplicatedmapEndpointConsumerBuilder pollingTimeout(
- String pollingTimeout) {
- setProperty("pollingTimeout", pollingTimeout);
- return this;
- }
- /**
- * Define the Pool size for Queue Consumer Executor.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: consumer
- */
- default HazelcastReplicatedmapEndpointConsumerBuilder poolSize(
- int poolSize) {
- setProperty("poolSize", poolSize);
- return this;
- }
- /**
- * Define the Pool size for Queue Consumer Executor.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: consumer
- */
- default HazelcastReplicatedmapEndpointConsumerBuilder poolSize(
- String poolSize) {
- setProperty("poolSize", poolSize);
- return this;
- }
- /**
- * Define the Queue Consumer mode: Listen or Poll.
- *
- * The option is a:
- * <code>org.apache.camel.component.hazelcast.queue.HazelcastQueueConsumerMode</code> type.
- *
- * Group: consumer
- */
- default HazelcastReplicatedmapEndpointConsumerBuilder queueConsumerMode(
- HazelcastQueueConsumerMode queueConsumerMode) {
- setProperty("queueConsumerMode", queueConsumerMode);
- return this;
- }
- /**
- * Define the Queue Consumer mode: Listen or Poll.
- *
- * The option will be converted to a
- * <code>org.apache.camel.component.hazelcast.queue.HazelcastQueueConsumerMode</code> type.
- *
- * Group: consumer
- */
- default HazelcastReplicatedmapEndpointConsumerBuilder queueConsumerMode(
- String queueConsumerMode) {
- setProperty("queueConsumerMode", queueConsumerMode);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointConsumerBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointConsumerBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointConsumerBuilder onErrorDelay(
- int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointConsumerBuilder onErrorDelay(
- String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointConsumerBuilder pollTimeout(
- int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointConsumerBuilder pollTimeout(
- String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointConsumerBuilder transacted(
- boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointConsumerBuilder transacted(
- String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointConsumerBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointConsumerBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
@@ -589,30 +357,6 @@ public interface HazelcastReplicatedmapEndpointBuilderFactory {
return this;
}
/**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastReplicatedmapEndpointProducerBuilder reliable(
- boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastReplicatedmapEndpointProducerBuilder reliable(
- String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
* Whether the producer should be started lazy (on the first message).
* By starting lazy you can use this to allow CamelContext and routes to
* startup in situations where a producer may otherwise fail during
@@ -652,140 +396,6 @@ public interface HazelcastReplicatedmapEndpointBuilderFactory {
setProperty("lazyStartProducer", lazyStartProducer);
return this;
}
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointProducerBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointProducerBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointProducerBuilder onErrorDelay(
- int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointProducerBuilder onErrorDelay(
- String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointProducerBuilder pollTimeout(
- int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointProducerBuilder pollTimeout(
- String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointProducerBuilder transacted(
- boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointProducerBuilder transacted(
- String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointProducerBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointProducerBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
@@ -933,162 +543,6 @@ public interface HazelcastReplicatedmapEndpointBuilderFactory {
setProperty("hazelcastInstanceName", hazelcastInstanceName);
return this;
}
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastReplicatedmapEndpointBuilder reliable(boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastReplicatedmapEndpointBuilder reliable(String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointBuilder onErrorDelay(
- int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointBuilder onErrorDelay(
- String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointBuilder pollTimeout(
- int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointBuilder pollTimeout(
- String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointBuilder transacted(
- boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointBuilder transacted(
- String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastReplicatedmapEndpointBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
@@ -1197,15 +651,6 @@ public interface HazelcastReplicatedmapEndpointBuilderFactory {
readOnceTail,
capacity;
}
-
- /**
- * Proxy enum for
- * <code>org.apache.camel.component.hazelcast.queue.HazelcastQueueConsumerMode</code> enum.
- */
- enum HazelcastQueueConsumerMode {
- listen,
- poll;
- }
/**
* Hazelcast Replicated Map (camel-hazelcast)
* 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 ff1cea5..8831f72 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
@@ -41,28 +41,6 @@ public interface HazelcastRingbufferEndpointBuilderFactory {
return (AdvancedHazelcastRingbufferEndpointBuilder) this;
}
/**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastRingbufferEndpointBuilder reliable(boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastRingbufferEndpointBuilder reliable(String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
* To specify a default operation to use, if no operation header has
* been provided.
*
@@ -134,136 +112,6 @@ public interface HazelcastRingbufferEndpointBuilderFactory {
setProperty("hazelcastInstanceName", hazelcastInstanceName);
return this;
}
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastRingbufferEndpointBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastRingbufferEndpointBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastRingbufferEndpointBuilder onErrorDelay(int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastRingbufferEndpointBuilder onErrorDelay(
- String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastRingbufferEndpointBuilder pollTimeout(int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastRingbufferEndpointBuilder pollTimeout(
- String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastRingbufferEndpointBuilder transacted(boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastRingbufferEndpointBuilder transacted(String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastRingbufferEndpointBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastRingbufferEndpointBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
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 5bf623c..d558f29 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
@@ -114,28 +114,6 @@ public interface HazelcastSedaEndpointBuilderFactory {
return this;
}
/**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastSedaEndpointConsumerBuilder reliable(boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastSedaEndpointConsumerBuilder reliable(String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
* Allows for bridging the consumer to the Camel routing Error Handler,
* which mean any exceptions occurred while the consumer is trying to
* pickup incoming messages, or the likes, will now be processed as a
@@ -172,78 +150,6 @@ public interface HazelcastSedaEndpointBuilderFactory {
return this;
}
/**
- * Define the polling timeout of the Queue consumer in Poll mode.
- *
- * The option is a: <code>long</code> type.
- *
- * Group: consumer
- */
- default HazelcastSedaEndpointConsumerBuilder pollingTimeout(
- long pollingTimeout) {
- setProperty("pollingTimeout", pollingTimeout);
- return this;
- }
- /**
- * Define the polling timeout of the Queue consumer in Poll mode.
- *
- * The option will be converted to a <code>long</code> type.
- *
- * Group: consumer
- */
- default HazelcastSedaEndpointConsumerBuilder pollingTimeout(
- String pollingTimeout) {
- setProperty("pollingTimeout", pollingTimeout);
- return this;
- }
- /**
- * Define the Pool size for Queue Consumer Executor.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: consumer
- */
- default HazelcastSedaEndpointConsumerBuilder poolSize(int poolSize) {
- setProperty("poolSize", poolSize);
- return this;
- }
- /**
- * Define the Pool size for Queue Consumer Executor.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: consumer
- */
- default HazelcastSedaEndpointConsumerBuilder poolSize(String poolSize) {
- setProperty("poolSize", poolSize);
- return this;
- }
- /**
- * Define the Queue Consumer mode: Listen or Poll.
- *
- * The option is a:
- * <code>org.apache.camel.component.hazelcast.queue.HazelcastQueueConsumerMode</code> type.
- *
- * Group: consumer
- */
- default HazelcastSedaEndpointConsumerBuilder queueConsumerMode(
- HazelcastQueueConsumerMode queueConsumerMode) {
- setProperty("queueConsumerMode", queueConsumerMode);
- return this;
- }
- /**
- * Define the Queue Consumer mode: Listen or Poll.
- *
- * The option will be converted to a
- * <code>org.apache.camel.component.hazelcast.queue.HazelcastQueueConsumerMode</code> type.
- *
- * Group: consumer
- */
- default HazelcastSedaEndpointConsumerBuilder queueConsumerMode(
- String queueConsumerMode) {
- setProperty("queueConsumerMode", queueConsumerMode);
- return this;
- }
- /**
* To use concurrent consumers polling from the SEDA queue.
*
* The option is a: <code>int</code> type.
@@ -580,28 +486,6 @@ public interface HazelcastSedaEndpointBuilderFactory {
return this;
}
/**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastSedaEndpointProducerBuilder reliable(boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastSedaEndpointProducerBuilder reliable(String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
* Whether the producer should be started lazy (on the first message).
* By starting lazy you can use this to allow CamelContext and routes to
* startup in situations where a producer may otherwise fail during
@@ -921,28 +805,6 @@ public interface HazelcastSedaEndpointBuilderFactory {
return this;
}
/**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastSedaEndpointBuilder reliable(boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastSedaEndpointBuilder reliable(String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
* To use concurrent consumers polling from the SEDA queue.
*
* The option is a: <code>int</code> type.
@@ -1178,15 +1040,6 @@ public interface HazelcastSedaEndpointBuilderFactory {
readOnceTail,
capacity;
}
-
- /**
- * Proxy enum for
- * <code>org.apache.camel.component.hazelcast.queue.HazelcastQueueConsumerMode</code> enum.
- */
- enum HazelcastQueueConsumerMode {
- listen,
- poll;
- }
/**
* Hazelcast SEDA (camel-hazelcast)
* 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 ab73281..a722a08 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
@@ -114,28 +114,6 @@ public interface HazelcastSetEndpointBuilderFactory {
return this;
}
/**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastSetEndpointConsumerBuilder reliable(boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastSetEndpointConsumerBuilder reliable(String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
* Allows for bridging the consumer to the Camel routing Error Handler,
* which mean any exceptions occurred while the consumer is trying to
* pickup incoming messages, or the likes, will now be processed as a
@@ -171,210 +149,6 @@ public interface HazelcastSetEndpointBuilderFactory {
setProperty("bridgeErrorHandler", bridgeErrorHandler);
return this;
}
- /**
- * Define the polling timeout of the Queue consumer in Poll mode.
- *
- * The option is a: <code>long</code> type.
- *
- * Group: consumer
- */
- default HazelcastSetEndpointConsumerBuilder pollingTimeout(
- long pollingTimeout) {
- setProperty("pollingTimeout", pollingTimeout);
- return this;
- }
- /**
- * Define the polling timeout of the Queue consumer in Poll mode.
- *
- * The option will be converted to a <code>long</code> type.
- *
- * Group: consumer
- */
- default HazelcastSetEndpointConsumerBuilder pollingTimeout(
- String pollingTimeout) {
- setProperty("pollingTimeout", pollingTimeout);
- return this;
- }
- /**
- * Define the Pool size for Queue Consumer Executor.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: consumer
- */
- default HazelcastSetEndpointConsumerBuilder poolSize(int poolSize) {
- setProperty("poolSize", poolSize);
- return this;
- }
- /**
- * Define the Pool size for Queue Consumer Executor.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: consumer
- */
- default HazelcastSetEndpointConsumerBuilder poolSize(String poolSize) {
- setProperty("poolSize", poolSize);
- return this;
- }
- /**
- * Define the Queue Consumer mode: Listen or Poll.
- *
- * The option is a:
- * <code>org.apache.camel.component.hazelcast.queue.HazelcastQueueConsumerMode</code> type.
- *
- * Group: consumer
- */
- default HazelcastSetEndpointConsumerBuilder queueConsumerMode(
- HazelcastQueueConsumerMode queueConsumerMode) {
- setProperty("queueConsumerMode", queueConsumerMode);
- return this;
- }
- /**
- * Define the Queue Consumer mode: Listen or Poll.
- *
- * The option will be converted to a
- * <code>org.apache.camel.component.hazelcast.queue.HazelcastQueueConsumerMode</code> type.
- *
- * Group: consumer
- */
- default HazelcastSetEndpointConsumerBuilder queueConsumerMode(
- String queueConsumerMode) {
- setProperty("queueConsumerMode", queueConsumerMode);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointConsumerBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointConsumerBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointConsumerBuilder onErrorDelay(
- int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointConsumerBuilder onErrorDelay(
- String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointConsumerBuilder pollTimeout(int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointConsumerBuilder pollTimeout(
- String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointConsumerBuilder transacted(
- boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointConsumerBuilder transacted(String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointConsumerBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointConsumerBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
@@ -579,28 +353,6 @@ public interface HazelcastSetEndpointBuilderFactory {
return this;
}
/**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastSetEndpointProducerBuilder reliable(boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastSetEndpointProducerBuilder reliable(String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
* Whether the producer should be started lazy (on the first message).
* By starting lazy you can use this to allow CamelContext and routes to
* startup in situations where a producer may otherwise fail during
@@ -640,138 +392,6 @@ public interface HazelcastSetEndpointBuilderFactory {
setProperty("lazyStartProducer", lazyStartProducer);
return this;
}
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointProducerBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointProducerBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointProducerBuilder onErrorDelay(
- int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointProducerBuilder onErrorDelay(
- String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointProducerBuilder pollTimeout(int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointProducerBuilder pollTimeout(
- String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointProducerBuilder transacted(
- boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointProducerBuilder transacted(String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointProducerBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointProducerBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
@@ -918,156 +538,6 @@ public interface HazelcastSetEndpointBuilderFactory {
setProperty("hazelcastInstanceName", hazelcastInstanceName);
return this;
}
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastSetEndpointBuilder reliable(boolean reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * Define if the endpoint will use a reliable Topic struct or not.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: common
- */
- default HazelcastSetEndpointBuilder reliable(String reliable) {
- setProperty("reliable", reliable);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointBuilder onErrorDelay(int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointBuilder onErrorDelay(String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointBuilder pollTimeout(int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointBuilder pollTimeout(String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointBuilder transacted(boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointBuilder transacted(String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastSetEndpointBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
@@ -1176,15 +646,6 @@ public interface HazelcastSetEndpointBuilderFactory {
readOnceTail,
capacity;
}
-
- /**
- * Proxy enum for
- * <code>org.apache.camel.component.hazelcast.queue.HazelcastQueueConsumerMode</code> enum.
- */
- enum HazelcastQueueConsumerMode {
- listen,
- poll;
- }
/**
* Hazelcast Set (camel-hazelcast)
* The camel Endpoint to access Hazelcast distributed set.
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 ec9c773..86374b3 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
@@ -171,212 +171,6 @@ public interface HazelcastTopicEndpointBuilderFactory {
setProperty("bridgeErrorHandler", bridgeErrorHandler);
return this;
}
- /**
- * Define the polling timeout of the Queue consumer in Poll mode.
- *
- * The option is a: <code>long</code> type.
- *
- * Group: consumer
- */
- default HazelcastTopicEndpointConsumerBuilder pollingTimeout(
- long pollingTimeout) {
- setProperty("pollingTimeout", pollingTimeout);
- return this;
- }
- /**
- * Define the polling timeout of the Queue consumer in Poll mode.
- *
- * The option will be converted to a <code>long</code> type.
- *
- * Group: consumer
- */
- default HazelcastTopicEndpointConsumerBuilder pollingTimeout(
- String pollingTimeout) {
- setProperty("pollingTimeout", pollingTimeout);
- return this;
- }
- /**
- * Define the Pool size for Queue Consumer Executor.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: consumer
- */
- default HazelcastTopicEndpointConsumerBuilder poolSize(int poolSize) {
- setProperty("poolSize", poolSize);
- return this;
- }
- /**
- * Define the Pool size for Queue Consumer Executor.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: consumer
- */
- default HazelcastTopicEndpointConsumerBuilder poolSize(String poolSize) {
- setProperty("poolSize", poolSize);
- return this;
- }
- /**
- * Define the Queue Consumer mode: Listen or Poll.
- *
- * The option is a:
- * <code>org.apache.camel.component.hazelcast.queue.HazelcastQueueConsumerMode</code> type.
- *
- * Group: consumer
- */
- default HazelcastTopicEndpointConsumerBuilder queueConsumerMode(
- HazelcastQueueConsumerMode queueConsumerMode) {
- setProperty("queueConsumerMode", queueConsumerMode);
- return this;
- }
- /**
- * Define the Queue Consumer mode: Listen or Poll.
- *
- * The option will be converted to a
- * <code>org.apache.camel.component.hazelcast.queue.HazelcastQueueConsumerMode</code> type.
- *
- * Group: consumer
- */
- default HazelcastTopicEndpointConsumerBuilder queueConsumerMode(
- String queueConsumerMode) {
- setProperty("queueConsumerMode", queueConsumerMode);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointConsumerBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointConsumerBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointConsumerBuilder onErrorDelay(
- int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointConsumerBuilder onErrorDelay(
- String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointConsumerBuilder pollTimeout(
- int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointConsumerBuilder pollTimeout(
- String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointConsumerBuilder transacted(
- boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointConsumerBuilder transacted(
- String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointConsumerBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointConsumerBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
@@ -643,140 +437,6 @@ public interface HazelcastTopicEndpointBuilderFactory {
setProperty("lazyStartProducer", lazyStartProducer);
return this;
}
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointProducerBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointProducerBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointProducerBuilder onErrorDelay(
- int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointProducerBuilder onErrorDelay(
- String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointProducerBuilder pollTimeout(
- int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointProducerBuilder pollTimeout(
- String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointProducerBuilder transacted(
- boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointProducerBuilder transacted(
- String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointProducerBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointProducerBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
@@ -946,134 +606,6 @@ public interface HazelcastTopicEndpointBuilderFactory {
setProperty("reliable", reliable);
return this;
}
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointBuilder concurrentConsumers(
- int concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * To use concurrent consumers polling from the SEDA queue.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointBuilder concurrentConsumers(
- String concurrentConsumers) {
- setProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointBuilder onErrorDelay(int onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * Milliseconds before consumer continues polling after an error has
- * occurred.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointBuilder onErrorDelay(String onErrorDelay) {
- setProperty("onErrorDelay", onErrorDelay);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option is a: <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointBuilder pollTimeout(int pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * The timeout used when consuming from the SEDA queue. When a timeout
- * occurs, the consumer can check whether it is allowed to continue
- * running. Setting a lower value allows the consumer to react more
- * quickly upon shutdown.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointBuilder pollTimeout(String pollTimeout) {
- setProperty("pollTimeout", pollTimeout);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointBuilder transacted(boolean transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true then the consumer runs in transaction mode, where the
- * messages in the seda queue will only be removed if the transaction
- * commits, which happens when the processing is complete.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointBuilder transacted(String transacted) {
- setProperty("transacted", transacted);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointBuilder transferExchange(
- boolean transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
- /**
- * If set to true the whole Exchange will be transfered. If header or
- * body contains not serializable objects, they will be skipped.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Group: seda
- */
- default HazelcastTopicEndpointBuilder transferExchange(
- String transferExchange) {
- setProperty("transferExchange", transferExchange);
- return this;
- }
}
/**
@@ -1182,15 +714,6 @@ public interface HazelcastTopicEndpointBuilderFactory {
readOnceTail,
capacity;
}
-
- /**
- * Proxy enum for
- * <code>org.apache.camel.component.hazelcast.queue.HazelcastQueueConsumerMode</code> enum.
- */
- enum HazelcastQueueConsumerMode {
- listen,
- poll;
- }
/**
* Hazelcast Topic (camel-hazelcast)
* The hazelcast-topic component is used to access Hazelcast distributed
[camel] 03/05: CAMEL-13870: Fast property configuration of Camel
endpoints. Work in progress.
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch CAMEL-13870
in repository https://gitbox.apache.org/repos/asf/camel.git
commit b6553d2e16c076a1e1a89340de2f1fd717e150c2
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Wed Aug 21 06:31:32 2019 +0200
CAMEL-13870: Fast property configuration of Camel endpoints. Work in progress.
---
.../camel-ftp/src/main/docs/ftps-component.adoc | 2 +-
.../camel/component/geocoder/GeoCoderEndpoint.java | 7 +++--
.../google/sheets/GoogleSheetsEndpoint.java | 8 ++---
.../endpoint/dsl/FtpsEndpointBuilderFactory.java | 36 +++++++++++-----------
4 files changed, 28 insertions(+), 25 deletions(-)
diff --git a/components/camel-ftp/src/main/docs/ftps-component.adoc b/components/camel-ftp/src/main/docs/ftps-component.adoc
index 43813fb..7f65dee 100644
--- a/components/camel-ftp/src/main/docs/ftps-component.adoc
+++ b/components/camel-ftp/src/main/docs/ftps-component.adoc
@@ -179,7 +179,7 @@ with the following path and query parameters:
| *execProt* (security) | The exec protection level PROT command. C - Clear S - Safe(SSL protocol only) E - Confidential(SSL protocol only) P - Private | | String
| *ftpClientKeyStore Parameters* (security) | Set the key store parameters | | Map
| *ftpClientTrustStore Parameters* (security) | Set the trust store parameters | | Map
-| *isImplicit* (security) | Set the security mode(Implicit/Explicit). true - Implicit Mode / False - Explicit Mode | false | boolean
+| *implicit* (security) | Set the security mode (Implicit/Explicit). true - Implicit Mode / False - Explicit Mode | false | boolean
| *password* (security) | Password to use for login | | String
| *securityProtocol* (security) | Set the underlying security protocol. | TLSv1.2 | String
| *sslContextParameters* (security) | Gets the JSSE configuration that overrides any settings in FtpsEndpoint#\ftpClientKeyStoreParameters, \ftpClientTrustStoreParameters, and FtpsConfiguration#getSecurityProtocol(). | | SSLContextParameters
diff --git a/components/camel-geocoder/src/main/java/org/apache/camel/component/geocoder/GeoCoderEndpoint.java b/components/camel-geocoder/src/main/java/org/apache/camel/component/geocoder/GeoCoderEndpoint.java
index 60ed9d5..050615e 100644
--- a/components/camel-geocoder/src/main/java/org/apache/camel/component/geocoder/GeoCoderEndpoint.java
+++ b/components/camel-geocoder/src/main/java/org/apache/camel/component/geocoder/GeoCoderEndpoint.java
@@ -147,8 +147,7 @@ public class GeoCoderEndpoint extends DefaultEndpoint {
this.clientKey = clientKey;
}
-
- private String getApiKey() {
+ public String getApiKey() {
return apiKey;
}
@@ -159,6 +158,10 @@ public class GeoCoderEndpoint extends DefaultEndpoint {
this.apiKey = apiKey;
}
+ public String getProxyHost() {
+ return proxyHost;
+ }
+
/**
* The proxy host name
*/
diff --git a/components/camel-google-sheets/src/main/java/org/apache/camel/component/google/sheets/GoogleSheetsEndpoint.java b/components/camel-google-sheets/src/main/java/org/apache/camel/component/google/sheets/GoogleSheetsEndpoint.java
index 744f37b..0cb4fc3 100644
--- a/components/camel-google-sheets/src/main/java/org/apache/camel/component/google/sheets/GoogleSheetsEndpoint.java
+++ b/components/camel-google-sheets/src/main/java/org/apache/camel/component/google/sheets/GoogleSheetsEndpoint.java
@@ -38,14 +38,14 @@ import org.apache.camel.support.component.ApiMethodPropertiesHelper;
@UriEndpoint(firstVersion = "2.23.0", scheme = "google-sheets", title = "Google Sheets", syntax = "google-sheets:apiName/methodName", consumerPrefix = "consumer", label = "api,cloud,sheets")
public class GoogleSheetsEndpoint extends AbstractApiEndpoint<GoogleSheetsApiName, GoogleSheetsConfiguration> {
- @UriParam(name = "configuration")
- private GoogleSheetsConfiguration endpointConfiguration;
+ @UriParam
+ private GoogleSheetsConfiguration configuration;
private Object apiProxy;
public GoogleSheetsEndpoint(String uri, GoogleSheetsComponent component, GoogleSheetsApiName apiName, String methodName, GoogleSheetsConfiguration endpointConfiguration) {
super(uri, component, apiName, methodName, GoogleSheetsApiCollection.getCollection().getHelper(apiName), endpointConfiguration);
- this.endpointConfiguration = endpointConfiguration;
+ this.configuration = endpointConfiguration;
}
@Override
@@ -90,7 +90,7 @@ public class GoogleSheetsEndpoint extends AbstractApiEndpoint<GoogleSheetsApiNam
}
public Sheets getClient() {
- return ((GoogleSheetsComponent)getComponent()).getClient(endpointConfiguration);
+ return ((GoogleSheetsComponent)getComponent()).getClient(configuration);
}
@Override
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 30e2d02..5558b87 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
@@ -1971,27 +1971,27 @@ public interface FtpsEndpointBuilderFactory {
return this;
}
/**
- * Set the security mode(Implicit/Explicit). true - Implicit Mode /
+ * Set the security mode (Implicit/Explicit). true - Implicit Mode /
* False - Explicit Mode.
*
* The option is a: <code>boolean</code> type.
*
* Group: security
*/
- default FtpsEndpointConsumerBuilder isImplicit(boolean isImplicit) {
- setProperty("isImplicit", isImplicit);
+ default FtpsEndpointConsumerBuilder implicit(boolean implicit) {
+ setProperty("implicit", implicit);
return this;
}
/**
- * Set the security mode(Implicit/Explicit). true - Implicit Mode /
+ * Set the security mode (Implicit/Explicit). true - Implicit Mode /
* False - Explicit Mode.
*
* The option will be converted to a <code>boolean</code> type.
*
* Group: security
*/
- default FtpsEndpointConsumerBuilder isImplicit(String isImplicit) {
- setProperty("isImplicit", isImplicit);
+ default FtpsEndpointConsumerBuilder implicit(String implicit) {
+ setProperty("implicit", implicit);
return this;
}
/**
@@ -3559,27 +3559,27 @@ public interface FtpsEndpointBuilderFactory {
return this;
}
/**
- * Set the security mode(Implicit/Explicit). true - Implicit Mode /
+ * Set the security mode (Implicit/Explicit). true - Implicit Mode /
* False - Explicit Mode.
*
* The option is a: <code>boolean</code> type.
*
* Group: security
*/
- default FtpsEndpointProducerBuilder isImplicit(boolean isImplicit) {
- setProperty("isImplicit", isImplicit);
+ default FtpsEndpointProducerBuilder implicit(boolean implicit) {
+ setProperty("implicit", implicit);
return this;
}
/**
- * Set the security mode(Implicit/Explicit). true - Implicit Mode /
+ * Set the security mode (Implicit/Explicit). true - Implicit Mode /
* False - Explicit Mode.
*
* The option will be converted to a <code>boolean</code> type.
*
* Group: security
*/
- default FtpsEndpointProducerBuilder isImplicit(String isImplicit) {
- setProperty("isImplicit", isImplicit);
+ default FtpsEndpointProducerBuilder implicit(String implicit) {
+ setProperty("implicit", implicit);
return this;
}
/**
@@ -4765,27 +4765,27 @@ public interface FtpsEndpointBuilderFactory {
return this;
}
/**
- * Set the security mode(Implicit/Explicit). true - Implicit Mode /
+ * Set the security mode (Implicit/Explicit). true - Implicit Mode /
* False - Explicit Mode.
*
* The option is a: <code>boolean</code> type.
*
* Group: security
*/
- default FtpsEndpointBuilder isImplicit(boolean isImplicit) {
- setProperty("isImplicit", isImplicit);
+ default FtpsEndpointBuilder implicit(boolean implicit) {
+ setProperty("implicit", implicit);
return this;
}
/**
- * Set the security mode(Implicit/Explicit). true - Implicit Mode /
+ * Set the security mode (Implicit/Explicit). true - Implicit Mode /
* False - Explicit Mode.
*
* The option will be converted to a <code>boolean</code> type.
*
* Group: security
*/
- default FtpsEndpointBuilder isImplicit(String isImplicit) {
- setProperty("isImplicit", isImplicit);
+ default FtpsEndpointBuilder implicit(String implicit) {
+ setProperty("implicit", implicit);
return this;
}
/**
[camel] 01/05: CAMEL-13870: Fast property configuration of Camel
endpoints. Work in progress.
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch CAMEL-13870
in repository https://gitbox.apache.org/repos/asf/camel.git
commit d00b92c77ae482826440451debb7c9e41446ab84
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Wed Aug 21 05:14:28 2019 +0200
CAMEL-13870: Fast property configuration of Camel endpoints. Work in progress.
---
.../camel/component/cmis/CMISSessionFacade.java | 28 ++++++++++++++++++++++
.../camel/component/jetty/JettyHttpComponent.java | 2 +-
.../camel/component/jetty/JettyHttpEndpoint.java | 9 ++-----
.../camel-jetty/src/main/docs/jetty-component.adoc | 4 ++--
.../camel/component/jetty/CustomFiltersTest.java | 2 +-
5 files changed, 34 insertions(+), 11 deletions(-)
diff --git a/components/camel-cmis/src/main/java/org/apache/camel/component/cmis/CMISSessionFacade.java b/components/camel-cmis/src/main/java/org/apache/camel/component/cmis/CMISSessionFacade.java
index 7ce83d7..557304e 100644
--- a/components/camel-cmis/src/main/java/org/apache/camel/component/cmis/CMISSessionFacade.java
+++ b/components/camel-cmis/src/main/java/org/apache/camel/component/cmis/CMISSessionFacade.java
@@ -236,6 +236,10 @@ public class CMISSessionFacade {
return session.createOperationContext();
}
+ public String getUsername() {
+ return username;
+ }
+
/**
* Username for the cmis repository
*/
@@ -243,6 +247,10 @@ public class CMISSessionFacade {
this.username = username;
}
+ public String getPassword() {
+ return password;
+ }
+
/**
* Password for the cmis repository
*/
@@ -250,6 +258,10 @@ public class CMISSessionFacade {
this.password = password;
}
+ public String getRepositoryId() {
+ return repositoryId;
+ }
+
/**
* The Id of the repository to use. If not specified the first available repository is used
*/
@@ -257,6 +269,10 @@ public class CMISSessionFacade {
this.repositoryId = repositoryId;
}
+ public boolean isReadContent() {
+ return readContent;
+ }
+
/**
* If set to true, the content of document node will be retrieved in addition to the properties
*/
@@ -264,6 +280,10 @@ public class CMISSessionFacade {
this.readContent = readContent;
}
+ public int getReadCount() {
+ return readCount;
+ }
+
/**
* Max number of nodes to read
*/
@@ -271,6 +291,10 @@ public class CMISSessionFacade {
this.readCount = readCount;
}
+ public String getQuery() {
+ return query;
+ }
+
/**
* The cmis query to execute against the repository.
* If not specified, the consumer will retrieve every node from the content repository by iterating the content tree recursively
@@ -279,6 +303,10 @@ public class CMISSessionFacade {
this.query = query;
}
+ public int getPageSize() {
+ return pageSize;
+ }
+
/**
* Number of nodes to retrieve per page
*/
diff --git a/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java b/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java
index b251411..0ae7136 100644
--- a/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java
+++ b/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpComponent.java
@@ -176,7 +176,7 @@ public abstract class JettyHttpComponent extends HttpCommonComponent implements
Boolean enableMultipartFilter = getAndRemoveParameter(parameters, "enableMultipartFilter",
Boolean.class, true);
Filter multipartFilter = resolveAndRemoveReferenceParameter(parameters, "multipartFilterRef", Filter.class);
- List<Filter> filters = resolveAndRemoveReferenceListParameter(parameters, "filtersRef", Filter.class);
+ List<Filter> filters = resolveAndRemoveReferenceListParameter(parameters, "filters", Filter.class);
Boolean enableCors = getAndRemoveParameter(parameters, "enableCORS", Boolean.class, false);
HeaderFilterStrategy headerFilterStrategy = resolveAndRemoveReferenceParameter(parameters, "headerFilterStrategy", HeaderFilterStrategy.class);
UrlRewrite urlRewrite = resolveAndRemoveReferenceParameter(parameters, "urlRewrite", UrlRewrite.class);
diff --git a/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java b/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java
index 45d3f03..c7f5f01 100644
--- a/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java
+++ b/components/camel-jetty-common/src/main/java/org/apache/camel/component/jetty/JettyHttpEndpoint.java
@@ -60,24 +60,19 @@ public abstract class JettyHttpEndpoint extends HttpCommonEndpoint {
@UriParam(label = "consumer",
description = "If the option is true, Jetty server will setup the CrossOriginFilter which supports the CORS out of box.")
private boolean enableCORS;
- @UriParam(label = "consumer,advanced", javaType = "java.lang.String",
+ @UriParam(label = "consumer,advanced",
description = "Specifies a comma-delimited set of Handler instances to lookup in your Registry."
+ " These handlers are added to the Jetty servlet context (for example, to add security)."
+ " Important: You can not use different handlers with different Jetty endpoints using the same port number."
+ " The handlers is associated to the port number. If you need different handlers, then use different port numbers.")
private List<Handler> handlers;
- @UriParam(label = "consumer,advanced", javaType = "java.lang.String", name = "filtersRef",
+ @UriParam(label = "consumer,advanced",
description = "Allows using a custom filters which is putted into a list and can be find in the Registry."
+ " Multiple values can be separated by comma.")
private List<Filter> filters;
@UriParam(label = "consumer,advanced", prefix = "filter.", multiValue = true,
description = "Configuration of the filter init parameters. These parameters will be applied to the filter list before starting the jetty server.")
private Map<String, String> filterInitParameters;
-
-// @UriParam(label = "consumer,advanced",
-// description = "Option to disable throwing the HttpOperationFailedException in case of failed responses from the remote server."
-// + " This allows you to get all responses regardless of the HTTP status code.")
-
@UriParam(label = "consumer,advanced",
description = "Allows using a custom multipart filter. Note: setting multipartFilterRef forces the value of enableMultipartFilter to true.")
private Filter multipartFilter;
diff --git a/components/camel-jetty/src/main/docs/jetty-component.adoc b/components/camel-jetty/src/main/docs/jetty-component.adoc
index 296f30c..9c7430e 100644
--- a/components/camel-jetty/src/main/docs/jetty-component.adoc
+++ b/components/camel-jetty/src/main/docs/jetty-component.adoc
@@ -147,8 +147,8 @@ with the following path and query parameters:
| *exceptionHandler* (consumer) | To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
| *exchangePattern* (consumer) | Sets the exchange pattern when the consumer creates an exchange. | | ExchangePattern
| *filterInitParameters* (consumer) | Configuration of the filter init parameters. These parameters will be applied to the filter list before starting the jetty server. | | Map
-| *filtersRef* (consumer) | Allows using a custom filters which is putted into a list and can be find in the Registry. Multiple values can be separated by comma. | | String
-| *handlers* (consumer) | Specifies a comma-delimited set of Handler instances to lookup in your Registry. These handlers are added to the Jetty servlet context (for example, to add security). Important: You can not use different handlers with different Jetty endpoints using the same port number. The handlers is associated to the port number. If you need different handlers, then use different port numbers. | | String
+| *filters* (consumer) | Allows using a custom filters which is putted into a list and can be find in the Registry. Multiple values can be separated by comma. | | List
+| *handlers* (consumer) | Specifies a comma-delimited set of Handler instances to lookup in your Registry. These handlers are added to the Jetty servlet context (for example, to add security). Important: You can not use different handlers with different Jetty endpoints using the same port number. The handlers is associated to the port number. If you need different handlers, then use different port numbers. | | List
| *multipartFilter* (consumer) | Allows using a custom multipart filter. Note: setting multipartFilterRef forces the value of enableMultipartFilter to true. | | Filter
| *optionsEnabled* (consumer) | Specifies whether to enable HTTP OPTIONS for this Servlet consumer. By default OPTIONS is turned off. | false | boolean
| *traceEnabled* (consumer) | Specifies whether to enable HTTP TRACE for this Servlet consumer. By default TRACE is turned off. | false | boolean
diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/CustomFiltersTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/CustomFiltersTest.java
index 0fafe2b..74e4874 100644
--- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/CustomFiltersTest.java
+++ b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/CustomFiltersTest.java
@@ -100,7 +100,7 @@ public class CustomFiltersTest extends BaseJettyTest {
public void configure() throws Exception {
// Test the filter list options
- from("jetty://http://localhost:{{port}}/testFilters?filtersRef=myFilters&filterInit.keyWord=KEY").process(new Processor() {
+ from("jetty://http://localhost:{{port}}/testFilters?filters=myFilters&filterInit.keyWord=KEY").process(new Processor() {
public void process(Exchange exchange) throws Exception {
Message in = exchange.getIn();
String request = in.getBody(String.class);
[camel] 05/05: CAMEL-13870: Fast property configuration of Camel
endpoints. Work in progress.
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch CAMEL-13870
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 9d969b95a6c2eb5cbb99f1cd8fffd50d75ce9fd6
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Wed Aug 21 07:16:22 2019 +0200
CAMEL-13870: Fast property configuration of Camel endpoints. Work in progress.
---
.../component/iec60870/AbstractIecEndpoint.java | 2 +
.../src/main/docs/ignite-events-component.adoc | 2 +-
.../ignite/events/IgniteEventsConsumer.java | 12 ++--
.../ignite/events/IgniteEventsEndpoint.java | 66 +++++++++-------------
.../camel/component/ignite/IgniteEventsTest.java | 29 ----------
.../camel/component/jcache/JCacheEndpoint.java | 12 ++--
.../apache/camel/component/jira/JiraEndpoint.java | 4 ++
.../apache/camel/component/jmx/JMXConsumer.java | 4 +-
.../apache/camel/component/jmx/JMXEndpoint.java | 4 +-
.../apache/camel/component/jpa/JpaEndpoint.java | 4 +-
.../camel/component/jt400/Jt400Endpoint.java | 4 ++
.../camel/component/kafka/KafkaConfiguration.java | 8 ++-
.../camel/component/kafka/KafkaConsumer.java | 2 +-
.../kubernetes/AbstractKubernetesEndpoint.java | 4 ++
14 files changed, 70 insertions(+), 87 deletions(-)
diff --git a/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/AbstractIecEndpoint.java b/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/AbstractIecEndpoint.java
index e5521e3..364953e 100644
--- a/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/AbstractIecEndpoint.java
+++ b/components/camel-iec60870/src/main/java/org/apache/camel/component/iec60870/AbstractIecEndpoint.java
@@ -78,6 +78,8 @@ public abstract class AbstractIecEndpoint<T extends AbstractConnectionMultiplexo
this.address = requireNonNull(address);
}
+
+
public ObjectAddress getAddress() {
return this.address;
}
diff --git a/components/camel-ignite/src/main/docs/ignite-events-component.adoc b/components/camel-ignite/src/main/docs/ignite-events-component.adoc
index d9ac803..748d3e8 100644
--- a/components/camel-ignite/src/main/docs/ignite-events-component.adoc
+++ b/components/camel-ignite/src/main/docs/ignite-events-component.adoc
@@ -52,7 +52,7 @@ with the following path and query parameters:
| Name | Description | Default | Type
| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a message and handled by the routing Error Handler. By default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be logged at WARN or ERROR level and ignored. | false | boolean
| *clusterGroupExpression* (consumer) | The cluster group expression. | | ClusterGroupExpression
-| *events* (consumer) | The event IDs to subscribe to as a Set directly where the IDs are the different constants in org.apache.ignite.events.EventType. | EventType.EVTS_ALL | SetOrString
+| *events* (consumer) | The event types to subscribe to as a comma-separated string of event constants as defined in EventType. For example: EVT_CACHE_ENTRY_CREATED,EVT_CACHE_OBJECT_REMOVED,EVT_IGFS_DIR_CREATED. | EVTS_ALL | String
| *propagateIncomingBodyIfNo ReturnValue* (consumer) | Sets whether to propagate the incoming body if the return type of the underlying Ignite operation is void. | true | boolean
| *treatCollectionsAsCache Objects* (consumer) | Sets whether to treat Collections as cache objects or as Collections of items to insert/update/compute, etc. | false | boolean
| *exceptionHandler* (consumer) | To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the consumer will deal with exceptions, that will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
diff --git a/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/events/IgniteEventsConsumer.java b/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/events/IgniteEventsConsumer.java
index 9f448a6..d0177a8 100644
--- a/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/events/IgniteEventsConsumer.java
+++ b/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/events/IgniteEventsConsumer.java
@@ -17,6 +17,7 @@
package org.apache.camel.component.ignite.events;
import java.util.Arrays;
+import java.util.List;
import org.apache.camel.AsyncCallback;
import org.apache.camel.Exchange;
@@ -72,12 +73,11 @@ public class IgniteEventsConsumer extends DefaultConsumer {
protected void doStart() throws Exception {
super.doStart();
- if (endpoint.getEvents() != null && endpoint.getEvents().size() > 0) {
- eventTypes = new int[endpoint.getEvents().size()];
- int counter = 0;
- for (Integer i : endpoint.getEvents()) {
- eventTypes[counter++] = i;
- }
+ List<Integer> ids = endpoint.getEventsAsIds();
+ eventTypes = new int[ids.size()];
+ int counter = 0;
+ for (Integer i : ids) {
+ eventTypes[counter++] = i;
}
events.localListen(predicate, eventTypes);
diff --git a/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/events/IgniteEventsEndpoint.java b/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/events/IgniteEventsEndpoint.java
index fb9f760..5d76301 100644
--- a/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/events/IgniteEventsEndpoint.java
+++ b/components/camel-ignite/src/main/java/org/apache/camel/component/ignite/events/IgniteEventsEndpoint.java
@@ -17,8 +17,10 @@
package org.apache.camel.component.ignite.events;
import java.lang.reflect.Field;
+import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashSet;
+import java.util.List;
import java.util.Map;
import java.util.Set;
@@ -49,20 +51,14 @@ public class IgniteEventsEndpoint extends AbstractIgniteEndpoint {
@UriPath
private String endpointId;
- @UriParam(label = "consumer", javaType = "Set<Integer> or String", defaultValue = "EventType.EVTS_ALL")
- private Set<Integer> events;
+ @UriParam(label = "consumer", defaultValue = "EVTS_ALL")
+ private String events = "EVTS_ALL";
@UriParam(label = "consumer")
private ClusterGroupExpression clusterGroupExpression;
public IgniteEventsEndpoint(String uri, String remaining, Map<String, Object> parameters, IgniteEventsComponent igniteComponent) {
super(uri, igniteComponent);
-
- // Initialize subscribed event types with ALL.
- events = new HashSet<>();
- for (Integer eventType : EventType.EVTS_ALL) {
- events.add(eventType);
- }
}
@Override
@@ -116,50 +112,46 @@ public class IgniteEventsEndpoint extends AbstractIgniteEndpoint {
/**
* Gets the event types to subscribe to.
- *
- * @return
*/
- public Set<Integer> getEvents() {
+ public String getEvents() {
return events;
}
/**
- * The event IDs to subscribe to as a Set<Integer> directly where
- * the IDs are the different constants in org.apache.ignite.events.EventType.
- *
- * @param events
- */
- public void setEvents(Set<Integer> events) {
- this.events = events;
- }
-
- /**
* The event types to subscribe to as a comma-separated string of event constants as defined in {@link EventType}.
- * <p>
* For example: EVT_CACHE_ENTRY_CREATED,EVT_CACHE_OBJECT_REMOVED,EVT_IGFS_DIR_CREATED.
- *
- * @param events
*/
public void setEvents(String events) {
- this.events = new HashSet<>();
- Set<String> requestedEvents = new HashSet<>(Arrays.asList(events.toUpperCase().split(",")));
- Field[] fields = EventType.class.getDeclaredFields();
- for (Field field : fields) {
- if (!requestedEvents.contains(field.getName())) {
- continue;
+ this.events = events;
+ }
+
+ public List<Integer> getEventsAsIds() {
+ List<Integer> answer = new ArrayList<>();
+
+ if (events.equals("EVTS_ALL")) {
+ for (Integer eventType : EventType.EVTS_ALL) {
+ answer.add(eventType);
}
- try {
- this.events.add(field.getInt(null));
- } catch (Exception e) {
- throw new IllegalArgumentException("Problem while resolving event type. See stacktrace.", e);
+ } else {
+ Set<String> requestedEvents = new HashSet<>(Arrays.asList(events.toUpperCase().split(",")));
+ Field[] fields = EventType.class.getDeclaredFields();
+ for (Field field : fields) {
+ if (!requestedEvents.contains(field.getName())) {
+ continue;
+ }
+ try {
+ answer.add(field.getInt(null));
+ } catch (Exception e) {
+ throw new IllegalArgumentException("Problem while resolving event type. See stacktrace.", e);
+ }
}
}
+
+ return answer;
}
/**
* Gets the cluster group expression.
- *
- * @return cluster group expression
*/
public ClusterGroupExpression getClusterGroupExpression() {
return clusterGroupExpression;
@@ -167,8 +159,6 @@ public class IgniteEventsEndpoint extends AbstractIgniteEndpoint {
/**
* The cluster group expression.
- *
- * @param clusterGroupExpression cluster group expression
*/
public void setClusterGroupExpression(ClusterGroupExpression clusterGroupExpression) {
this.clusterGroupExpression = clusterGroupExpression;
diff --git a/components/camel-ignite/src/test/java/org/apache/camel/component/ignite/IgniteEventsTest.java b/components/camel-ignite/src/test/java/org/apache/camel/component/ignite/IgniteEventsTest.java
index 12be923..d2239f7 100644
--- a/components/camel-ignite/src/test/java/org/apache/camel/component/ignite/IgniteEventsTest.java
+++ b/components/camel-ignite/src/test/java/org/apache/camel/component/ignite/IgniteEventsTest.java
@@ -86,35 +86,6 @@ public class IgniteEventsTest extends AbstractIgniteTest {
}
@Test
- public void testConsumeFilteredEventsWithRef() throws Exception {
- context.getRegistry().bind("filter", Sets.newHashSet(EventType.EVT_CACHE_OBJECT_PUT));
-
- context.addRoutes(new RouteBuilder() {
- @Override
- public void configure() throws Exception {
- from("ignite-events:" + resourceUid + "?events=#filter").to("mock:test2");
- }
- });
-
- getMockEndpoint("mock:test2").expectedMessageCount(2);
-
- IgniteCache<String, String> cache = ignite().getOrCreateCache(resourceUid);
-
- // Generate cache activity.
- cache.put(resourceUid, "123");
- cache.get(resourceUid);
- cache.remove(resourceUid);
- cache.get(resourceUid);
- cache.put(resourceUid, "123");
-
- assertMockEndpointsSatisfied();
-
- List<Integer> eventTypes = receivedEventTypes("mock:test2");
-
- assert_().that(eventTypes).containsExactly(EventType.EVT_CACHE_OBJECT_PUT, EventType.EVT_CACHE_OBJECT_PUT).inOrder();
- }
-
- @Test
public void testConsumeFilteredEventsInline() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
diff --git a/components/camel-jcache/src/main/java/org/apache/camel/component/jcache/JCacheEndpoint.java b/components/camel-jcache/src/main/java/org/apache/camel/component/jcache/JCacheEndpoint.java
index f6a3225..83d5fa9 100644
--- a/components/camel-jcache/src/main/java/org/apache/camel/component/jcache/JCacheEndpoint.java
+++ b/components/camel-jcache/src/main/java/org/apache/camel/component/jcache/JCacheEndpoint.java
@@ -35,7 +35,7 @@ public class JCacheEndpoint extends DefaultEndpoint {
@Metadata(required = true)
private final String cacheName;
@UriParam
- private final JCacheConfiguration cacheConfiguration;
+ private final JCacheConfiguration configuration;
private volatile JCacheManager<Object, Object> cacheManager;
@@ -43,12 +43,16 @@ public class JCacheEndpoint extends DefaultEndpoint {
super(uri, component);
this.cacheName = configuration.getCacheName();
- this.cacheConfiguration = configuration;
+ this.configuration = configuration;
+ }
+
+ public JCacheConfiguration getConfiguration() {
+ return configuration;
}
@Override
public Producer createProducer() throws Exception {
- return new JCacheProducer(this, cacheConfiguration);
+ return new JCacheProducer(this, configuration);
}
@Override
@@ -58,7 +62,7 @@ public class JCacheEndpoint extends DefaultEndpoint {
@Override
protected void doStart() throws Exception {
- cacheManager = JCacheHelper.createManager(cacheConfiguration);
+ cacheManager = JCacheHelper.createManager(configuration);
}
@Override
diff --git a/components/camel-jira/src/main/java/org/apache/camel/component/jira/JiraEndpoint.java b/components/camel-jira/src/main/java/org/apache/camel/component/jira/JiraEndpoint.java
index b9b468f..9c3baf8 100644
--- a/components/camel-jira/src/main/java/org/apache/camel/component/jira/JiraEndpoint.java
+++ b/components/camel-jira/src/main/java/org/apache/camel/component/jira/JiraEndpoint.java
@@ -86,6 +86,10 @@ public class JiraEndpoint extends DefaultEndpoint {
this.configuration = configuration;
}
+ public JiraConfiguration getConfiguration() {
+ return configuration;
+ }
+
@Override
public void doStart() throws Exception {
super.doStart();
diff --git a/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXConsumer.java b/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXConsumer.java
index 7c5b37e..1d3a398 100644
--- a/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXConsumer.java
+++ b/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXConsumer.java
@@ -115,7 +115,7 @@ public class JMXConsumer extends DefaultConsumer implements NotificationListener
try {
initNetworkConnection();
} catch (IOException e) {
- if (!mJmxEndpoint.getTestConnectionOnStartup()) {
+ if (!mJmxEndpoint.isTestConnectionOnStartup()) {
log.warn("Failed to connect to JMX server. >> {}", e.getMessage());
scheduleDelayedStart();
return;
@@ -197,7 +197,7 @@ public class JMXConsumer extends DefaultConsumer implements NotificationListener
|| connectionNotification.getType().equals(JMXConnectionNotification.CLOSED)
|| connectionNotification.getType().equals(JMXConnectionNotification.FAILED)) {
log.warn("Lost JMX connection for : {}", URISupport.sanitizeUri(mJmxEndpoint.getEndpointUri()));
- if (mJmxEndpoint.getReconnectOnConnectionFailure()) {
+ if (mJmxEndpoint.isReconnectOnConnectionFailure()) {
scheduleReconnect();
} else {
log.warn("The JMX consumer will not be reconnected. Use 'reconnectOnConnectionFailure' to "
diff --git a/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXEndpoint.java b/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXEndpoint.java
index 0e7af35..961d7e7 100644
--- a/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXEndpoint.java
+++ b/components/camel-jmx/src/main/java/org/apache/camel/component/jmx/JMXEndpoint.java
@@ -507,7 +507,7 @@ public class JMXEndpoint extends DefaultEndpoint {
stringToCompare = aStringToCompare;
}
- public boolean getTestConnectionOnStartup() {
+ public boolean isTestConnectionOnStartup() {
return this.testConnectionOnStartup;
}
@@ -515,7 +515,7 @@ public class JMXEndpoint extends DefaultEndpoint {
this.testConnectionOnStartup = testConnectionOnStartup;
}
- public boolean getReconnectOnConnectionFailure() {
+ public boolean isReconnectOnConnectionFailure() {
return this.reconnectOnConnectionFailure;
}
diff --git a/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java b/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java
index 70ef706..777a0ab 100644
--- a/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java
+++ b/components/camel-jpa/src/main/java/org/apache/camel/component/jpa/JpaEndpoint.java
@@ -135,7 +135,7 @@ public class JpaEndpoint extends ScheduledPollEndpoint {
producer.setParameters(getParameters());
producer.setResultClass(getResultClass());
producer.setFindEntity(isFindEntity());
- producer.setUseExecuteUpdate(isUseExecuteUpdate());
+ producer.setUseExecuteUpdate(getUseExecuteUpdate());
return producer;
}
@@ -499,7 +499,7 @@ public class JpaEndpoint extends ScheduledPollEndpoint {
this.preDeleteHandler = preDeleteHandler;
}
- public Boolean isUseExecuteUpdate() {
+ public Boolean getUseExecuteUpdate() {
return useExecuteUpdate;
}
diff --git a/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400Endpoint.java b/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400Endpoint.java
index 420274f..4b5d99a 100644
--- a/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400Endpoint.java
+++ b/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400Endpoint.java
@@ -70,6 +70,10 @@ public class Jt400Endpoint extends ScheduledPollEndpoint implements MultipleCons
}
}
+ public Jt400Configuration getConfiguration() {
+ return configuration;
+ }
+
@Override
public Producer createProducer() throws Exception {
if (Jt400Type.DTAQ == configuration.getType()) {
diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
index 4c9d0ce..71564fe 100644
--- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
+++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
@@ -409,7 +409,7 @@ public class KafkaConfiguration implements Cloneable, HeaderFilterStrategyAware
addPropertyIfNotNull(props, ConsumerConfig.INTERCEPTOR_CLASSES_CONFIG, getInterceptorClasses());
addPropertyIfNotNull(props, ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, getAutoOffsetReset());
addPropertyIfNotNull(props, ConsumerConfig.CONNECTIONS_MAX_IDLE_MS_CONFIG, getConnectionMaxIdleMs());
- addPropertyIfNotNull(props, ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, isAutoCommitEnable());
+ addPropertyIfNotNull(props, ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, getAutoCommitEnable());
addPropertyIfNotNull(props, ConsumerConfig.PARTITION_ASSIGNMENT_STRATEGY_CONFIG, getPartitionAssignor());
addPropertyIfNotNull(props, ConsumerConfig.RECEIVE_BUFFER_CONFIG, getReceiveBufferBytes());
addPropertyIfNotNull(props, ConsumerConfig.REQUEST_TIMEOUT_MS_CONFIG, getConsumerRequestTimeoutMs());
@@ -645,10 +645,14 @@ public class KafkaConfiguration implements Cloneable, HeaderFilterStrategyAware
this.clientId = clientId;
}
- public Boolean isAutoCommitEnable() {
+ public boolean isAutoCommitEnable() {
return offsetRepository == null ? autoCommitEnable : false;
}
+ public Boolean getAutoCommitEnable() {
+ return autoCommitEnable;
+ }
+
/**
* If true, periodically commit to ZooKeeper the offset of messages already
* fetched by the consumer. This committed offset will be used when the
diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
index e644a10..aa3bb76 100644
--- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
+++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
@@ -490,7 +490,7 @@ public class KafkaConsumer extends DefaultConsumer {
}
private boolean isAutoCommitEnabled() {
- return endpoint.getConfiguration().isAutoCommitEnable() != null && endpoint.getConfiguration().isAutoCommitEnable();
+ return endpoint.getConfiguration().getAutoCommitEnable() != null && endpoint.getConfiguration().getAutoCommitEnable();
}
protected String serializeOffsetKey(TopicPartition topicPartition) {
diff --git a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/AbstractKubernetesEndpoint.java b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/AbstractKubernetesEndpoint.java
index 10d2d3c..9904f7e 100644
--- a/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/AbstractKubernetesEndpoint.java
+++ b/components/camel-kubernetes/src/main/java/org/apache/camel/component/kubernetes/AbstractKubernetesEndpoint.java
@@ -38,6 +38,10 @@ public abstract class AbstractKubernetesEndpoint extends DefaultEndpoint {
this.configuration = config;
}
+ public KubernetesConfiguration getConfiguration() {
+ return configuration;
+ }
+
@Override
public boolean isSingleton() {
return false;