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:44 UTC
[camel] 04/05: CAMEL-13870: Fast property configuration of Camel
endpoints. Work in progress.
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