This is an automated email from the ASF dual-hosted git repository.
apupier pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new b8debda9a865 Removal of Hazelcast-atomicvalue
b8debda9a865 is described below
commit b8debda9a865b161d1987ac7f2379b934640c1ba
Author: Aurélien Pupier <[email protected]>
AuthorDate: Tue Sep 15 10:55:41 2026 +0200
Removal of Hazelcast-atomicvalue
The component `camel-hazelcast-atomicvalue` was deprecated in 4.19.0.
In hazelcast 5.5+, the CP subsystem is only available in the enterprise
edition of hazelcast. `hazelcast-pncounter` is a partial replacement.
Signed-off-by: Aurélien Pupier <[email protected]>
---
.../org/apache/camel/catalog/components.properties | 1 -
.../catalog/components/hazelcast-atomicvalue.json | 43 ---
.../org/apache/camel/catalog/docs.properties | 1 -
.../docs/hazelcast-atomicvalue-component.adoc | 270 -------------------
.../HazelcastAtomicnumberComponentConfigurer.java | 69 -----
.../HazelcastAtomicnumberEndpointConfigurer.java | 75 ------
.../HazelcastAtomicnumberEndpointUriFactory.java | 82 ------
.../atomicnumber/hazelcast-atomicvalue.json | 43 ---
.../services/org/apache/camel/component.properties | 2 +-
.../apache/camel/component/hazelcast-atomicvalue | 2 -
.../main/docs/hazelcast-atomicvalue-component.adoc | 270 -------------------
.../component/hazelcast/HazelcastCommand.java | 1 -
.../component/hazelcast/HazelcastConstants.java | 4 +-
.../HazelcastAtomicnumberComponent.java | 50 ----
.../HazelcastAtomicnumberEndpoint.java | 62 -----
.../HazelcastAtomicnumberProducer.java | 133 ---------
...HazelcastAtomicnumberProducerForSpringTest.java | 126 ---------
.../HazelcastAtomicnumberProducerTest.java | 182 -------------
.../hazelcast/HazelcastCamelTestHelper.java | 4 -
.../hazelcast/HazelcastErrorMessagesTest.java | 21 +-
.../spring/test-camel-context-atomicnumber.xml | 86 ------
.../org/apache/camel/main/components.properties | 1 -
.../ROOT/examples/json/hazelcast-atomicvalue.json | 1 -
docs/components/modules/ROOT/nav.adoc | 1 -
.../pages/hazelcast-atomicvalue-component.adoc | 1 -
.../ROOT/pages/camel-4x-upgrade-guide-4_23.adoc | 6 +
.../component/ComponentsBuilderFactory.java | 14 -
...azelcastAtomicvalueComponentBuilderFactory.java | 160 -----------
.../builder/endpoint/EndpointBuilderFactory.java | 1 -
.../camel/builder/endpoint/EndpointBuilders.java | 1 -
.../builder/endpoint/EndpointHeaderBuilders.java | 15 --
.../builder/endpoint/StaticEndpointBuilders.java | 44 ---
...azelcastAtomicnumberEndpointBuilderFactory.java | 299 ---------------------
.../camel-component-known-dependencies.properties | 1 -
34 files changed, 11 insertions(+), 2061 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
index 9f7553286bfe..597f3a6a0ea2 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
@@ -158,7 +158,6 @@ google-vision
graphql
grpc
hashicorp-vault
-hazelcast-atomicvalue
hazelcast-instance
hazelcast-list
hazelcast-map
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/hazelcast-atomicvalue.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/hazelcast-atomicvalue.json
deleted file mode 100644
index 220dc2beb10d..000000000000
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/hazelcast-atomicvalue.json
+++ /dev/null
@@ -1,43 +0,0 @@
-{
- "component": {
- "kind": "component",
- "name": "hazelcast-atomicvalue",
- "title": "Hazelcast Atomic Number",
- "description": "Increment, decrement, set, etc. Hazelcast atomic number (a
grid wide number).",
- "deprecated": true,
- "firstVersion": "2.7.0",
- "label": "cache,clustering",
- "javaType":
"org.apache.camel.component.hazelcast.atomicnumber.HazelcastAtomicnumberComponent",
- "supportLevel": "Stable",
- "groupId": "org.apache.camel",
- "artifactId": "camel-hazelcast",
- "version": "4.23.0-SNAPSHOT",
- "scheme": "hazelcast-atomicvalue",
- "extendsScheme": "",
- "syntax": "hazelcast-atomicvalue:cacheName",
- "async": false,
- "api": false,
- "consumerOnly": false,
- "producerOnly": true,
- "lenientProperties": false,
- "browsable": false,
- "remote": true
- },
- "componentProperties": {
- "lazyStartProducer": { "index": 0, "kind": "property", "displayName":
"Lazy Start Producer", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"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 [...]
- "autowiredEnabled": { "index": 1, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Whether autowiring is enabled. This is used for automatic autowiring options
(the option must be marked as autowired) by looking up in the registry to find
if there is a single instance of matching t [...]
- "hazelcastInstance": { "index": 2, "kind": "property", "displayName":
"Hazelcast Instance", "group": "advanced", "label": "advanced", "required":
false, "type": "object", "javaType": "com.hazelcast.core.HazelcastInstance",
"deprecated": false, "autowired": false, "secret": false, "description": "The
hazelcast instance reference 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 insta [...]
- "hazelcastMode": { "index": 3, "kind": "property", "displayName":
"Hazelcast Mode", "group": "advanced", "label": "advanced", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "node", "description":
"The hazelcast mode reference which kind of instance should be used. If you
don't specify the mode, then the node mode will be the default." }
- },
- "headers": {
- "CamelHazelcastOperationType": { "index": 0, "kind": "header",
"displayName": "", "group": "producer", "label": "producer", "required": false,
"javaType": "String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The operation to perform",
"constantName":
"org.apache.camel.component.hazelcast.HazelcastConstants#OPERATION" }
- },
- "properties": {
- "cacheName": { "index": 0, "kind": "path", "displayName": "Cache Name",
"group": "producer", "label": "", "required": true, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "The name of the cache" },
- "defaultOperation": { "index": 1, "kind": "parameter", "displayName":
"Default Operation", "group": "producer", "label": "", "required": false,
"type": "enum", "javaType":
"org.apache.camel.component.hazelcast.HazelcastOperation", "enum": [ "put",
"delete", "get", "update", "query", "getAll", "clear", "putIfAbsent", "addAll",
"removeAll", "retainAll", "evict", "evictAll", "valueCount", "containsKey",
"containsValue", "getKeys", "removeValue", "increment", "decrement",
"setValue", "de [...]
- "hazelcastConfigUri": { "index": 2, "kind": "parameter", "displayName":
"Hazelcast Config Uri", "group": "producer", "label": "", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false,
"supportFileReference": true, "description": "Hazelcast configuration file." },
- "hazelcastInstance": { "index": 3, "kind": "parameter", "displayName":
"Hazelcast Instance", "group": "producer", "label": "", "required": false,
"type": "object", "javaType": "com.hazelcast.core.HazelcastInstance",
"deprecated": false, "autowired": false, "secret": false, "description": "The
hazelcast instance reference which can be used for hazelcast endpoint." },
- "hazelcastInstanceName": { "index": 4, "kind": "parameter", "displayName":
"Hazelcast Instance Name", "group": "producer", "label": "", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "description": "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." },
- "lazyStartProducer": { "index": 5, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "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 produc [...]
- }
-}
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs.properties
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs.properties
index 14faa8f37cd3..9df506bc5e9b 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs.properties
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs.properties
@@ -240,7 +240,6 @@ gson-dataformat
guaranteed-delivery
gzipDeflater-dataformat
hashicorp-vault-component
-hazelcast-atomicvalue-component
hazelcast-instance-component
hazelcast-list-component
hazelcast-map-component
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/hazelcast-atomicvalue-component.adoc
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/hazelcast-atomicvalue-component.adoc
deleted file mode 100644
index 4e52d3ce89c9..000000000000
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/hazelcast-atomicvalue-component.adoc
+++ /dev/null
@@ -1,270 +0,0 @@
-= Hazelcast Atomic Number Component (deprecated)
-:doctitle: Hazelcast Atomic Number
-:shortname: hazelcast-atomicvalue
-:artifactid: camel-hazelcast
-:description: Increment, decrement, set, etc. Hazelcast atomic number (a grid
wide number).
-:since: 2.7
-:supportlevel: Stable-deprecated
-:deprecated: *deprecated*
-:tabs-sync-option:
-:component-header: Only producer is supported
-//Manually maintained attributes
-:group: Hazelcast
-
-*Since Camel {since}*
-
-*{component-header}*
-
-[WARNING]
-====
-*Deprecated*: This component is deprecated as of Camel 4.19.0 and will be
removed in a future release.
-
-Since Hazelcast 5.5, IAtomicLong requires the CP Subsystem which is only
available in Hazelcast Enterprise Edition.
-This component will throw `UnsupportedOperationException` at runtime when used
with Hazelcast Community Edition 5.5+.
-====
-
-The http://www.hazelcast.com/[Hazelcast] atomic number component is one of
Camel Hazelcast Components which allows you to access Hazelcast atomic number.
-An atomic number is an object that simply provides a grid wide number (long).
-
-
-// component options: START
-include::partial$component-configure-options.adoc[]
-include::partial$component-endpoint-options.adoc[]
-include::partial$component-endpoint-headers.adoc[]
-// component options: END
-
-
-== atomic number producer - to("hazelcast-atomicvalue:foo")
-
-The operations for this producer are:
-
-* setvalue (set the number with a given value)
-* get
-* increment (+1)
-* decrement (-1)
-* destroy
-* compareAndSet
-* getAndAdd
-
-=== Example for *set*:
-
-[tabs]
-====
-Java::
-+
-[source,java]
-----
-from("direct:set")
- .setHeader("CamelHazelcastOperationType", constant("setValue"))
- .to("hazelcast-atomicvalue:foo");
-----
-
-XML::
-+
-[source,xml]
-----
-<route>
- <from uri="direct:set"/>
- <setHeader name="hazelcast.operation.type">
- <constant>setvalue</constant>
- </setHeader>
- <to uri="hazelcast-atomicvalue:foo"/>
-</route>
-----
-
-YAML::
-+
-[source,yaml]
-----
-- route:
- from:
- uri: direct:set
- steps:
- - setHeader:
- name: hazelcast.operation.type
- constant: setvalue
- - to:
- uri: hazelcast-atomicvalue:foo
-----
-====
-
-Provide the value to set inside the message body (here the value is 10):
-`template.sendBody("direct:set", 10);`
-
-=== Example for *get*:
-
-[tabs]
-====
-Java::
-+
-[source,java]
-----
-from("direct:get")
- .setHeader("CamelHazelcastOperationType", constant("get"))
- .to("hazelcast-atomicvalue:foo");
-----
-
-XML::
-+
-[source,xml]
-----
-<route>
- <from uri="direct:get"/>
- <setHeader name="hazelcast.operation.type">
- <constant>get</constant>
- </setHeader>
- <to uri="hazelcast-atomicvalue:foo"/>
-</route>
-----
-
-YAML::
-+
-[source,yaml]
-----
-- route:
- from:
- uri: direct:get
- steps:
- - setHeader:
- name: hazelcast.operation.type
- constant: get
- - to:
- uri: hazelcast-atomicvalue:foo
-----
-====
-
-You can get the number with
-`long body = template.requestBody("direct:get", null, Long.class);`.
-
-=== Example for *increment*:
-
-[tabs]
-====
-Java::
-+
-[source,java]
-----
-from("direct:increment")
- .setHeader("CamelHazelcastOperationType", constant("increment"))
- .to("hazelcast-atomicvalue:foo");
-----
-
-XML::
-+
-[source,xml]
-----
-<route>
- <from uri="direct:increment"/>
- <setHeader name="hazelcast.operation.type">
- <constant>increment</constant>
- </setHeader>
- <to uri="hazelcast-atomicvalue:foo"/>
-</route>
-----
-
-YAML::
-+
-[source,yaml]
-----
-- route:
- from:
- uri: direct:increment
- steps:
- - setHeader:
- name: hazelcast.operation.type
- constant: increment
- - to:
- uri: hazelcast-atomicvalue:foo
-----
-====
-
-The actual value (after increment) will be provided inside the message
-body.
-
-=== Example for *decrement*:
-
-[tabs]
-====
-Java::
-+
-[source,java]
-----
-from("direct:decrement")
- .setHeader("CamelHazelcastOperationType", constant("decrement"))
- .to("hazelcast-atomicvalue:foo");
-----
-
-XML::
-+
-[source,xml]
-----
-<route>
- <from uri="direct:decrement"/>
- <setHeader name="hazelcast.operation.type">
- <constant>decrement</constant>
- </setHeader>
- <to uri="hazelcast-atomicvalue:foo"/>
-</route>
-----
-
-YAML::
-+
-[source,yaml]
-----
-- route:
- from:
- uri: direct:decrement
- steps:
- - setHeader:
- name: hazelcast.operation.type
- constant: decrement
- - to:
- uri: hazelcast-atomicvalue:foo
-----
-====
-
-The actual value (after decrement) will be provided inside the message
-body.
-
-=== Example for *destroy*
-
-[tabs]
-====
-Java::
-+
-[source,java]
-----
-from("direct:destroy")
- .setHeader("CamelHazelcastOperationType", constant("destroy"))
- .to("hazelcast-atomicvalue:foo");
-----
-
-XML::
-+
-[source,xml]
-----
-<route>
- <from uri="direct:destroy"/>
- <setHeader name="hazelcast.operation.type">
- <constant>destroy</constant>
- </setHeader>
- <to uri="hazelcast-atomicvalue:foo"/>
-</route>
-----
-
-YAML::
-+
-[source,yaml]
-----
-- route:
- from:
- uri: direct:destroy
- steps:
- - setHeader:
- name: hazelcast.operation.type
- constant: destroy
- - to:
- uri: hazelcast-atomicvalue:foo
-----
-====
-
diff --git
a/components/camel-hazelcast/src/generated/java/org/apache/camel/component/hazelcast/atomicnumber/HazelcastAtomicnumberComponentConfigurer.java
b/components/camel-hazelcast/src/generated/java/org/apache/camel/component/hazelcast/atomicnumber/HazelcastAtomicnumberComponentConfigurer.java
deleted file mode 100644
index 384f339f19f3..000000000000
---
a/components/camel-hazelcast/src/generated/java/org/apache/camel/component/hazelcast/atomicnumber/HazelcastAtomicnumberComponentConfigurer.java
+++ /dev/null
@@ -1,69 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-package org.apache.camel.component.hazelcast.atomicnumber;
-
-import javax.annotation.processing.Generated;
-import java.util.Map;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.spi.ExtendedPropertyConfigurerGetter;
-import org.apache.camel.spi.PropertyConfigurerGetter;
-import org.apache.camel.spi.ConfigurerStrategy;
-import org.apache.camel.spi.GeneratedPropertyConfigurer;
-import org.apache.camel.util.CaseInsensitiveMap;
-import org.apache.camel.support.component.PropertyConfigurerSupport;
-
-/**
- * Generated by camel build tools - do NOT edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.EndpointSchemaGeneratorMojo")
-@SuppressWarnings("unchecked")
-public class HazelcastAtomicnumberComponentConfigurer extends
PropertyConfigurerSupport implements GeneratedPropertyConfigurer,
PropertyConfigurerGetter {
-
- @Override
- public boolean configure(CamelContext camelContext, Object obj, String
name, Object value, boolean ignoreCase) {
- HazelcastAtomicnumberComponent target =
(HazelcastAtomicnumberComponent) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "autowiredenabled":
- case "autowiredEnabled":
target.setAutowiredEnabled(property(camelContext, boolean.class, value));
return true;
- case "hazelcastinstance":
- case "hazelcastInstance":
target.setHazelcastInstance(property(camelContext,
com.hazelcast.core.HazelcastInstance.class, value)); return true;
- case "hazelcastmode":
- case "hazelcastMode": target.setHazelcastMode(property(camelContext,
java.lang.String.class, value)); return true;
- case "lazystartproducer":
- case "lazyStartProducer":
target.setLazyStartProducer(property(camelContext, boolean.class, value));
return true;
- default: return false;
- }
- }
-
- @Override
- public Class<?> getOptionType(String name, boolean ignoreCase) {
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "autowiredenabled":
- case "autowiredEnabled": return boolean.class;
- case "hazelcastinstance":
- case "hazelcastInstance": return
com.hazelcast.core.HazelcastInstance.class;
- case "hazelcastmode":
- case "hazelcastMode": return java.lang.String.class;
- case "lazystartproducer":
- case "lazyStartProducer": return boolean.class;
- default: return null;
- }
- }
-
- @Override
- public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
- HazelcastAtomicnumberComponent target =
(HazelcastAtomicnumberComponent) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "autowiredenabled":
- case "autowiredEnabled": return target.isAutowiredEnabled();
- case "hazelcastinstance":
- case "hazelcastInstance": return target.getHazelcastInstance();
- case "hazelcastmode":
- case "hazelcastMode": return target.getHazelcastMode();
- case "lazystartproducer":
- case "lazyStartProducer": return target.isLazyStartProducer();
- default: return null;
- }
- }
-}
-
diff --git
a/components/camel-hazelcast/src/generated/java/org/apache/camel/component/hazelcast/atomicnumber/HazelcastAtomicnumberEndpointConfigurer.java
b/components/camel-hazelcast/src/generated/java/org/apache/camel/component/hazelcast/atomicnumber/HazelcastAtomicnumberEndpointConfigurer.java
deleted file mode 100644
index 262c19f0158b..000000000000
---
a/components/camel-hazelcast/src/generated/java/org/apache/camel/component/hazelcast/atomicnumber/HazelcastAtomicnumberEndpointConfigurer.java
+++ /dev/null
@@ -1,75 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-package org.apache.camel.component.hazelcast.atomicnumber;
-
-import javax.annotation.processing.Generated;
-import java.util.Map;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.spi.ExtendedPropertyConfigurerGetter;
-import org.apache.camel.spi.PropertyConfigurerGetter;
-import org.apache.camel.spi.ConfigurerStrategy;
-import org.apache.camel.spi.GeneratedPropertyConfigurer;
-import org.apache.camel.util.CaseInsensitiveMap;
-import org.apache.camel.support.component.PropertyConfigurerSupport;
-
-/**
- * Generated by camel build tools - do NOT edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.EndpointSchemaGeneratorMojo")
-@SuppressWarnings("unchecked")
-public class HazelcastAtomicnumberEndpointConfigurer extends
PropertyConfigurerSupport implements GeneratedPropertyConfigurer,
PropertyConfigurerGetter {
-
- @Override
- public boolean configure(CamelContext camelContext, Object obj, String
name, Object value, boolean ignoreCase) {
- HazelcastAtomicnumberEndpoint target = (HazelcastAtomicnumberEndpoint)
obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "defaultoperation":
- case "defaultOperation":
target.setDefaultOperation(property(camelContext,
org.apache.camel.component.hazelcast.HazelcastOperation.class, value)); return
true;
- case "hazelcastconfiguri":
- case "hazelcastConfigUri":
target.setHazelcastConfigUri(property(camelContext, java.lang.String.class,
value)); return true;
- case "hazelcastinstance":
- case "hazelcastInstance":
target.setHazelcastInstance(property(camelContext,
com.hazelcast.core.HazelcastInstance.class, value)); return true;
- case "hazelcastinstancename":
- case "hazelcastInstanceName":
target.setHazelcastInstanceName(property(camelContext, java.lang.String.class,
value)); return true;
- case "lazystartproducer":
- case "lazyStartProducer":
target.setLazyStartProducer(property(camelContext, boolean.class, value));
return true;
- default: return false;
- }
- }
-
- @Override
- public Class<?> getOptionType(String name, boolean ignoreCase) {
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "defaultoperation":
- case "defaultOperation": return
org.apache.camel.component.hazelcast.HazelcastOperation.class;
- case "hazelcastconfiguri":
- case "hazelcastConfigUri": return java.lang.String.class;
- case "hazelcastinstance":
- case "hazelcastInstance": return
com.hazelcast.core.HazelcastInstance.class;
- case "hazelcastinstancename":
- case "hazelcastInstanceName": return java.lang.String.class;
- case "lazystartproducer":
- case "lazyStartProducer": return boolean.class;
- default: return null;
- }
- }
-
- @Override
- public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
- HazelcastAtomicnumberEndpoint target = (HazelcastAtomicnumberEndpoint)
obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "defaultoperation":
- case "defaultOperation": return target.getDefaultOperation();
- case "hazelcastconfiguri":
- case "hazelcastConfigUri": return target.getHazelcastConfigUri();
- case "hazelcastinstance":
- case "hazelcastInstance": return target.getHazelcastInstance();
- case "hazelcastinstancename":
- case "hazelcastInstanceName": return target.getHazelcastInstanceName();
- case "lazystartproducer":
- case "lazyStartProducer": return target.isLazyStartProducer();
- default: return null;
- }
- }
-}
-
diff --git
a/components/camel-hazelcast/src/generated/java/org/apache/camel/component/hazelcast/atomicnumber/HazelcastAtomicnumberEndpointUriFactory.java
b/components/camel-hazelcast/src/generated/java/org/apache/camel/component/hazelcast/atomicnumber/HazelcastAtomicnumberEndpointUriFactory.java
deleted file mode 100644
index 059339f22817..000000000000
---
a/components/camel-hazelcast/src/generated/java/org/apache/camel/component/hazelcast/atomicnumber/HazelcastAtomicnumberEndpointUriFactory.java
+++ /dev/null
@@ -1,82 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-package org.apache.camel.component.hazelcast.atomicnumber;
-
-import javax.annotation.processing.Generated;
-import java.net.URISyntaxException;
-import java.util.Collections;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.Map;
-import java.util.Set;
-
-import org.apache.camel.spi.EndpointUriFactory;
-
-/**
- * Generated by camel build tools - do NOT edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.GenerateEndpointUriFactoryMojo")
-public class HazelcastAtomicnumberEndpointUriFactory extends
org.apache.camel.support.component.EndpointUriFactorySupport implements
EndpointUriFactory {
-
- private static final String BASE = ":cacheName";
-
- private static final Set<String> PROPERTY_NAMES;
- private static final Set<String> SECRET_PROPERTY_NAMES;
- private static final Set<String> ENDPOINT_IDENTITY_PROPERTY_NAMES;
- private static final Map<String, String> MULTI_VALUE_PREFIXES;
- static {
- Set<String> props = new HashSet<>(6);
- props.add("cacheName");
- props.add("defaultOperation");
- props.add("hazelcastConfigUri");
- props.add("hazelcastInstance");
- props.add("hazelcastInstanceName");
- props.add("lazyStartProducer");
- PROPERTY_NAMES = Collections.unmodifiableSet(props);
- SECRET_PROPERTY_NAMES = Collections.emptySet();
- ENDPOINT_IDENTITY_PROPERTY_NAMES = Collections.emptySet();
- MULTI_VALUE_PREFIXES = Collections.emptyMap();
- }
-
- @Override
- public boolean isEnabled(String scheme) {
- return "hazelcast-atomicvalue".equals(scheme);
- }
-
- @Override
- public String buildUri(String scheme, Map<String, Object> properties,
boolean encode) throws URISyntaxException {
- String syntax = scheme + BASE;
- String uri = syntax;
-
- Map<String, Object> copy = new HashMap<>(properties);
-
- uri = buildPathParameter(syntax, uri, "cacheName", null, true, copy);
- uri = buildQueryParameters(uri, copy, encode);
- return uri;
- }
-
- @Override
- public Set<String> propertyNames() {
- return PROPERTY_NAMES;
- }
-
- @Override
- public Set<String> secretPropertyNames() {
- return SECRET_PROPERTY_NAMES;
- }
-
- @Override
- public Set<String> endpointIdentityPropertyNames() {
- return ENDPOINT_IDENTITY_PROPERTY_NAMES;
- }
-
- @Override
- public Map<String, String> multiValuePrefixes() {
- return MULTI_VALUE_PREFIXES;
- }
-
- @Override
- public boolean isLenientProperties() {
- return false;
- }
-}
-
diff --git
a/components/camel-hazelcast/src/generated/resources/META-INF/org/apache/camel/component/hazelcast/atomicnumber/hazelcast-atomicvalue.json
b/components/camel-hazelcast/src/generated/resources/META-INF/org/apache/camel/component/hazelcast/atomicnumber/hazelcast-atomicvalue.json
deleted file mode 100644
index 220dc2beb10d..000000000000
---
a/components/camel-hazelcast/src/generated/resources/META-INF/org/apache/camel/component/hazelcast/atomicnumber/hazelcast-atomicvalue.json
+++ /dev/null
@@ -1,43 +0,0 @@
-{
- "component": {
- "kind": "component",
- "name": "hazelcast-atomicvalue",
- "title": "Hazelcast Atomic Number",
- "description": "Increment, decrement, set, etc. Hazelcast atomic number (a
grid wide number).",
- "deprecated": true,
- "firstVersion": "2.7.0",
- "label": "cache,clustering",
- "javaType":
"org.apache.camel.component.hazelcast.atomicnumber.HazelcastAtomicnumberComponent",
- "supportLevel": "Stable",
- "groupId": "org.apache.camel",
- "artifactId": "camel-hazelcast",
- "version": "4.23.0-SNAPSHOT",
- "scheme": "hazelcast-atomicvalue",
- "extendsScheme": "",
- "syntax": "hazelcast-atomicvalue:cacheName",
- "async": false,
- "api": false,
- "consumerOnly": false,
- "producerOnly": true,
- "lenientProperties": false,
- "browsable": false,
- "remote": true
- },
- "componentProperties": {
- "lazyStartProducer": { "index": 0, "kind": "property", "displayName":
"Lazy Start Producer", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"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 [...]
- "autowiredEnabled": { "index": 1, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Whether autowiring is enabled. This is used for automatic autowiring options
(the option must be marked as autowired) by looking up in the registry to find
if there is a single instance of matching t [...]
- "hazelcastInstance": { "index": 2, "kind": "property", "displayName":
"Hazelcast Instance", "group": "advanced", "label": "advanced", "required":
false, "type": "object", "javaType": "com.hazelcast.core.HazelcastInstance",
"deprecated": false, "autowired": false, "secret": false, "description": "The
hazelcast instance reference 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 insta [...]
- "hazelcastMode": { "index": 3, "kind": "property", "displayName":
"Hazelcast Mode", "group": "advanced", "label": "advanced", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "node", "description":
"The hazelcast mode reference which kind of instance should be used. If you
don't specify the mode, then the node mode will be the default." }
- },
- "headers": {
- "CamelHazelcastOperationType": { "index": 0, "kind": "header",
"displayName": "", "group": "producer", "label": "producer", "required": false,
"javaType": "String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The operation to perform",
"constantName":
"org.apache.camel.component.hazelcast.HazelcastConstants#OPERATION" }
- },
- "properties": {
- "cacheName": { "index": 0, "kind": "path", "displayName": "Cache Name",
"group": "producer", "label": "", "required": true, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "The name of the cache" },
- "defaultOperation": { "index": 1, "kind": "parameter", "displayName":
"Default Operation", "group": "producer", "label": "", "required": false,
"type": "enum", "javaType":
"org.apache.camel.component.hazelcast.HazelcastOperation", "enum": [ "put",
"delete", "get", "update", "query", "getAll", "clear", "putIfAbsent", "addAll",
"removeAll", "retainAll", "evict", "evictAll", "valueCount", "containsKey",
"containsValue", "getKeys", "removeValue", "increment", "decrement",
"setValue", "de [...]
- "hazelcastConfigUri": { "index": 2, "kind": "parameter", "displayName":
"Hazelcast Config Uri", "group": "producer", "label": "", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false,
"supportFileReference": true, "description": "Hazelcast configuration file." },
- "hazelcastInstance": { "index": 3, "kind": "parameter", "displayName":
"Hazelcast Instance", "group": "producer", "label": "", "required": false,
"type": "object", "javaType": "com.hazelcast.core.HazelcastInstance",
"deprecated": false, "autowired": false, "secret": false, "description": "The
hazelcast instance reference which can be used for hazelcast endpoint." },
- "hazelcastInstanceName": { "index": 4, "kind": "parameter", "displayName":
"Hazelcast Instance Name", "group": "producer", "label": "", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "description": "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." },
- "lazyStartProducer": { "index": 5, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "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 produc [...]
- }
-}
diff --git
a/components/camel-hazelcast/src/generated/resources/META-INF/services/org/apache/camel/component.properties
b/components/camel-hazelcast/src/generated/resources/META-INF/services/org/apache/camel/component.properties
index d900da06d3ae..037b3c8da476 100644
---
a/components/camel-hazelcast/src/generated/resources/META-INF/services/org/apache/camel/component.properties
+++
b/components/camel-hazelcast/src/generated/resources/META-INF/services/org/apache/camel/component.properties
@@ -1,5 +1,5 @@
# Generated by camel build tools - do NOT edit this file!
-components=hazelcast-atomicvalue hazelcast-instance hazelcast-list
hazelcast-map hazelcast-multimap hazelcast-pncounter hazelcast-queue
hazelcast-replicatedmap hazelcast-ringbuffer hazelcast-seda hazelcast-set
hazelcast-topic
+components=hazelcast-instance hazelcast-list hazelcast-map hazelcast-multimap
hazelcast-pncounter hazelcast-queue hazelcast-replicatedmap
hazelcast-ringbuffer hazelcast-seda hazelcast-set hazelcast-topic
groupId=org.apache.camel
artifactId=camel-hazelcast
version=4.23.0-SNAPSHOT
diff --git
a/components/camel-hazelcast/src/generated/resources/META-INF/services/org/apache/camel/component/hazelcast-atomicvalue
b/components/camel-hazelcast/src/generated/resources/META-INF/services/org/apache/camel/component/hazelcast-atomicvalue
deleted file mode 100644
index 18fe93c637bf..000000000000
---
a/components/camel-hazelcast/src/generated/resources/META-INF/services/org/apache/camel/component/hazelcast-atomicvalue
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.hazelcast.atomicnumber.HazelcastAtomicnumberComponent
diff --git
a/components/camel-hazelcast/src/main/docs/hazelcast-atomicvalue-component.adoc
b/components/camel-hazelcast/src/main/docs/hazelcast-atomicvalue-component.adoc
deleted file mode 100644
index 4e52d3ce89c9..000000000000
---
a/components/camel-hazelcast/src/main/docs/hazelcast-atomicvalue-component.adoc
+++ /dev/null
@@ -1,270 +0,0 @@
-= Hazelcast Atomic Number Component (deprecated)
-:doctitle: Hazelcast Atomic Number
-:shortname: hazelcast-atomicvalue
-:artifactid: camel-hazelcast
-:description: Increment, decrement, set, etc. Hazelcast atomic number (a grid
wide number).
-:since: 2.7
-:supportlevel: Stable-deprecated
-:deprecated: *deprecated*
-:tabs-sync-option:
-:component-header: Only producer is supported
-//Manually maintained attributes
-:group: Hazelcast
-
-*Since Camel {since}*
-
-*{component-header}*
-
-[WARNING]
-====
-*Deprecated*: This component is deprecated as of Camel 4.19.0 and will be
removed in a future release.
-
-Since Hazelcast 5.5, IAtomicLong requires the CP Subsystem which is only
available in Hazelcast Enterprise Edition.
-This component will throw `UnsupportedOperationException` at runtime when used
with Hazelcast Community Edition 5.5+.
-====
-
-The http://www.hazelcast.com/[Hazelcast] atomic number component is one of
Camel Hazelcast Components which allows you to access Hazelcast atomic number.
-An atomic number is an object that simply provides a grid wide number (long).
-
-
-// component options: START
-include::partial$component-configure-options.adoc[]
-include::partial$component-endpoint-options.adoc[]
-include::partial$component-endpoint-headers.adoc[]
-// component options: END
-
-
-== atomic number producer - to("hazelcast-atomicvalue:foo")
-
-The operations for this producer are:
-
-* setvalue (set the number with a given value)
-* get
-* increment (+1)
-* decrement (-1)
-* destroy
-* compareAndSet
-* getAndAdd
-
-=== Example for *set*:
-
-[tabs]
-====
-Java::
-+
-[source,java]
-----
-from("direct:set")
- .setHeader("CamelHazelcastOperationType", constant("setValue"))
- .to("hazelcast-atomicvalue:foo");
-----
-
-XML::
-+
-[source,xml]
-----
-<route>
- <from uri="direct:set"/>
- <setHeader name="hazelcast.operation.type">
- <constant>setvalue</constant>
- </setHeader>
- <to uri="hazelcast-atomicvalue:foo"/>
-</route>
-----
-
-YAML::
-+
-[source,yaml]
-----
-- route:
- from:
- uri: direct:set
- steps:
- - setHeader:
- name: hazelcast.operation.type
- constant: setvalue
- - to:
- uri: hazelcast-atomicvalue:foo
-----
-====
-
-Provide the value to set inside the message body (here the value is 10):
-`template.sendBody("direct:set", 10);`
-
-=== Example for *get*:
-
-[tabs]
-====
-Java::
-+
-[source,java]
-----
-from("direct:get")
- .setHeader("CamelHazelcastOperationType", constant("get"))
- .to("hazelcast-atomicvalue:foo");
-----
-
-XML::
-+
-[source,xml]
-----
-<route>
- <from uri="direct:get"/>
- <setHeader name="hazelcast.operation.type">
- <constant>get</constant>
- </setHeader>
- <to uri="hazelcast-atomicvalue:foo"/>
-</route>
-----
-
-YAML::
-+
-[source,yaml]
-----
-- route:
- from:
- uri: direct:get
- steps:
- - setHeader:
- name: hazelcast.operation.type
- constant: get
- - to:
- uri: hazelcast-atomicvalue:foo
-----
-====
-
-You can get the number with
-`long body = template.requestBody("direct:get", null, Long.class);`.
-
-=== Example for *increment*:
-
-[tabs]
-====
-Java::
-+
-[source,java]
-----
-from("direct:increment")
- .setHeader("CamelHazelcastOperationType", constant("increment"))
- .to("hazelcast-atomicvalue:foo");
-----
-
-XML::
-+
-[source,xml]
-----
-<route>
- <from uri="direct:increment"/>
- <setHeader name="hazelcast.operation.type">
- <constant>increment</constant>
- </setHeader>
- <to uri="hazelcast-atomicvalue:foo"/>
-</route>
-----
-
-YAML::
-+
-[source,yaml]
-----
-- route:
- from:
- uri: direct:increment
- steps:
- - setHeader:
- name: hazelcast.operation.type
- constant: increment
- - to:
- uri: hazelcast-atomicvalue:foo
-----
-====
-
-The actual value (after increment) will be provided inside the message
-body.
-
-=== Example for *decrement*:
-
-[tabs]
-====
-Java::
-+
-[source,java]
-----
-from("direct:decrement")
- .setHeader("CamelHazelcastOperationType", constant("decrement"))
- .to("hazelcast-atomicvalue:foo");
-----
-
-XML::
-+
-[source,xml]
-----
-<route>
- <from uri="direct:decrement"/>
- <setHeader name="hazelcast.operation.type">
- <constant>decrement</constant>
- </setHeader>
- <to uri="hazelcast-atomicvalue:foo"/>
-</route>
-----
-
-YAML::
-+
-[source,yaml]
-----
-- route:
- from:
- uri: direct:decrement
- steps:
- - setHeader:
- name: hazelcast.operation.type
- constant: decrement
- - to:
- uri: hazelcast-atomicvalue:foo
-----
-====
-
-The actual value (after decrement) will be provided inside the message
-body.
-
-=== Example for *destroy*
-
-[tabs]
-====
-Java::
-+
-[source,java]
-----
-from("direct:destroy")
- .setHeader("CamelHazelcastOperationType", constant("destroy"))
- .to("hazelcast-atomicvalue:foo");
-----
-
-XML::
-+
-[source,xml]
-----
-<route>
- <from uri="direct:destroy"/>
- <setHeader name="hazelcast.operation.type">
- <constant>destroy</constant>
- </setHeader>
- <to uri="hazelcast-atomicvalue:foo"/>
-</route>
-----
-
-YAML::
-+
-[source,yaml]
-----
-- route:
- from:
- uri: direct:destroy
- steps:
- - setHeader:
- name: hazelcast.operation.type
- constant: destroy
- - to:
- uri: hazelcast-atomicvalue:foo
-----
-====
-
diff --git
a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastCommand.java
b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastCommand.java
index a7ffe344edc4..fe659d8204d3 100644
---
a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastCommand.java
+++
b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastCommand.java
@@ -24,7 +24,6 @@ public enum HazelcastCommand {
topic,
seda,
set,
- atomicvalue,
instance,
list,
replicatedmap,
diff --git
a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastConstants.java
b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastConstants.java
index 3ed1c2a2e14f..35393d5dd53b 100644
---
a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastConstants.java
+++
b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastConstants.java
@@ -23,7 +23,6 @@ public final class HazelcastConstants {
/**
* All the schemes
*/
- public static final String SCHEME_ATOMIC_VALUE = "hazelcast-atomicvalue";
public static final String SCHEME_INSTANCE = "hazelcast-instance";
public static final String SCHEME_LIST = "hazelcast-list";
public static final String SCHEME_MAP = "hazelcast-map";
@@ -42,7 +41,6 @@ public final class HazelcastConstants {
public static final String MAP_PREFIX = "map:";
public static final String MULTIMAP_PREFIX = "multimap:";
public static final String REPLICATEDMAP_PREFIX = "replicatedmap:";
- public static final String ATOMICNUMBER_PREFIX = "atomicvalue:";
public static final String INSTANCE_PREFIX = "instance:";
public static final String PNCOUNTER_PREFIX = "pncounter:";
public static final String QUEUE_PREFIX = "queue:";
@@ -110,7 +108,7 @@ public final class HazelcastConstants {
@Metadata(label = "producer", description = "The operation to perform",
javaType = "String",
applicableFor = {
SCHEME_MULTIMAP, SCHEME_REPLICATED_MAP, SCHEME_LIST,
SCHEME_QUEUE, SCHEME_SET, SCHEME_MAP, SCHEME_TOPIC,
- SCHEME_ATOMIC_VALUE, SCHEME_RING_BUFFER })
+ SCHEME_RING_BUFFER })
public static final String OPERATION = "CamelHazelcastOperationType";
/**
diff --git
a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/atomicnumber/HazelcastAtomicnumberComponent.java
b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/atomicnumber/HazelcastAtomicnumberComponent.java
deleted file mode 100644
index e66e3726b15d..000000000000
---
a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/atomicnumber/HazelcastAtomicnumberComponent.java
+++ /dev/null
@@ -1,50 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.hazelcast.atomicnumber;
-
-import java.util.Map;
-
-import com.hazelcast.core.HazelcastInstance;
-import org.apache.camel.CamelContext;
-import org.apache.camel.component.hazelcast.HazelcastDefaultComponent;
-import org.apache.camel.component.hazelcast.HazelcastDefaultEndpoint;
-import org.apache.camel.spi.annotations.Component;
-
-/**
- * @deprecated Since Hazelcast 5.5, IAtomicLong requires the CP Subsystem
which is only available in Hazelcast
- * Enterprise Edition. This component will throw
UnsupportedOperationException at runtime when used with
- * Hazelcast Community Edition 5.5+.
- */
-@Deprecated(since = "4.19.0", forRemoval = true)
-@Component("hazelcast-atomicvalue")
-public class HazelcastAtomicnumberComponent extends HazelcastDefaultComponent {
-
- public HazelcastAtomicnumberComponent() {
- }
-
- public HazelcastAtomicnumberComponent(final CamelContext context) {
- super(context);
- }
-
- @Override
- protected HazelcastDefaultEndpoint doCreateEndpoint(
- String uri, String remaining, Map<String, Object> parameters,
HazelcastInstance hzInstance)
- throws Exception {
- return new HazelcastAtomicnumberEndpoint(hzInstance, uri, this,
remaining);
- }
-
-}
diff --git
a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/atomicnumber/HazelcastAtomicnumberEndpoint.java
b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/atomicnumber/HazelcastAtomicnumberEndpoint.java
deleted file mode 100644
index 9567d519a425..000000000000
---
a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/atomicnumber/HazelcastAtomicnumberEndpoint.java
+++ /dev/null
@@ -1,62 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.hazelcast.atomicnumber;
-
-import com.hazelcast.core.HazelcastInstance;
-import org.apache.camel.Category;
-import org.apache.camel.Component;
-import org.apache.camel.Consumer;
-import org.apache.camel.Processor;
-import org.apache.camel.Producer;
-import org.apache.camel.component.hazelcast.HazelcastCommand;
-import org.apache.camel.component.hazelcast.HazelcastConstants;
-import org.apache.camel.component.hazelcast.HazelcastDefaultEndpoint;
-import org.apache.camel.spi.UriEndpoint;
-
-import static
org.apache.camel.component.hazelcast.HazelcastConstants.SCHEME_ATOMIC_VALUE;
-
-/**
- * Increment, decrement, set, etc. Hazelcast atomic number (a grid wide
number).
- *
- * @deprecated Since Hazelcast 5.5, IAtomicLong requires the CP Subsystem
which is only available in Hazelcast
- * Enterprise Edition. This component will throw
UnsupportedOperationException at runtime when used with
- * Hazelcast Community Edition 5.5+.
- */
-@Deprecated(since = "4.19.0", forRemoval = true)
-@UriEndpoint(firstVersion = "2.7.0", scheme = SCHEME_ATOMIC_VALUE, title =
"Hazelcast Atomic Number",
- syntax = "hazelcast-atomicvalue:cacheName", producerOnly = true,
- category = { Category.CACHE, Category.CLUSTERING },
- headersClass = HazelcastConstants.class)
-public class HazelcastAtomicnumberEndpoint extends HazelcastDefaultEndpoint {
-
- public HazelcastAtomicnumberEndpoint(HazelcastInstance hazelcastInstance,
String uri, Component component,
- final String cacheName) {
- super(hazelcastInstance, uri, component, cacheName);
- setCommand(HazelcastCommand.atomicvalue);
- }
-
- @Override
- public Consumer createConsumer(Processor processor) throws Exception {
- throw new UnsupportedOperationException("You cannot send messages to
this endpoint: " + getEndpointUri());
- }
-
- @Override
- public Producer createProducer() throws Exception {
- return new HazelcastAtomicnumberProducer(hazelcastInstance, this,
cacheName);
- }
-
-}
diff --git
a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/atomicnumber/HazelcastAtomicnumberProducer.java
b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/atomicnumber/HazelcastAtomicnumberProducer.java
deleted file mode 100644
index ed5862720078..000000000000
---
a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/atomicnumber/HazelcastAtomicnumberProducer.java
+++ /dev/null
@@ -1,133 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.hazelcast.atomicnumber;
-
-import java.util.Map;
-
-import com.hazelcast.core.HazelcastInstance;
-import com.hazelcast.cp.IAtomicLong;
-import org.apache.camel.Exchange;
-import org.apache.camel.component.hazelcast.HazelcastComponentHelper;
-import org.apache.camel.component.hazelcast.HazelcastConstants;
-import org.apache.camel.component.hazelcast.HazelcastDefaultEndpoint;
-import org.apache.camel.component.hazelcast.HazelcastDefaultProducer;
-import org.apache.camel.component.hazelcast.HazelcastOperation;
-import org.apache.camel.util.ObjectHelper;
-
-/**
- * @deprecated Since Hazelcast 5.5, IAtomicLong requires the CP Subsystem
which is only available in Hazelcast
- * Enterprise Edition. This component will throw
UnsupportedOperationException at runtime when used with
- * Hazelcast Community Edition 5.5+.
- */
-@Deprecated(since = "4.19.0", forRemoval = true)
-public class HazelcastAtomicnumberProducer extends HazelcastDefaultProducer {
-
- private final IAtomicLong atomicnumber;
-
- public HazelcastAtomicnumberProducer(HazelcastInstance hazelcastInstance,
HazelcastDefaultEndpoint endpoint,
- String cacheName) {
- super(endpoint);
- this.atomicnumber =
hazelcastInstance.getCPSubsystem().getAtomicLong(cacheName);
- }
-
- @Override
- public void process(Exchange exchange) throws Exception {
-
- Map<String, Object> headers = exchange.getIn().getHeaders();
-
- long expectedValue = 0L;
-
- if (headers.containsKey(HazelcastConstants.EXPECTED_VALUE)) {
- expectedValue = (long)
headers.get(HazelcastConstants.EXPECTED_VALUE);
- }
-
- HazelcastOperation operation = lookupOperation(exchange);
-
- switch (operation) {
-
- case INCREMENT:
- this.increment(exchange);
- break;
-
- case DECREMENT:
- this.decrement(exchange);
- break;
-
- case COMPARE_AND_SET:
- this.compare(expectedValue, exchange);
- break;
-
- case GET_AND_ADD:
- this.getAndAdd(exchange);
- break;
-
- case SET_VALUE:
- this.set(exchange);
- break;
-
- case GET:
- this.get(exchange);
- break;
-
- case DESTROY:
- this.destroy();
- break;
-
- default:
- throw new IllegalArgumentException(
- String.format("The value '%s' is not allowed for
parameter '%s' on the ATOMICNUMBER.", operation,
- HazelcastConstants.OPERATION));
- }
-
- // finally copy headers
- HazelcastComponentHelper.copyHeaders(exchange);
- }
-
- private void get(Exchange exchange) {
- exchange.getMessage().setBody(this.atomicnumber.get());
- }
-
- private void increment(Exchange exchange) {
- exchange.getMessage().setBody(this.atomicnumber.incrementAndGet());
- }
-
- private void decrement(Exchange exchange) {
- exchange.getMessage().setBody(this.atomicnumber.decrementAndGet());
- }
-
- private void compare(long expected, Exchange exchange) {
- long update = exchange.getIn().getBody(Long.class);
- if (ObjectHelper.isEmpty(expected)) {
- throw new IllegalArgumentException("Expected value must be
specified");
- }
-
exchange.getMessage().setBody(this.atomicnumber.compareAndSet(expected,
update));
- }
-
- private void getAndAdd(Exchange exchange) {
- long delta = exchange.getIn().getBody(Long.class);
- exchange.getMessage().setBody(this.atomicnumber.getAndAdd(delta));
- }
-
- private void set(Exchange exchange) {
- this.atomicnumber.set(exchange.getIn().getBody(Long.class));
- }
-
- private void destroy() {
- this.atomicnumber.destroy();
- }
-
-}
diff --git
a/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastAtomicnumberProducerForSpringTest.java
b/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastAtomicnumberProducerForSpringTest.java
deleted file mode 100644
index 8bb8986036d3..000000000000
---
a/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastAtomicnumberProducerForSpringTest.java
+++ /dev/null
@@ -1,126 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.hazelcast;
-
-import java.util.HashMap;
-import java.util.Map;
-
-import com.hazelcast.core.HazelcastInstance;
-import com.hazelcast.cp.CPSubsystem;
-import com.hazelcast.cp.IAtomicLong;
-import org.junit.jupiter.api.AfterEach;
-import org.junit.jupiter.api.Test;
-import org.mockito.Mock;
-import org.springframework.context.support.AbstractApplicationContext;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.mockito.Mockito.atLeastOnce;
-import static org.mockito.Mockito.times;
-import static org.mockito.Mockito.verify;
-import static org.mockito.Mockito.verifyNoMoreInteractions;
-import static org.mockito.Mockito.when;
-
-public class HazelcastAtomicnumberProducerForSpringTest extends
HazelcastCamelSpringTestSupport {
-
- @Mock
- private IAtomicLong atomicNumber;
-
- @Mock
- private CPSubsystem cpSubsystem;
-
- @Override
- protected void trainHazelcastInstance(HazelcastInstance hazelcastInstance)
{
- when(hazelcastInstance.getCPSubsystem()).thenReturn(cpSubsystem);
- when(cpSubsystem.getAtomicLong("foo")).thenReturn(atomicNumber);
- }
-
- @Override
- protected void verifyHazelcastInstance(HazelcastInstance
hazelcastInstance) {
- verify(hazelcastInstance, times(7)).getCPSubsystem();
- verify(cpSubsystem, atLeastOnce()).getAtomicLong("foo");
- }
-
- @AfterEach
- public void verifyAtomicNumberMock() {
- verifyNoMoreInteractions(atomicNumber);
- }
-
- @Override
- protected AbstractApplicationContext createApplicationContext() {
- return
newAppContext("/META-INF/spring/test-camel-context-atomicnumber.xml");
- }
-
- @Test
- public void testSet() {
- template.sendBody("direct:set", 4711);
- verify(atomicNumber).set(4711);
- }
-
- @Test
- public void testGet() {
- when(atomicNumber.get()).thenReturn(1234L);
- long body = template.requestBody("direct:get", null, Long.class);
- verify(atomicNumber).get();
- assertEquals(1234, body);
- }
-
- @Test
- public void testIncrement() {
- when(atomicNumber.incrementAndGet()).thenReturn(11L);
- long body = template.requestBody("direct:increment", null, Long.class);
- verify(atomicNumber).incrementAndGet();
- assertEquals(11, body);
- }
-
- @Test
- public void testDecrement() {
- when(atomicNumber.decrementAndGet()).thenReturn(9L);
- long body = template.requestBody("direct:decrement", null, Long.class);
- verify(atomicNumber).decrementAndGet();
- assertEquals(9, body);
- }
-
- @Test
- public void testDestroy() throws InterruptedException {
- template.sendBody("direct:destroy", null);
- verify(atomicNumber).destroy();
- }
-
- @Test
- public void testCompareAndSet() {
- Map<String, Object> headersOk = new HashMap();
- headersOk.put(HazelcastConstants.EXPECTED_VALUE, 1234L);
- when(atomicNumber.compareAndSet(1234L, 1235L)).thenReturn(true);
- when(atomicNumber.compareAndSet(1233L, 1235L)).thenReturn(false);
- boolean result =
template.requestBodyAndHeaders("direct:compareAndSet", 1235L, headersOk,
Boolean.class);
- verify(atomicNumber).compareAndSet(1234L, 1235L);
- assertEquals(true, result);
- Map<String, Object> headersKo = new HashMap();
- headersKo.put(HazelcastConstants.EXPECTED_VALUE, 1233L);
- result = template.requestBodyAndHeaders("direct:compareAndSet", 1235L,
headersKo, Boolean.class);
- verify(atomicNumber).compareAndSet(1233L, 1235L);
- assertEquals(false, result);
- }
-
- @Test
- public void testGetAndAdd() {
- when(atomicNumber.getAndAdd(12L)).thenReturn(13L);
- long result = template.requestBody("direct:getAndAdd", 12L,
Long.class);
- verify(atomicNumber).getAndAdd(12L);
- assertEquals(13L, result);
- }
-}
diff --git
a/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastAtomicnumberProducerTest.java
b/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastAtomicnumberProducerTest.java
deleted file mode 100644
index 55039c24c248..000000000000
---
a/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastAtomicnumberProducerTest.java
+++ /dev/null
@@ -1,182 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.hazelcast;
-
-import java.util.HashMap;
-import java.util.Map;
-
-import com.hazelcast.core.HazelcastInstance;
-import com.hazelcast.cp.CPSubsystem;
-import com.hazelcast.cp.IAtomicLong;
-import org.apache.camel.CamelExecutionException;
-import org.apache.camel.builder.RouteBuilder;
-import org.junit.jupiter.api.AfterEach;
-import org.junit.jupiter.api.Test;
-import org.mockito.Mock;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertThrows;
-import static org.mockito.Mockito.atLeastOnce;
-import static org.mockito.Mockito.times;
-import static org.mockito.Mockito.verify;
-import static org.mockito.Mockito.verifyNoMoreInteractions;
-import static org.mockito.Mockito.when;
-
-public class HazelcastAtomicnumberProducerTest extends
HazelcastCamelTestSupport {
-
- @Mock
- private IAtomicLong atomicNumber;
-
- @Mock
- private CPSubsystem cpSubsystem;
-
- @Override
- protected void trainHazelcastInstance(HazelcastInstance hazelcastInstance)
{
- when(hazelcastInstance.getCPSubsystem()).thenReturn(cpSubsystem);
- when(cpSubsystem.getAtomicLong("foo")).thenReturn(atomicNumber);
- }
-
- @Override
- protected void verifyHazelcastInstance(HazelcastInstance
hazelcastInstance) {
- verify(hazelcastInstance, times(10)).getCPSubsystem();
- verify(cpSubsystem, atLeastOnce()).getAtomicLong("foo");
- }
-
- @AfterEach
- public void verifyAtomicNumberMock() {
- verifyNoMoreInteractions(atomicNumber);
- }
-
- @Test
- public void testWithInvalidOperationName() {
- assertThrows(CamelExecutionException.class,
- () -> template.sendBody("direct:setInvalid", 4711));
- }
-
- @Test
- public void testSet() {
- template.sendBody("direct:set", 4711);
- verify(atomicNumber).set(4711);
- }
-
- @Test
- public void testGet() {
- when(atomicNumber.get()).thenReturn(1234L);
- long body = template.requestBody("direct:get", null, Long.class);
- verify(atomicNumber).get();
- assertEquals(1234, body);
- }
-
- @Test
- public void testIncrement() {
- when(atomicNumber.incrementAndGet()).thenReturn(11L);
- long body = template.requestBody("direct:increment", null, Long.class);
- verify(atomicNumber).incrementAndGet();
- assertEquals(11, body);
- }
-
- @Test
- public void testDecrement() {
- when(atomicNumber.decrementAndGet()).thenReturn(9L);
- long body = template.requestBody("direct:decrement", null, Long.class);
- verify(atomicNumber).decrementAndGet();
- assertEquals(9, body);
- }
-
- @Test
- public void testDestroy() throws InterruptedException {
- template.sendBody("direct:destroy", null);
- verify(atomicNumber).destroy();
- }
-
- @Test
- public void testSetWithOperationNumber() {
- template.sendBody("direct:setWithOperationNumber", 5711);
- verify(atomicNumber).set(5711);
- }
-
- @Test
- public void testSetWithOperationName() {
- template.sendBody("direct:setWithOperationName", 5711);
- verify(atomicNumber).set(5711);
- }
-
- @Test
- public void testCompareAndSet() {
- Map<String, Object> headersOk = new HashMap();
- headersOk.put(HazelcastConstants.EXPECTED_VALUE, 1234L);
- when(atomicNumber.compareAndSet(1234L, 1235L)).thenReturn(true);
- when(atomicNumber.compareAndSet(1233L, 1235L)).thenReturn(false);
- boolean result =
template.requestBodyAndHeaders("direct:compareAndSet", 1235L, headersOk,
Boolean.class);
- verify(atomicNumber).compareAndSet(1234L, 1235L);
- assertEquals(true, result);
- Map<String, Object> headersKo = new HashMap();
- headersKo.put(HazelcastConstants.EXPECTED_VALUE, 1233L);
- result = template.requestBodyAndHeaders("direct:compareAndSet", 1235L,
headersKo, Boolean.class);
- verify(atomicNumber).compareAndSet(1233L, 1235L);
- assertEquals(false, result);
- }
-
- @Test
- public void testGetAndAdd() {
- when(atomicNumber.getAndAdd(12L)).thenReturn(13L);
- long result = template.requestBody("direct:getAndAdd", 12L,
Long.class);
- verify(atomicNumber).getAndAdd(12L);
- assertEquals(13L, result);
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() throws Exception {
- return new RouteBuilder() {
- @Override
- public void configure() throws Exception {
-
-
from("direct:setInvalid").setHeader(HazelcastConstants.OPERATION,
constant("invalid"))
- .to(String.format("hazelcast-%sfoo",
HazelcastConstants.ATOMICNUMBER_PREFIX));
-
- from("direct:set").setHeader(HazelcastConstants.OPERATION,
constant(HazelcastOperation.SET_VALUE))
- .to(String.format("hazelcast-%sfoo",
HazelcastConstants.ATOMICNUMBER_PREFIX));
-
- from("direct:get").setHeader(HazelcastConstants.OPERATION,
constant(HazelcastOperation.GET))
- .to(String.format("hazelcast-%sfoo",
HazelcastConstants.ATOMICNUMBER_PREFIX));
-
-
from("direct:increment").setHeader(HazelcastConstants.OPERATION,
constant(HazelcastOperation.INCREMENT)).to(
- String.format("hazelcast-%sfoo",
HazelcastConstants.ATOMICNUMBER_PREFIX));
-
-
from("direct:decrement").setHeader(HazelcastConstants.OPERATION,
constant(HazelcastOperation.DECREMENT)).to(
- String.format("hazelcast-%sfoo",
HazelcastConstants.ATOMICNUMBER_PREFIX));
-
- from("direct:destroy").setHeader(HazelcastConstants.OPERATION,
constant(HazelcastOperation.DESTROY)).to(
- String.format("hazelcast-%sfoo",
HazelcastConstants.ATOMICNUMBER_PREFIX));
-
- from("direct:compareAndSet")
- .setHeader(HazelcastConstants.OPERATION,
constant(HazelcastOperation.COMPARE_AND_SET)).to(
- String.format("hazelcast-%sfoo",
HazelcastConstants.ATOMICNUMBER_PREFIX));
-
-
from("direct:getAndAdd").setHeader(HazelcastConstants.OPERATION,
constant(HazelcastOperation.GET_AND_ADD)).to(
- String.format("hazelcast-%sfoo",
HazelcastConstants.ATOMICNUMBER_PREFIX));
-
-
from("direct:setWithOperationNumber").toF("hazelcast-%sfoo?operation=%s",
- HazelcastConstants.ATOMICNUMBER_PREFIX,
HazelcastOperation.SET_VALUE);
-
from("direct:setWithOperationName").toF("hazelcast-%sfoo?operation=setvalue",
- HazelcastConstants.ATOMICNUMBER_PREFIX);
-
- }
- };
- }
-
-}
diff --git
a/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastCamelTestHelper.java
b/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastCamelTestHelper.java
index 1e721b51549d..f13b26d23e90 100644
---
a/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastCamelTestHelper.java
+++
b/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastCamelTestHelper.java
@@ -18,7 +18,6 @@ package org.apache.camel.component.hazelcast;
import com.hazelcast.core.HazelcastInstance;
import org.apache.camel.CamelContext;
-import
org.apache.camel.component.hazelcast.atomicnumber.HazelcastAtomicnumberComponent;
import
org.apache.camel.component.hazelcast.instance.HazelcastInstanceComponent;
import org.apache.camel.component.hazelcast.list.HazelcastListComponent;
import org.apache.camel.component.hazelcast.map.HazelcastMapComponent;
@@ -37,9 +36,6 @@ public final class HazelcastCamelTestHelper {
}
public static void registerHazelcastComponents(CamelContext context,
HazelcastInstance hazelcastInstance) {
- HazelcastAtomicnumberComponent atomic = new
HazelcastAtomicnumberComponent(context);
- atomic.setHazelcastInstance(hazelcastInstance);
- context.addComponent("hazelcast-atomicvalue", atomic);
HazelcastInstanceComponent instance = new
HazelcastInstanceComponent(context);
instance.setHazelcastInstance(hazelcastInstance);
context.addComponent("hazelcast-instance", instance);
diff --git
a/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastErrorMessagesTest.java
b/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastErrorMessagesTest.java
index 0b39792782f9..4a251ec31b86 100644
---
a/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastErrorMessagesTest.java
+++
b/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastErrorMessagesTest.java
@@ -22,25 +22,10 @@ import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.assertThrows;
import static org.junit.jupiter.api.Assertions.assertTrue;
-public class HazelcastErrorMessagesTest extends HazelcastCamelTestSupport {
+class HazelcastErrorMessagesTest extends HazelcastCamelTestSupport {
@Test
- public void testAtomicNumberConsumer() {
- RouteBuilder builder = new RouteBuilder() {
- public void configure() throws Exception {
- from("hazelcast-atomicvalue:foo").to("seda:out");
- }
- };
- Exception e = assertThrows(Exception.class, () -> {
- context.addRoutes(builder);
- context.start();
- });
- assertTrue(e.getCause().getMessage()
- .contains("You cannot send messages to this endpoint:
hazelcast-atomicvalue://foo"));
- }
-
- @Test
- public void testPNCounterConsumer() {
+ void testPNCounterConsumer() {
RouteBuilder builder = new RouteBuilder() {
public void configure() throws Exception {
from("hazelcast-pncounter:foo").to("seda:out");
@@ -55,7 +40,7 @@ public class HazelcastErrorMessagesTest extends
HazelcastCamelTestSupport {
}
@Test
- public void testInstanceProducer() {
+ void testInstanceProducer() {
RouteBuilder builder = new RouteBuilder() {
public void configure() throws Exception {
from("direct:foo").to("hazelcast-instance:foo");
diff --git
a/components/camel-hazelcast/src/test/resources/META-INF/spring/test-camel-context-atomicnumber.xml
b/components/camel-hazelcast/src/test/resources/META-INF/spring/test-camel-context-atomicnumber.xml
deleted file mode 100644
index 943beac72c27..000000000000
---
a/components/camel-hazelcast/src/test/resources/META-INF/spring/test-camel-context-atomicnumber.xml
+++ /dev/null
@@ -1,86 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-
- Licensed to the Apache Software Foundation (ASF) under one or more
- contributor license agreements. See the NOTICE file distributed with
- this work for additional information regarding copyright ownership.
- The ASF licenses this file to You under the Apache License, Version 2.0
- (the "License"); you may not use this file except in compliance with
- the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
-
--->
-<beans xmlns="http://www.springframework.org/schema/beans";
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xmlns:camel="http://camel.apache.org/schema/spring";
- xsi:schemaLocation="
- http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
- http://camel.apache.org/schema/spring
http://camel.apache.org/schema/spring/camel-spring.xsd";>
-
- <camelContext xmlns="http://camel.apache.org/schema/spring";>
-
- <route>
- <from uri="direct:set" />
- <setHeader name="CamelHazelcastOperationType">
- <constant>setvalue</constant>
- </setHeader>
- <to uri="hazelcast-atomicvalue:foo" />
- </route>
-
- <route>
- <from uri="direct:get" />
- <setHeader name="CamelHazelcastOperationType">
- <constant>get</constant>
- </setHeader>
- <to uri="hazelcast-atomicvalue:foo" />
- </route>
-
- <route>
- <from uri="direct:increment" />
- <setHeader name="CamelHazelcastOperationType">
- <constant>increment</constant>
- </setHeader>
- <to uri="hazelcast-atomicvalue:foo" />
- </route>
-
- <route>
- <from uri="direct:decrement" />
- <setHeader name="CamelHazelcastOperationType">
- <constant>decrement</constant>
- </setHeader>
- <to uri="hazelcast-atomicvalue:foo" />
- </route>
-
- <route>
- <from uri="direct:compareAndSet" />
- <setHeader name="CamelHazelcastOperationType">
- <constant>compareAndSet</constant>
- </setHeader>
- <to uri="hazelcast-atomicvalue:foo" />
- </route>
-
- <route>
- <from uri="direct:getAndAdd" />
- <setHeader name="CamelHazelcastOperationType">
- <constant>getAndAdd</constant>
- </setHeader>
- <to uri="hazelcast-atomicvalue:foo" />
- </route>
-
- <route>
- <from uri="direct:destroy" />
- <setHeader name="CamelHazelcastOperationType">
- <constant>destroy</constant>
- </setHeader>
- <to uri="hazelcast-atomicvalue:foo" />
- </route>
-
- </camelContext>
-
-</beans>
diff --git
a/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties
b/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties
index 9f7553286bfe..597f3a6a0ea2 100644
---
a/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties
+++
b/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties
@@ -158,7 +158,6 @@ google-vision
graphql
grpc
hashicorp-vault
-hazelcast-atomicvalue
hazelcast-instance
hazelcast-list
hazelcast-map
diff --git
a/docs/components/modules/ROOT/examples/json/hazelcast-atomicvalue.json
b/docs/components/modules/ROOT/examples/json/hazelcast-atomicvalue.json
deleted file mode 120000
index 273fd87e77b3..000000000000
--- a/docs/components/modules/ROOT/examples/json/hazelcast-atomicvalue.json
+++ /dev/null
@@ -1 +0,0 @@
-../../../../../../components/camel-hazelcast/src/generated/resources/META-INF/org/apache/camel/component/hazelcast/atomicnumber/hazelcast-atomicvalue.json
\ No newline at end of file
diff --git a/docs/components/modules/ROOT/nav.adoc
b/docs/components/modules/ROOT/nav.adoc
index 47b437e3fa17..a8d37415282e 100644
--- a/docs/components/modules/ROOT/nav.adoc
+++ b/docs/components/modules/ROOT/nav.adoc
@@ -187,7 +187,6 @@
** xref:grpc-component.adoc[gRPC]
** xref:hashicorp-vault-component.adoc[HashiCorp Vault]
** xref:hazelcast-summary.adoc[Hazelcast]
-*** xref:hazelcast-atomicvalue-component.adoc[Hazelcast Atomic Number]
*** xref:hazelcast-instance-component.adoc[Hazelcast Instance]
*** xref:hazelcast-list-component.adoc[Hazelcast List]
*** xref:hazelcast-map-component.adoc[Hazelcast Map]
diff --git
a/docs/components/modules/ROOT/pages/hazelcast-atomicvalue-component.adoc
b/docs/components/modules/ROOT/pages/hazelcast-atomicvalue-component.adoc
deleted file mode 120000
index 44f337416dca..000000000000
--- a/docs/components/modules/ROOT/pages/hazelcast-atomicvalue-component.adoc
+++ /dev/null
@@ -1 +0,0 @@
-../../../../../components/camel-hazelcast/src/main/docs/hazelcast-atomicvalue-component.adoc
\ No newline at end of file
diff --git
a/docs/user-manual/modules/ROOT/pages/camel-4x-upgrade-guide-4_23.adoc
b/docs/user-manual/modules/ROOT/pages/camel-4x-upgrade-guide-4_23.adoc
index 3df6c00f78bb..d8e4cc4d13be 100644
--- a/docs/user-manual/modules/ROOT/pages/camel-4x-upgrade-guide-4_23.adoc
+++ b/docs/user-manual/modules/ROOT/pages/camel-4x-upgrade-guide-4_23.adoc
@@ -179,6 +179,12 @@ The maven plugin was deprecated in 4.12. The catalog now
has built-in suggestion
The component camel-digitalocean was deprecated in 4.21. The java library used
has been unmaintained for several years and there is no replacement.
+==== camel-hazelcast-atomicvalue
+
+The component `camel-hazelcast-atomicvalue` was deprecated in 4.19.0.
+
+In hazelcast 5.5+, the CP subsystem is only available in the enterprise
edition of hazelcast. `hazelcast-pncounter` is a partial replacement.
+
==== camel-headersmap
The component camel-headersmap was deprecated in 4.21. The default
`CaseInsensitiveMap` in camel-core
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
index f27b36f424fb..94015850bbd0 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
@@ -2173,20 +2173,6 @@ public interface ComponentsBuilderFactory {
static
HashicorpVaultComponentBuilderFactory.HashicorpVaultComponentBuilder
hashicorpVault() {
return HashicorpVaultComponentBuilderFactory.hashicorpVault();
}
- /**
- * Hazelcast Atomic Number (camel-hazelcast)
- * Increment, decrement, set, etc. Hazelcast atomic number (a grid wide
- * number).
- *
- * Category: cache,clustering
- * Since: 2.7
- * Maven coordinates: org.apache.camel:camel-hazelcast
- *
- * @return the dsl builder
- */
- static
HazelcastAtomicvalueComponentBuilderFactory.HazelcastAtomicvalueComponentBuilder
hazelcastAtomicvalue() {
- return
HazelcastAtomicvalueComponentBuilderFactory.hazelcastAtomicvalue();
- }
/**
* Hazelcast Instance (camel-hazelcast)
* Consume join/leave events of a cache instance in a Hazelcast cluster.
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/HazelcastAtomicvalueComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/HazelcastAtomicvalueComponentBuilderFactory.java
deleted file mode 100644
index 118c224dc4e2..000000000000
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/HazelcastAtomicvalueComponentBuilderFactory.java
+++ /dev/null
@@ -1,160 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.builder.component.dsl;
-
-import javax.annotation.processing.Generated;
-import org.apache.camel.Component;
-import org.apache.camel.builder.component.AbstractComponentBuilder;
-import org.apache.camel.builder.component.ComponentBuilder;
-import
org.apache.camel.component.hazelcast.atomicnumber.HazelcastAtomicnumberComponent;
-
-/**
- * Increment, decrement, set, etc. Hazelcast atomic number (a grid wide
number).
- *
- * Generated by camel build tools - do NOT edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.ComponentDslMojo")
-public interface HazelcastAtomicvalueComponentBuilderFactory {
-
- /**
- * Hazelcast Atomic Number (camel-hazelcast)
- * Increment, decrement, set, etc. Hazelcast atomic number (a grid wide
- * number).
- *
- * Category: cache,clustering
- * Since: 2.7
- * Maven coordinates: org.apache.camel:camel-hazelcast
- *
- * @return the dsl builder
- */
- static HazelcastAtomicvalueComponentBuilder hazelcastAtomicvalue() {
- return new HazelcastAtomicvalueComponentBuilderImpl();
- }
-
- /**
- * Builder for the Hazelcast Atomic Number component.
- */
- interface HazelcastAtomicvalueComponentBuilder extends
ComponentBuilder<HazelcastAtomicnumberComponent> {
-
-
- /**
- * 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 starting the
- * producer may take a little time and prolong the total processing
time
- * of the processing.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: producer
- *
- * @param lazyStartProducer the value to set
- * @return the dsl builder
- */
- default HazelcastAtomicvalueComponentBuilder lazyStartProducer(boolean
lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- return this;
- }
-
-
- /**
- * Whether autowiring is enabled. This is used for automatic autowiring
- * options (the option must be marked as autowired) by looking up in
the
- * registry to find if there is a single instance of matching type,
- * which then gets configured on the component. This can be used for
- * automatic configuring JDBC data sources, JMS connection factories,
- * AWS Clients, etc.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: true
- * Group: advanced
- *
- * @param autowiredEnabled the value to set
- * @return the dsl builder
- */
- default HazelcastAtomicvalueComponentBuilder autowiredEnabled(boolean
autowiredEnabled) {
- doSetProperty("autowiredEnabled", autowiredEnabled);
- return this;
- }
-
- /**
- * The hazelcast instance reference 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.
- *
- * The option is a:
- * <code>com.hazelcast.core.HazelcastInstance</code> type.
- *
- * Group: advanced
- *
- * @param hazelcastInstance the value to set
- * @return the dsl builder
- */
- default HazelcastAtomicvalueComponentBuilder
hazelcastInstance(com.hazelcast.core.HazelcastInstance hazelcastInstance) {
- doSetProperty("hazelcastInstance", hazelcastInstance);
- return this;
- }
-
-
- /**
- * The hazelcast mode reference which kind of instance should be used.
- * If you don't specify the mode, then the node mode will be the
- * default.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Default: node
- * Group: advanced
- *
- * @param hazelcastMode the value to set
- * @return the dsl builder
- */
- default HazelcastAtomicvalueComponentBuilder
hazelcastMode(java.lang.String hazelcastMode) {
- doSetProperty("hazelcastMode", hazelcastMode);
- return this;
- }
- }
-
- class HazelcastAtomicvalueComponentBuilderImpl
- extends AbstractComponentBuilder<HazelcastAtomicnumberComponent>
- implements HazelcastAtomicvalueComponentBuilder {
- @Override
- protected HazelcastAtomicnumberComponent buildConcreteComponent() {
- return new HazelcastAtomicnumberComponent();
- }
- @Override
- protected boolean setPropertyOnComponent(
- Component component,
- String name,
- Object value) {
- switch (name) {
- case "lazyStartProducer": ((HazelcastAtomicnumberComponent)
component).setLazyStartProducer((boolean) value); return true;
- case "autowiredEnabled": ((HazelcastAtomicnumberComponent)
component).setAutowiredEnabled((boolean) value); return true;
- case "hazelcastInstance": ((HazelcastAtomicnumberComponent)
component).setHazelcastInstance((com.hazelcast.core.HazelcastInstance) value);
return true;
- case "hazelcastMode": ((HazelcastAtomicnumberComponent)
component).setHazelcastMode((java.lang.String) value); return true;
- default: return false;
- }
- }
- }
-}
\ No newline at end of file
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
index f30ed4664a3d..09e2aadda63e 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
@@ -163,7 +163,6 @@ public interface EndpointBuilderFactory
org.apache.camel.builder.endpoint.dsl.GridFsEndpointBuilderFactory.GridFsBuilders,
org.apache.camel.builder.endpoint.dsl.GrpcEndpointBuilderFactory.GrpcBuilders,
org.apache.camel.builder.endpoint.dsl.HashicorpVaultEndpointBuilderFactory.HashicorpVaultBuilders,
-
org.apache.camel.builder.endpoint.dsl.HazelcastAtomicnumberEndpointBuilderFactory.HazelcastAtomicnumberBuilders,
org.apache.camel.builder.endpoint.dsl.HazelcastInstanceEndpointBuilderFactory.HazelcastInstanceBuilders,
org.apache.camel.builder.endpoint.dsl.HazelcastListEndpointBuilderFactory.HazelcastListBuilders,
org.apache.camel.builder.endpoint.dsl.HazelcastMapEndpointBuilderFactory.HazelcastMapBuilders,
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
index 027574b51d00..12e3765f4a28 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
@@ -160,7 +160,6 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.GridFsEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.GrpcEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.HashicorpVaultEndpointBuilderFactory,
-
org.apache.camel.builder.endpoint.dsl.HazelcastAtomicnumberEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.HazelcastInstanceEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.HazelcastListEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.HazelcastMapEndpointBuilderFactory,
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointHeaderBuilders.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointHeaderBuilders.java
index 98df92ce7258..29c7b4d16b5f 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointHeaderBuilders.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointHeaderBuilders.java
@@ -1671,21 +1671,6 @@ public class EndpointHeaderBuilders {
public static
HashicorpVaultEndpointBuilderFactory.HashicorpVaultHeaderNameBuilder
hashicorpVault() {
return
HashicorpVaultEndpointBuilderFactory.HashicorpVaultHeaderNameBuilder.INSTANCE;
}
- /**
- * Hazelcast Atomic Number (camel-hazelcast)
- * Increment, decrement, set, etc. Hazelcast atomic number (a grid wide
- * number).
- *
- * Category: cache,clustering
- * Since: 2.7
- * Maven coordinates: org.apache.camel:camel-hazelcast
- *
- * @return the dsl builder for the headers' name.
- */
- @Deprecated
- public static
HazelcastAtomicnumberEndpointBuilderFactory.HazelcastAtomicnumberHeaderNameBuilder
hazelcastAtomicvalue() {
- return
HazelcastAtomicnumberEndpointBuilderFactory.HazelcastAtomicnumberHeaderNameBuilder.INSTANCE;
- }
/**
* Hazelcast Instance (camel-hazelcast)
* Consume join/leave events of a cache instance in a Hazelcast cluster.
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
index f8470732b6e5..23c03355a4e4 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
@@ -7093,50 +7093,6 @@ public class StaticEndpointBuilders {
public static
HashicorpVaultEndpointBuilderFactory.HashicorpVaultEndpointBuilder
hashicorpVault(String componentName, String path) {
return
HashicorpVaultEndpointBuilderFactory.endpointBuilder(componentName, path);
}
- /**
- * Hazelcast Atomic Number (camel-hazelcast)
- * Increment, decrement, set, etc. Hazelcast atomic number (a grid wide
- * number).
- *
- * Category: cache,clustering
- * Since: 2.7
- * Maven coordinates: org.apache.camel:camel-hazelcast
- *
- * Syntax: <code>hazelcast-atomicvalue:cacheName</code>
- *
- * Path parameter: cacheName (required)
- * The name of the cache
- *
- * @param path cacheName
- * @return the dsl builder
- */
- @Deprecated
- public static
HazelcastAtomicnumberEndpointBuilderFactory.HazelcastAtomicnumberEndpointBuilder
hazelcastAtomicvalue(String path) {
- return hazelcastAtomicvalue("hazelcast-atomicvalue", path);
- }
- /**
- * Hazelcast Atomic Number (camel-hazelcast)
- * Increment, decrement, set, etc. Hazelcast atomic number (a grid wide
- * number).
- *
- * Category: cache,clustering
- * Since: 2.7
- * Maven coordinates: org.apache.camel:camel-hazelcast
- *
- * Syntax: <code>hazelcast-atomicvalue:cacheName</code>
- *
- * Path parameter: cacheName (required)
- * The name of the cache
- *
- * @param componentName to use a custom component name for the endpoint
- * instead of the default name
- * @param path cacheName
- * @return the dsl builder
- */
- @Deprecated
- public static
HazelcastAtomicnumberEndpointBuilderFactory.HazelcastAtomicnumberEndpointBuilder
hazelcastAtomicvalue(String componentName, String path) {
- return
HazelcastAtomicnumberEndpointBuilderFactory.endpointBuilder(componentName,
path);
- }
/**
* Hazelcast Instance (camel-hazelcast)
* Consume join/leave events of a cache instance in a Hazelcast cluster.
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/HazelcastAtomicnumberEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/HazelcastAtomicnumberEndpointBuilderFactory.java
deleted file mode 100644
index f99f70e1eddf..000000000000
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/HazelcastAtomicnumberEndpointBuilderFactory.java
+++ /dev/null
@@ -1,299 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.builder.endpoint.dsl;
-
-import java.util.*;
-import java.util.concurrent.*;
-import java.util.function.*;
-import java.util.stream.*;
-import javax.annotation.processing.Generated;
-import org.apache.camel.builder.EndpointConsumerBuilder;
-import org.apache.camel.builder.EndpointProducerBuilder;
-import org.apache.camel.builder.endpoint.AbstractEndpointBuilder;
-
-/**
- * Increment, decrement, set, etc. Hazelcast atomic number (a grid wide
number).
- *
- * Generated by camel build tools - do NOT edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.EndpointDslMojo")
-public interface HazelcastAtomicnumberEndpointBuilderFactory {
-
- /**
- * Builder for endpoint for the Hazelcast Atomic Number component.
- */
- public interface HazelcastAtomicnumberEndpointBuilder
- extends
- EndpointProducerBuilder {
- default AdvancedHazelcastAtomicnumberEndpointBuilder advanced() {
- return (AdvancedHazelcastAtomicnumberEndpointBuilder) this;
- }
-
- /**
- * To specify a default operation to use, if no operation header has
- * been provided.
- *
- * The option is a:
- * <code>org.apache.camel.component.hazelcast.HazelcastOperation</code>
- * type.
- *
- * Group: producer
- *
- * @param defaultOperation the value to set
- * @return the dsl builder
- */
- default HazelcastAtomicnumberEndpointBuilder
defaultOperation(org.apache.camel.component.hazelcast.HazelcastOperation
defaultOperation) {
- doSetProperty("defaultOperation", defaultOperation);
- return this;
- }
- /**
- * To specify a default operation to use, if no operation header has
- * been provided.
- *
- * The option will be converted to a
- * <code>org.apache.camel.component.hazelcast.HazelcastOperation</code>
- * type.
- *
- * Group: producer
- *
- * @param defaultOperation the value to set
- * @return the dsl builder
- */
- default HazelcastAtomicnumberEndpointBuilder defaultOperation(String
defaultOperation) {
- doSetProperty("defaultOperation", defaultOperation);
- return this;
- }
- /**
- * Hazelcast configuration file.
- *
- * This option can also be loaded from an existing file, by prefixing
- * with file: or classpath: followed by the location of the file.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: producer
- *
- * @param hazelcastConfigUri the value to set
- * @return the dsl builder
- */
- default HazelcastAtomicnumberEndpointBuilder hazelcastConfigUri(String
hazelcastConfigUri) {
- doSetProperty("hazelcastConfigUri", hazelcastConfigUri);
- return this;
- }
- /**
- * The hazelcast instance reference which can be used for hazelcast
- * endpoint.
- *
- * The option is a: <code>com.hazelcast.core.HazelcastInstance</code>
- * type.
- *
- * Group: producer
- *
- * @param hazelcastInstance the value to set
- * @return the dsl builder
- */
- default HazelcastAtomicnumberEndpointBuilder
hazelcastInstance(com.hazelcast.core.HazelcastInstance hazelcastInstance) {
- doSetProperty("hazelcastInstance", hazelcastInstance);
- return this;
- }
- /**
- * The hazelcast instance reference which can be used for hazelcast
- * endpoint.
- *
- * The option will be converted to a
- * <code>com.hazelcast.core.HazelcastInstance</code> type.
- *
- * Group: producer
- *
- * @param hazelcastInstance the value to set
- * @return the dsl builder
- */
- default HazelcastAtomicnumberEndpointBuilder hazelcastInstance(String
hazelcastInstance) {
- doSetProperty("hazelcastInstance", hazelcastInstance);
- return this;
- }
- /**
- * 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.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: producer
- *
- * @param hazelcastInstanceName the value to set
- * @return the dsl builder
- */
- default HazelcastAtomicnumberEndpointBuilder
hazelcastInstanceName(String hazelcastInstanceName) {
- doSetProperty("hazelcastInstanceName", hazelcastInstanceName);
- return this;
- }
- }
-
- /**
- * Advanced builder for endpoint for the Hazelcast Atomic Number component.
- */
- public interface AdvancedHazelcastAtomicnumberEndpointBuilder
- extends
- EndpointProducerBuilder {
- default HazelcastAtomicnumberEndpointBuilder basic() {
- return (HazelcastAtomicnumberEndpointBuilder) 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
- * 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 starting the
- * producer may take a little time and prolong the total processing
time
- * of the processing.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: producer (advanced)
- *
- * @param lazyStartProducer the value to set
- * @return the dsl builder
- */
- default AdvancedHazelcastAtomicnumberEndpointBuilder
lazyStartProducer(boolean lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- 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
- * 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 starting the
- * producer may take a little time and prolong the total processing
time
- * of the processing.
- *
- * The option will be converted to a <code>boolean</code> type.
- *
- * Default: false
- * Group: producer (advanced)
- *
- * @param lazyStartProducer the value to set
- * @return the dsl builder
- */
- default AdvancedHazelcastAtomicnumberEndpointBuilder
lazyStartProducer(String lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- return this;
- }
- }
-
- public interface HazelcastAtomicnumberBuilders {
- /**
- * Hazelcast Atomic Number (camel-hazelcast)
- * Increment, decrement, set, etc. Hazelcast atomic number (a grid wide
- * number).
- *
- * Category: cache,clustering
- * Since: 2.7
- * Maven coordinates: org.apache.camel:camel-hazelcast
- *
- * @return the dsl builder for the headers' name.
- */
- @Deprecated
- default HazelcastAtomicnumberHeaderNameBuilder hazelcastAtomicvalue() {
- return HazelcastAtomicnumberHeaderNameBuilder.INSTANCE;
- }
- /**
- * Hazelcast Atomic Number (camel-hazelcast)
- * Increment, decrement, set, etc. Hazelcast atomic number (a grid wide
- * number).
- *
- * Category: cache,clustering
- * Since: 2.7
- * Maven coordinates: org.apache.camel:camel-hazelcast
- *
- * Syntax: <code>hazelcast-atomicvalue:cacheName</code>
- *
- * Path parameter: cacheName (required)
- * The name of the cache
- *
- * @param path cacheName
- * @return the dsl builder
- */
- @Deprecated
- default HazelcastAtomicnumberEndpointBuilder
hazelcastAtomicvalue(String path) {
- return
HazelcastAtomicnumberEndpointBuilderFactory.endpointBuilder("hazelcast-atomicvalue",
path);
- }
- /**
- * Hazelcast Atomic Number (camel-hazelcast)
- * Increment, decrement, set, etc. Hazelcast atomic number (a grid wide
- * number).
- *
- * Category: cache,clustering
- * Since: 2.7
- * Maven coordinates: org.apache.camel:camel-hazelcast
- *
- * Syntax: <code>hazelcast-atomicvalue:cacheName</code>
- *
- * Path parameter: cacheName (required)
- * The name of the cache
- *
- * @param componentName to use a custom component name for the endpoint
- * instead of the default name
- * @param path cacheName
- * @return the dsl builder
- */
- @Deprecated
- default HazelcastAtomicnumberEndpointBuilder
hazelcastAtomicvalue(String componentName, String path) {
- return
HazelcastAtomicnumberEndpointBuilderFactory.endpointBuilder(componentName,
path);
- }
-
- }
- /**
- * The builder of headers' name for the Hazelcast Atomic Number component.
- */
- public static class HazelcastAtomicnumberHeaderNameBuilder {
- /**
- * The internal instance of the builder used to access to all the
- * methods representing the name of headers.
- */
- public static final HazelcastAtomicnumberHeaderNameBuilder INSTANCE =
new HazelcastAtomicnumberHeaderNameBuilder();
-
- /**
- * The operation to perform.
- *
- * The option is a: {@code String} type.
- *
- * Group: producer
- *
- * @return the name of the header {@code HazelcastOperationType}.
- */
- public String hazelcastOperationType() {
- return "CamelHazelcastOperationType";
- }
- }
- static HazelcastAtomicnumberEndpointBuilder endpointBuilder(String
componentName, String path) {
- class HazelcastAtomicnumberEndpointBuilderImpl extends
AbstractEndpointBuilder implements HazelcastAtomicnumberEndpointBuilder,
AdvancedHazelcastAtomicnumberEndpointBuilder {
- public HazelcastAtomicnumberEndpointBuilderImpl(String path) {
- super(componentName, path);
- }
- }
- return new HazelcastAtomicnumberEndpointBuilderImpl(path);
- }
-}
\ No newline at end of file
diff --git
a/dsl/camel-kamelet-main/src/generated/resources/camel-component-known-dependencies.properties
b/dsl/camel-kamelet-main/src/generated/resources/camel-component-known-dependencies.properties
index 0411208e2605..f1c3bcc5a22b 100644
---
a/dsl/camel-kamelet-main/src/generated/resources/camel-component-known-dependencies.properties
+++
b/dsl/camel-kamelet-main/src/generated/resources/camel-component-known-dependencies.properties
@@ -175,7 +175,6 @@
org.apache.camel.component.google.vision.GoogleCloudVisionComponent=camel:google
org.apache.camel.component.graphql.GraphqlComponent=camel:graphql
org.apache.camel.component.grpc.GrpcComponent=camel:grpc
org.apache.camel.component.hashicorp.vault.HashicorpVaultComponent=camel:hashicorp-vault
-org.apache.camel.component.hazelcast.atomicnumber.HazelcastAtomicnumberComponent=camel:hazelcast
org.apache.camel.component.hazelcast.instance.HazelcastInstanceComponent=camel:hazelcast
org.apache.camel.component.hazelcast.list.HazelcastListComponent=camel:hazelcast
org.apache.camel.component.hazelcast.map.HazelcastMapComponent=camel:hazelcast
