This is an automated email from the ASF dual-hosted git repository. nfilotto pushed a commit to branch CAMEL-17792/doc-message-headers in repository https://gitbox.apache.org/repos/asf/camel.git
commit 618be7cb892c067d323faeca1861b4187816b63c Author: Nicolas Filotto <[email protected]> AuthorDate: Wed Mar 23 11:06:50 2022 +0100 CAMEL-17792: Add doc about the message headers of camel-hazelcast --- .../atomicnumber/hazelcast-atomicvalue.json | 3 ++ .../hazelcast/instance/hazelcast-instance.json | 7 +++ .../component/hazelcast/list/hazelcast-list.json | 9 ++++ .../component/hazelcast/map/hazelcast-map.json | 12 +++++ .../hazelcast/multimap/hazelcast-multimap.json | 9 ++++ .../component/hazelcast/queue/hazelcast-queue.json | 9 ++++ .../replicatedmap/hazelcast-replicatedmap.json | 8 ++++ .../hazelcast/ringbuffer/hazelcast-ringbuffer.json | 3 ++ .../component/hazelcast/set/hazelcast-set.json | 8 ++++ .../component/hazelcast/topic/hazelcast-topic.json | 8 ++++ .../main/docs/hazelcast-atomicvalue-component.adoc | 18 ++++---- .../main/docs/hazelcast-instance-component.adoc | 23 ++-------- .../src/main/docs/hazelcast-list-component.adoc | 10 ++++- .../src/main/docs/hazelcast-map-component.adoc | 25 ++--------- .../main/docs/hazelcast-multimap-component.adoc | 45 ++++++------------- .../src/main/docs/hazelcast-queue-component.adoc | 19 +++++--- .../docs/hazelcast-replicatedmap-component.adoc | 18 +++----- .../main/docs/hazelcast-ringbuffer-component.adoc | 18 +++----- .../src/main/docs/hazelcast-seda-component.adoc | 4 ++ .../src/main/docs/hazelcast-set-component.adoc | 14 ++++++ .../src/main/docs/hazelcast-topic-component.adoc | 4 ++ .../component/hazelcast/HazelcastConstants.java | 52 ++++++++++++++++++++++ .../HazelcastAtomicnumberEndpoint.java | 8 +++- .../instance/HazelcastInstanceEndpoint.java | 7 ++- .../hazelcast/list/HazelcastListEndpoint.java | 7 ++- .../hazelcast/map/HazelcastMapEndpoint.java | 7 ++- .../multimap/HazelcastMultimapEndpoint.java | 8 +++- .../hazelcast/queue/HazelcastQueueEndpoint.java | 8 +++- .../HazelcastReplicatedmapEndpoint.java | 8 +++- .../ringbuffer/HazelcastRingbufferEndpoint.java | 8 +++- .../hazelcast/seda/HazelcastSedaEndpoint.java | 7 ++- .../hazelcast/set/HazelcastSetEndpoint.java | 7 ++- .../hazelcast/topic/HazelcastTopicEndpoint.java | 8 +++- 33 files changed, 272 insertions(+), 137 deletions(-) diff --git a/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/atomicnumber/hazelcast-atomicvalue.json b/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/atomicnumber/hazelcast-atomicvalue.json index 3c5f75b..255c0df 100644 --- a/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/atomicnumber/hazelcast-atomicvalue.json +++ b/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/atomicnumber/hazelcast-atomicvalue.json @@ -27,6 +27,9 @@ "hazelcastInstance": { "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 instance." }, "hazelcastMode": { "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": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The operation to perform" } + }, "properties": { "cacheName": { "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": { "kind": "parameter", "displayName": "Default Operation", "group": "producer", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.hazelcast.HazelcastOperation", "enum": [ "put", "delete", "get", "update", "query", "getAll", "clear", "putIfAbsent", "allAll", "removeAll", "retainAll", "evict", "evictAll", "valueCount", "containsKey", "containsValue", "keySet", "removevalue", "increment", "decrement", "setvalue", "destroy", "co [...] diff --git a/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/instance/hazelcast-instance.json b/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/instance/hazelcast-instance.json index e3af486..0b42756 100644 --- a/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/instance/hazelcast-instance.json +++ b/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/instance/hazelcast-instance.json @@ -27,6 +27,13 @@ "hazelcastInstance": { "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 instance." }, "hazelcastMode": { "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": { + "CamelHazelcastListenerAction": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The type of event - here *added* and *removed*" }, + "CamelHazelcastListenerType": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The map consumer" }, + "CamelHazelcastListenerTime": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "Long", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The time of the event in millis" }, + "CamelHazelcastInstanceHost": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The host name of the instance" }, + "CamelHazelcastInstancePort": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "Integer", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The port number of the instance" } + }, "properties": { "cacheName": { "kind": "path", "displayName": "Cache Name", "group": "consumer", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The name of the cache" }, "bridgeErrorHandler": { "kind": "parameter", "displayName": "Bridge Error Handler", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a m [...] diff --git a/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/list/hazelcast-list.json b/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/list/hazelcast-list.json index 0142734..90220c4 100644 --- a/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/list/hazelcast-list.json +++ b/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/list/hazelcast-list.json @@ -28,6 +28,15 @@ "hazelcastInstance": { "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 instance." }, "hazelcastMode": { "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": { + "CamelHazelcastObjectId": { "kind": "header", "displayName": "", "group": "common", "label": "", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "the object id to store \/ find your object inside the cache" }, + "CamelHazelcastObjectIndex": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "Integer", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The index of the object" }, + "CamelHazelcastListenerAction": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The type of event - here *added* and *removed*" }, + "CamelHazelcastListenerType": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The map consumer" }, + "CamelHazelcastListenerTime": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "Long", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The time of the event in millis" }, + "CamelHazelcastCacheName": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The name of the cache - e.g. \"foo\"" }, + "CamelHazelcastOperationType": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The operation to perform" } + }, "properties": { "cacheName": { "kind": "path", "displayName": "Cache Name", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The name of the cache" }, "defaultOperation": { "kind": "parameter", "displayName": "Default Operation", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.hazelcast.HazelcastOperation", "enum": [ "put", "delete", "get", "update", "query", "getAll", "clear", "putIfAbsent", "allAll", "removeAll", "retainAll", "evict", "evictAll", "valueCount", "containsKey", "containsValue", "keySet", "removevalue", "increment", "decrement", "setvalue", "destroy", "comp [...] diff --git a/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/map/hazelcast-map.json b/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/map/hazelcast-map.json index 27e3a97..a9db4a3 100644 --- a/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/map/hazelcast-map.json +++ b/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/map/hazelcast-map.json @@ -28,6 +28,18 @@ "hazelcastInstance": { "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 instance." }, "hazelcastMode": { "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": { + "CamelHazelcastObjectId": { "kind": "header", "displayName": "", "group": "common", "label": "", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "the object id to store \/ find your object inside the cache" }, + "CamelHazelcastObjectValue": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "Object", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The old value" }, + "CamelHazelcastObjectTtlValue": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "Integer", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The value of the TTL" }, + "CamelHazelcastObjectTtlUnit": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "java.util.concurrent.TimeUnit", "enum": [ "NANOSECONDS", "MICROSECONDS", "MILLISECONDS", "SECONDS", "MINUTES", "HOURS", "DAYS" ], "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The value of time unit ( DAYS \/ HOURS \/ MINUTES \/ ...." }, + "CamelHazelcastQuery": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The query to execute against the map with a sql like syntax (see http:\/\/www.hazelcast.com\/)" }, + "CamelHazelcastListenerAction": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The type of event - here *added* and *removed*" }, + "CamelHazelcastListenerType": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The map consumer" }, + "CamelHazelcastListenerTime": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "Long", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The time of the event in millis" }, + "CamelHazelcastCacheName": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The name of the cache - e.g. \"foo\"" }, + "CamelHazelcastOperationType": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The operation to perform" } + }, "properties": { "cacheName": { "kind": "path", "displayName": "Cache Name", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The name of the cache" }, "defaultOperation": { "kind": "parameter", "displayName": "Default Operation", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.hazelcast.HazelcastOperation", "enum": [ "put", "delete", "get", "update", "query", "getAll", "clear", "putIfAbsent", "allAll", "removeAll", "retainAll", "evict", "evictAll", "valueCount", "containsKey", "containsValue", "keySet", "removevalue", "increment", "decrement", "setvalue", "destroy", "comp [...] diff --git a/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/multimap/hazelcast-multimap.json b/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/multimap/hazelcast-multimap.json index f6870c1..3d66f59 100644 --- a/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/multimap/hazelcast-multimap.json +++ b/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/multimap/hazelcast-multimap.json @@ -28,6 +28,15 @@ "hazelcastInstance": { "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 instance." }, "hazelcastMode": { "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": { + "CamelHazelcastObjectId": { "kind": "header", "displayName": "", "group": "common", "label": "", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "the object id to store \/ find your object inside the cache" }, + "CamelHazelcastListenerAction": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The type of event - here *added* and *removed*" }, + "CamelHazelcastListenerType": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The map consumer" }, + "CamelHazelcastListenerTime": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "Long", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The time of the event in millis" }, + "CamelHazelcastCacheName": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The name of the cache - e.g. \"foo\"" }, + "CamelHazelcastCacheType": { "kind": "header", "displayName": "", "group": "common", "label": "", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The type of the cache - here multimap" }, + "CamelHazelcastOperationType": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The operation to perform" } + }, "properties": { "cacheName": { "kind": "path", "displayName": "Cache Name", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The name of the cache" }, "defaultOperation": { "kind": "parameter", "displayName": "Default Operation", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.hazelcast.HazelcastOperation", "enum": [ "put", "delete", "get", "update", "query", "getAll", "clear", "putIfAbsent", "allAll", "removeAll", "retainAll", "evict", "evictAll", "valueCount", "containsKey", "containsValue", "keySet", "removevalue", "increment", "decrement", "setvalue", "destroy", "comp [...] diff --git a/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/queue/hazelcast-queue.json b/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/queue/hazelcast-queue.json index 2c893fc..9395562 100644 --- a/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/queue/hazelcast-queue.json +++ b/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/queue/hazelcast-queue.json @@ -28,6 +28,15 @@ "hazelcastInstance": { "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 instance." }, "hazelcastMode": { "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": { + "CamelHazelcastObjectId": { "kind": "header", "displayName": "", "group": "common", "label": "", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "the object id to store \/ find your object inside the cache" }, + "CamelHazelcastDrainToCollection": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "Collection", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The collection to transfer elements into" }, + "CamelHazelcastListenerAction": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The type of event - here *added* and *removed*" }, + "CamelHazelcastListenerType": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The map consumer" }, + "CamelHazelcastListenerTime": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "Long", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The time of the event in millis" }, + "CamelHazelcastCacheName": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The name of the cache - e.g. \"foo\"" }, + "CamelHazelcastOperationType": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The operation to perform" } + }, "properties": { "cacheName": { "kind": "path", "displayName": "Cache Name", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The name of the cache" }, "defaultOperation": { "kind": "parameter", "displayName": "Default Operation", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.hazelcast.HazelcastOperation", "enum": [ "put", "delete", "get", "update", "query", "getAll", "clear", "putIfAbsent", "allAll", "removeAll", "retainAll", "evict", "evictAll", "valueCount", "containsKey", "containsValue", "keySet", "removevalue", "increment", "decrement", "setvalue", "destroy", "comp [...] diff --git a/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/replicatedmap/hazelcast-replicatedmap.json b/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/replicatedmap/hazelcast-replicatedmap.json index 9646716..1195fc7 100644 --- a/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/replicatedmap/hazelcast-replicatedmap.json +++ b/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/replicatedmap/hazelcast-replicatedmap.json @@ -28,6 +28,14 @@ "hazelcastInstance": { "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 instance." }, "hazelcastMode": { "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": { + "CamelHazelcastObjectId": { "kind": "header", "displayName": "", "group": "common", "label": "", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "the object id to store \/ find your object inside the cache" }, + "CamelHazelcastListenerAction": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The type of event - here *added* and *removed*" }, + "CamelHazelcastListenerType": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The map consumer" }, + "CamelHazelcastListenerTime": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "Long", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The time of the event in millis" }, + "CamelHazelcastCacheName": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The name of the cache - e.g. \"foo\"" }, + "CamelHazelcastOperationType": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The operation to perform" } + }, "properties": { "cacheName": { "kind": "path", "displayName": "Cache Name", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The name of the cache" }, "defaultOperation": { "kind": "parameter", "displayName": "Default Operation", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.hazelcast.HazelcastOperation", "enum": [ "put", "delete", "get", "update", "query", "getAll", "clear", "putIfAbsent", "allAll", "removeAll", "retainAll", "evict", "evictAll", "valueCount", "containsKey", "containsValue", "keySet", "removevalue", "increment", "decrement", "setvalue", "destroy", "comp [...] diff --git a/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/ringbuffer/hazelcast-ringbuffer.json b/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/ringbuffer/hazelcast-ringbuffer.json index a3c8d71..dafb4d6 100644 --- a/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/ringbuffer/hazelcast-ringbuffer.json +++ b/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/ringbuffer/hazelcast-ringbuffer.json @@ -27,6 +27,9 @@ "hazelcastInstance": { "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 instance." }, "hazelcastMode": { "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": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The operation to perform" } + }, "properties": { "cacheName": { "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": { "kind": "parameter", "displayName": "Default Operation", "group": "producer", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.hazelcast.HazelcastOperation", "enum": [ "put", "delete", "get", "update", "query", "getAll", "clear", "putIfAbsent", "allAll", "removeAll", "retainAll", "evict", "evictAll", "valueCount", "containsKey", "containsValue", "keySet", "removevalue", "increment", "decrement", "setvalue", "destroy", "co [...] diff --git a/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/set/hazelcast-set.json b/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/set/hazelcast-set.json index e8bdde2..227cac6 100644 --- a/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/set/hazelcast-set.json +++ b/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/set/hazelcast-set.json @@ -28,6 +28,14 @@ "hazelcastInstance": { "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 instance." }, "hazelcastMode": { "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": { + "CamelHazelcastObjectId": { "kind": "header", "displayName": "", "group": "common", "label": "", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "the object id to store \/ find your object inside the cache" }, + "CamelHazelcastListenerAction": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The type of event - here *added* and *removed*" }, + "CamelHazelcastListenerType": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The map consumer" }, + "CamelHazelcastListenerTime": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "Long", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The time of the event in millis" }, + "CamelHazelcastCacheName": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The name of the cache - e.g. \"foo\"" }, + "CamelHazelcastOperationType": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The operation to perform" } + }, "properties": { "cacheName": { "kind": "path", "displayName": "Cache Name", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The name of the cache" }, "defaultOperation": { "kind": "parameter", "displayName": "Default Operation", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.hazelcast.HazelcastOperation", "enum": [ "put", "delete", "get", "update", "query", "getAll", "clear", "putIfAbsent", "allAll", "removeAll", "retainAll", "evict", "evictAll", "valueCount", "containsKey", "containsValue", "keySet", "removevalue", "increment", "decrement", "setvalue", "destroy", "comp [...] diff --git a/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/topic/hazelcast-topic.json b/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/topic/hazelcast-topic.json index 40dc05b..253b625 100644 --- a/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/topic/hazelcast-topic.json +++ b/components/camel-hazelcast/src/generated/resources/org/apache/camel/component/hazelcast/topic/hazelcast-topic.json @@ -28,6 +28,14 @@ "hazelcastInstance": { "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 instance." }, "hazelcastMode": { "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": { + "CamelHazelcastObjectId": { "kind": "header", "displayName": "", "group": "common", "label": "", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "the object id to store \/ find your object inside the cache" }, + "CamelHazelcastListenerAction": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The type of event - here *added* and *removed*" }, + "CamelHazelcastListenerType": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The map consumer" }, + "CamelHazelcastListenerTime": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "Long", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The time of the event in millis" }, + "CamelHazelcastCacheName": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The name of the cache - e.g. \"foo\"" }, + "CamelHazelcastOperationType": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The operation to perform" } + }, "properties": { "cacheName": { "kind": "path", "displayName": "Cache Name", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The name of the cache" }, "defaultOperation": { "kind": "parameter", "displayName": "Default Operation", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.hazelcast.HazelcastOperation", "enum": [ "put", "delete", "get", "update", "query", "getAll", "clear", "putIfAbsent", "allAll", "removeAll", "retainAll", "evict", "evictAll", "valueCount", "containsKey", "containsValue", "keySet", "removevalue", "increment", "decrement", "setvalue", "destroy", "comp [...] diff --git a/components/camel-hazelcast/src/main/docs/hazelcast-atomicvalue-component.adoc b/components/camel-hazelcast/src/main/docs/hazelcast-atomicvalue-component.adoc index f82d349..ad96b0e 100644 --- a/components/camel-hazelcast/src/main/docs/hazelcast-atomicvalue-component.adoc +++ b/components/camel-hazelcast/src/main/docs/hazelcast-atomicvalue-component.adoc @@ -35,20 +35,18 @@ include::partial$component-endpoint-options.adoc[] == atomic number producer - to("hazelcast-atomicvalue:foo") The operations for this producer are: + * setvalue (set the number with a given value) * get -* increase (+1) -* decrease (-1) +* increment (+1) +* decrement (-1) * destroy +* compareAndSet +* getAndAdd -Header Variables for the request message: - -[width="100%",cols="10%,10%,80%",options="header",] -|======================================================================= -|Name |Type |Description - -|`CamelHazelcastOperationType` |`String` |valid values are: setvalue, get, increase, decrease, destroy -|======================================================================= +// component headers: START +include::partial$component-endpoint-headers.adoc[] +// component headers: END === Sample for *set*: diff --git a/components/camel-hazelcast/src/main/docs/hazelcast-instance-component.adoc b/components/camel-hazelcast/src/main/docs/hazelcast-instance-component.adoc index fbae7e0..df321e1 100644 --- a/components/camel-hazelcast/src/main/docs/hazelcast-instance-component.adoc +++ b/components/camel-hazelcast/src/main/docs/hazelcast-instance-component.adoc @@ -50,25 +50,8 @@ fromF("hazelcast-%sfoo", HazelcastConstants.INSTANCE_PREFIX) .to("mock:removed"); ----------------------------------------------------------------------------------------- -Each event provides the following information inside the message header: - -Header Variables inside the response message: - - -[width="100%",cols="10%,10%,80%",options="header",] -|======================================================================= -|Name |Type |Description - -|`CamelHazelcastListenerTime` |`Long` |time of the event in millis - -|`CamelHazelcastListenerType` |`String` |the map consumer sets here "instancelistener" - -|`CamelHazelcastListenerAction` |`String` |type of event - here *added* or *removed*. - -|`CamelHazelcastInstanceHost` |`String` | host name of the instance - -|`CamelHazelcastInstancePort` |`Integer` |port number of the instance -|======================================================================= - +// component headers: START +include::partial$component-endpoint-headers.adoc[] +// component headers: END include::spring-boot:partial$starter.adoc[] diff --git a/components/camel-hazelcast/src/main/docs/hazelcast-list-component.adoc b/components/camel-hazelcast/src/main/docs/hazelcast-list-component.adoc index 6bc0e1c..da4c064 100644 --- a/components/camel-hazelcast/src/main/docs/hazelcast-list-component.adoc +++ b/components/camel-hazelcast/src/main/docs/hazelcast-list-component.adoc @@ -34,14 +34,20 @@ include::partial$component-endpoint-options.adoc[] == List producer – to(“hazelcast-list:foo”) -The list producer provides 7 operations: +The list producer provides 8 operations: + * add * addAll -* set +* setvalue * get * removevalue * removeAll * clear +* retainAll + +// component headers: START +include::partial$component-endpoint-headers.adoc[] +// component headers: END === Sample for *add*: diff --git a/components/camel-hazelcast/src/main/docs/hazelcast-map-component.adoc b/components/camel-hazelcast/src/main/docs/hazelcast-map-component.adoc index 8bb8505..996aa4a 100644 --- a/components/camel-hazelcast/src/main/docs/hazelcast-map-component.adoc +++ b/components/camel-hazelcast/src/main/docs/hazelcast-map-component.adoc @@ -54,28 +54,9 @@ The map cache producer provides follow operations specified by *CamelHazelcastOp * evict * evictAll -All operations are provide the inside the "hazelcast.operation.type" header variable. In Java -DSL you can use the constants from `org.apache.camel.component.hazelcast.HazelcastOperation`. - -Header Variables for the request message: - -[width="100%",cols="10%,10%,80%",options="header",] -|======================================================================= -|Name |Type |Description -|`CamelHazelcastOperationType` |`String` | as already described. - -|`CamelHazelcastObjectId` |`String` |the object id to store / find your object inside the cache (not needed for the query operation) -|======================================================================= - -*put* and *putIfAbsent* operations provide an eviction mechanism: - -[width="100%",cols="10%,10%,80%",options="header",] -|======================================================================= -|Name |Type |Description -|`CamelHazelcastObjectTtlValue` |`Integer` | value of TTL. - -|`CamelHazelcastObjectTtlUnit` |`java.util.concurrent.TimeUnit` | value of time unit ( DAYS / HOURS / MINUTES / .... -|======================================================================= +// component headers: START +include::partial$component-endpoint-headers.adoc[] +// component headers: END You can call the samples with: diff --git a/components/camel-hazelcast/src/main/docs/hazelcast-multimap-component.adoc b/components/camel-hazelcast/src/main/docs/hazelcast-multimap-component.adoc index dc49848..57e6196 100644 --- a/components/camel-hazelcast/src/main/docs/hazelcast-multimap-component.adoc +++ b/components/camel-hazelcast/src/main/docs/hazelcast-multimap-component.adoc @@ -35,19 +35,22 @@ include::partial$component-endpoint-options.adoc[] == multimap cache producer - to("hazelcast-multimap:foo") -A multimap is a cache where you can store n values to one key. The -multimap producer provides 4 operations (put, get, removevalue, delete). +A multimap is a cache where you can store n values to one key. -Header Variables for the request message: +The multimap producer provides 8 operations: -[width="100%",cols="10%,10%,80%",options="header",] -|======================================================================= -|Name |Type |Description +* put +* get +* removevalue +* delete +* containsKey +* containsValue +* clear +* valueCount -|`CamelHazelcastOperationType` |`String` |valid values are: put, get, removevalue, delete, clear. - -|`CamelHazelcastObjectId` |`String` |the object id to store / find your object inside the cache -|======================================================================= +// component headers: START +include::partial$component-endpoint-headers.adoc[] +// component headers: END === Sample for *put*: @@ -166,7 +169,7 @@ template.sendBodyAndHeader("direct:[put|get|removevalue|delete]", "my-foo", Haze == multimap cache consumer - from("hazelcast-multimap:foo") For the multimap cache this component provides the same listeners / -variables as for the map cache consumer (except the update and enviction +variables as for the map cache consumer (except the update and eviction listener). The only difference is the *multimap* prefix inside the URI. Here is a sample: @@ -188,24 +191,4 @@ fromF("hazelcast-%sbar", HazelcastConstants.MULTIMAP_PREFIX) .log("fail!"); -------------------------------------------------------------------------------------------------- -Header Variables inside the response message: - -[width="100%",cols="10%,10%,80%",options="header",] -|======================================================================= -|Name |Type |Description - -|`CamelHazelcastListenerTime` |`Long` |time of the event in millis - -|`CamelHazelcastListenerType` |`String` |the map consumer sets here "cachelistener" - -|`CamelHazelcastListenerAction` |`String` |type of event - here *added* and *removed* (and soon *envicted*) - -|`CamelHazelcastObjectId` |`String` |the oid of the object - -|`CamelHazelcastCacheName` |`String` |the name of the cache - e.g. "foo" - -|`CamelHazelcastCacheType` |`String` |the type of the cache - here multimap -|======================================================================= - - include::spring-boot:partial$starter.adoc[] diff --git a/components/camel-hazelcast/src/main/docs/hazelcast-queue-component.adoc b/components/camel-hazelcast/src/main/docs/hazelcast-queue-component.adoc index 78e1eca..a86d660 100644 --- a/components/camel-hazelcast/src/main/docs/hazelcast-queue-component.adoc +++ b/components/camel-hazelcast/src/main/docs/hazelcast-queue-component.adoc @@ -34,19 +34,24 @@ include::partial$component-endpoint-options.adoc[] == Queue producer – to(“hazelcast-queue:foo”) -The queue producer provides 10 operations: +The queue producer provides 12 operations: + * add * put * poll * peek * offer -* remove value -* remaining capacity -* remove all -* remove if -* drain to +* removevalue +* remainingCapacity +* removeAll +* removeIf +* drainTo * take -* retain all +* retainAll + +// component headers: START +include::partial$component-endpoint-headers.adoc[] +// component headers: END === Sample for *add*: diff --git a/components/camel-hazelcast/src/main/docs/hazelcast-replicatedmap-component.adoc b/components/camel-hazelcast/src/main/docs/hazelcast-replicatedmap-component.adoc index 721a86b..6f6bc1c 100644 --- a/components/camel-hazelcast/src/main/docs/hazelcast-replicatedmap-component.adoc +++ b/components/camel-hazelcast/src/main/docs/hazelcast-replicatedmap-component.adoc @@ -34,22 +34,18 @@ include::partial$component-endpoint-options.adoc[] == replicatedmap cache producer -The replicatedmap producer provides 4 operations: +The replicatedmap producer provides 6 operations: + * put * get * delete * clear +* containsKey +* containsValue -Header Variables for the request message: - -[width="100%",cols="10%,10%,80%",options="header",] -|======================================================================= -|Name |Type |Description - -|`CamelHazelcastOperationType` |`String` | valid values are: put, get, removevalue, delete - -|`CamelHazelcastObjectId` |`String` | the object id to store / find your object inside the cache -|======================================================================= +// component headers: START +include::partial$component-endpoint-headers.adoc[] +// component headers: END === Sample for *put*: diff --git a/components/camel-hazelcast/src/main/docs/hazelcast-ringbuffer-component.adoc b/components/camel-hazelcast/src/main/docs/hazelcast-ringbuffer-component.adoc index 278aace..fe804a8 100644 --- a/components/camel-hazelcast/src/main/docs/hazelcast-ringbuffer-component.adoc +++ b/components/camel-hazelcast/src/main/docs/hazelcast-ringbuffer-component.adoc @@ -35,22 +35,16 @@ include::partial$component-endpoint-options.adoc[] == ringbuffer cache producer The ringbuffer producer provides 5 operations: + * add -* readonceHead -* readonceTail +* readOnceHead +* readOnceTail * remainingCapacity * capacity -Header Variables for the request message: - -[width="100%",cols="10%,10%,80%",options="header",] -|======================================================================= -|Name |Type |Description - -|`CamelHazelcastOperationType` |`String` |valid values are: put, get, removevalue, delete - -|`CamelHazelcastObjectId` |`String` |the object id to store / find your object inside the cache -|======================================================================= +// component headers: START +include::partial$component-endpoint-headers.adoc[] +// component headers: END === Sample for *put*: diff --git a/components/camel-hazelcast/src/main/docs/hazelcast-seda-component.adoc b/components/camel-hazelcast/src/main/docs/hazelcast-seda-component.adoc index 3e8dd6e..7321a45 100644 --- a/components/camel-hazelcast/src/main/docs/hazelcast-seda-component.adoc +++ b/components/camel-hazelcast/src/main/docs/hazelcast-seda-component.adoc @@ -37,6 +37,10 @@ include::partial$component-endpoint-options.adoc[] The SEDA producer provides no operations. You only send data to the specified queue. +// component headers: START +include::partial$component-endpoint-headers.adoc[] +// component headers: END + Java DSL : [source,java] diff --git a/components/camel-hazelcast/src/main/docs/hazelcast-set-component.adoc b/components/camel-hazelcast/src/main/docs/hazelcast-set-component.adoc index e21cbb3..55c0afd 100644 --- a/components/camel-hazelcast/src/main/docs/hazelcast-set-component.adoc +++ b/components/camel-hazelcast/src/main/docs/hazelcast-set-component.adoc @@ -30,6 +30,20 @@ include::partial$component-endpoint-options.adoc[] // endpoint options: END +== set cache producer +The set producer provides 7 operations: + +* add +* removeAll +* clear +* addAll +* removeAll +* retainAll +* getAll + +// component headers: START +include::partial$component-endpoint-headers.adoc[] +// component headers: END include::spring-boot:partial$starter.adoc[] diff --git a/components/camel-hazelcast/src/main/docs/hazelcast-topic-component.adoc b/components/camel-hazelcast/src/main/docs/hazelcast-topic-component.adoc index 20897be..b325cdb 100644 --- a/components/camel-hazelcast/src/main/docs/hazelcast-topic-component.adoc +++ b/components/camel-hazelcast/src/main/docs/hazelcast-topic-component.adoc @@ -37,6 +37,10 @@ include::partial$component-endpoint-options.adoc[] The topic producer provides only one operation (publish). +// component headers: START +include::partial$component-endpoint-headers.adoc[] +// component headers: END + === Sample for *publish*: [source,java] 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 c15cab8..0217c47 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 @@ -16,8 +16,25 @@ */ package org.apache.camel.component.hazelcast; +import org.apache.camel.spi.Metadata; + 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"; + public static final String SCHEME_MULTIMAP = "hazelcast-multimap"; + public static final String SCHEME_QUEUE = "hazelcast-queue"; + public static final String SCHEME_REPLICATED_MAP = "hazelcast-replicatedmap"; + public static final String SCHEME_RING_BUFFER = "hazelcast-ringbuffer"; + public static final String SCHEME_SEDA = "hazelcast-seda"; + public static final String SCHEME_SET = "hazelcast-set"; + public static final String SCHEME_TOPIC = "hazelcast-topic"; + /* * uri prefixes */ @@ -36,27 +53,62 @@ public final class HazelcastConstants { /* * incoming header properties */ + @Metadata(description = "the object id to store / find your object inside the cache", javaType = "String", applicableFor = { + SCHEME_MULTIMAP, SCHEME_REPLICATED_MAP, SCHEME_LIST, SCHEME_QUEUE, SCHEME_SET, SCHEME_MAP, SCHEME_TOPIC }) public static final String OBJECT_ID = "CamelHazelcastObjectId"; + @Metadata(label = "producer", description = "The index of the object", javaType = "Integer", applicableFor = SCHEME_LIST) public static final String OBJECT_POS = "CamelHazelcastObjectIndex"; + @Metadata(label = "producer", description = "The old value", javaType = "Object", applicableFor = SCHEME_MAP) public static final String OBJECT_VALUE = "CamelHazelcastObjectValue"; + @Metadata(label = "producer", description = "The value of the TTL", javaType = "Integer", applicableFor = SCHEME_MAP) public static final String TTL_VALUE = "CamelHazelcastObjectTtlValue"; + @Metadata(label = "producer", description = "The value of time unit ( DAYS / HOURS / MINUTES / ....", + javaType = "java.util.concurrent.TimeUnit", applicableFor = SCHEME_MAP) public static final String TTL_UNIT = "CamelHazelcastObjectTtlUnit"; + @Metadata(label = "producer", + description = "The query to execute against the map with a sql like syntax (see http://www.hazelcast.com/)", + javaType = "String", applicableFor = SCHEME_MAP) public static final String QUERY = "CamelHazelcastQuery"; public static final String EXPECTED_VALUE = "CamelHazelcastExpectedValue"; + @Metadata(label = "producer", description = "The collection to transfer elements into", javaType = "Collection", + applicableFor = SCHEME_QUEUE) public static final String DRAIN_TO_COLLECTION = "CamelHazelcastDrainToCollection"; /* * outgoing header properties */ + @Metadata(label = "consumer", description = "The type of event - here *added* and *removed*", javaType = "String", + applicableFor = { + SCHEME_MULTIMAP, SCHEME_REPLICATED_MAP, SCHEME_LIST, SCHEME_QUEUE, SCHEME_SET, SCHEME_MAP, SCHEME_TOPIC, + SCHEME_INSTANCE }) public static final String LISTENER_ACTION = "CamelHazelcastListenerAction"; + @Metadata(label = "consumer", description = "The map consumer", javaType = "String", + applicableFor = { + SCHEME_MULTIMAP, SCHEME_REPLICATED_MAP, SCHEME_LIST, SCHEME_QUEUE, SCHEME_SET, SCHEME_MAP, SCHEME_TOPIC, + SCHEME_INSTANCE }) public static final String LISTENER_TYPE = "CamelHazelcastListenerType"; + @Metadata(label = "consumer", description = "The time of the event in millis", javaType = "Long", + applicableFor = { + SCHEME_MULTIMAP, SCHEME_REPLICATED_MAP, SCHEME_LIST, SCHEME_QUEUE, SCHEME_SET, SCHEME_MAP, SCHEME_TOPIC, + SCHEME_INSTANCE }) public static final String LISTENER_TIME = "CamelHazelcastListenerTime"; + @Metadata(label = "consumer", description = "The host name of the instance", javaType = "String", + applicableFor = SCHEME_INSTANCE) public static final String INSTANCE_HOST = "CamelHazelcastInstanceHost"; + @Metadata(label = "consumer", description = "The port number of the instance", javaType = "Integer", + applicableFor = SCHEME_INSTANCE) public static final String INSTANCE_PORT = "CamelHazelcastInstancePort"; + @Metadata(label = "consumer", description = "The name of the cache - e.g. \"foo\"", javaType = "String", applicableFor = { + SCHEME_MULTIMAP, SCHEME_REPLICATED_MAP, SCHEME_LIST, SCHEME_QUEUE, SCHEME_SET, SCHEME_MAP, SCHEME_TOPIC }) public static final String CACHE_NAME = "CamelHazelcastCacheName"; + @Metadata(description = "The type of the cache - here multimap", javaType = "String", applicableFor = SCHEME_MULTIMAP) public static final String CACHE_TYPE = "CamelHazelcastCacheType"; // actions (PUT, DELETE, GET, GET_ALL, UPDATE, CLEAR) + @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 }) public static final String OPERATION = "CamelHazelcastOperationType"; /** 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 index dbc4d54..faa05e1 100644 --- 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 @@ -23,14 +23,18 @@ 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). */ -@UriEndpoint(firstVersion = "2.7.0", scheme = "hazelcast-atomicvalue", title = "Hazelcast Atomic Number", - syntax = "hazelcast-atomicvalue:cacheName", producerOnly = true, category = { Category.CACHE, Category.DATAGRID }) +@UriEndpoint(firstVersion = "2.7.0", scheme = SCHEME_ATOMIC_VALUE, title = "Hazelcast Atomic Number", + syntax = "hazelcast-atomicvalue:cacheName", producerOnly = true, category = { Category.CACHE, Category.DATAGRID }, + headersClass = HazelcastConstants.class) public class HazelcastAtomicnumberEndpoint extends HazelcastDefaultEndpoint { public HazelcastAtomicnumberEndpoint(HazelcastInstance hazelcastInstance, String uri, Component component, diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/instance/HazelcastInstanceEndpoint.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/instance/HazelcastInstanceEndpoint.java index 0cdab75..e25f57c 100644 --- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/instance/HazelcastInstanceEndpoint.java +++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/instance/HazelcastInstanceEndpoint.java @@ -22,16 +22,19 @@ 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.HazelcastDefaultComponent; import org.apache.camel.component.hazelcast.HazelcastDefaultEndpoint; import org.apache.camel.spi.UriEndpoint; +import static org.apache.camel.component.hazelcast.HazelcastConstants.SCHEME_INSTANCE; + /** * Consume join/leave events of a cache instance in a Hazelcast cluster. */ -@UriEndpoint(firstVersion = "2.7.0", scheme = "hazelcast-instance", title = "Hazelcast Instance", +@UriEndpoint(firstVersion = "2.7.0", scheme = SCHEME_INSTANCE, title = "Hazelcast Instance", syntax = "hazelcast-instance:cacheName", - consumerOnly = true, category = { Category.CACHE, Category.DATAGRID }) + consumerOnly = true, category = { Category.CACHE, Category.DATAGRID }, headersClass = HazelcastConstants.class) public class HazelcastInstanceEndpoint extends HazelcastDefaultEndpoint { public HazelcastInstanceEndpoint(HazelcastInstance hazelcastInstance, String uri, HazelcastDefaultComponent component) { diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/list/HazelcastListEndpoint.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/list/HazelcastListEndpoint.java index 4a6ed8f..aab407b 100644 --- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/list/HazelcastListEndpoint.java +++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/list/HazelcastListEndpoint.java @@ -23,14 +23,17 @@ 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_LIST; + /** * Perform operations on <a href="http://www.hazelcast.com/";>Hazelcast</a> distributed list. */ -@UriEndpoint(firstVersion = "2.7.0", scheme = "hazelcast-list", title = "Hazelcast List", syntax = "hazelcast-list:cacheName", - category = { Category.CACHE, Category.DATAGRID }) +@UriEndpoint(firstVersion = "2.7.0", scheme = SCHEME_LIST, title = "Hazelcast List", syntax = "hazelcast-list:cacheName", + category = { Category.CACHE, Category.DATAGRID }, headersClass = HazelcastConstants.class) public class HazelcastListEndpoint extends HazelcastDefaultEndpoint { public HazelcastListEndpoint(HazelcastInstance hazelcastInstance, String endpointUri, Component component, diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/map/HazelcastMapEndpoint.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/map/HazelcastMapEndpoint.java index e1c10e1..0e5027e 100644 --- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/map/HazelcastMapEndpoint.java +++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/map/HazelcastMapEndpoint.java @@ -22,15 +22,18 @@ 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.HazelcastDefaultComponent; import org.apache.camel.component.hazelcast.HazelcastDefaultEndpoint; import org.apache.camel.spi.UriEndpoint; +import static org.apache.camel.component.hazelcast.HazelcastConstants.SCHEME_MAP; + /** * Perform operations on <a href="http://www.hazelcast.com/";>Hazelcast</a> distributed map. */ -@UriEndpoint(firstVersion = "2.7.0", scheme = "hazelcast-map", title = "Hazelcast Map", syntax = "hazelcast-map:cacheName", - category = { Category.CACHE, Category.DATAGRID }) +@UriEndpoint(firstVersion = "2.7.0", scheme = SCHEME_MAP, title = "Hazelcast Map", syntax = "hazelcast-map:cacheName", + category = { Category.CACHE, Category.DATAGRID }, headersClass = HazelcastConstants.class) public class HazelcastMapEndpoint extends HazelcastDefaultEndpoint { public HazelcastMapEndpoint(HazelcastInstance hazelcastInstance, String uri, String cacheName, diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/multimap/HazelcastMultimapEndpoint.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/multimap/HazelcastMultimapEndpoint.java index e969f57..89b0386 100644 --- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/multimap/HazelcastMultimapEndpoint.java +++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/multimap/HazelcastMultimapEndpoint.java @@ -22,15 +22,19 @@ 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.HazelcastDefaultComponent; import org.apache.camel.component.hazelcast.HazelcastDefaultEndpoint; import org.apache.camel.spi.UriEndpoint; +import static org.apache.camel.component.hazelcast.HazelcastConstants.SCHEME_MULTIMAP; + /** * Perform operations on <a href="http://www.hazelcast.com/";>Hazelcast</a> distributed multimap. */ -@UriEndpoint(firstVersion = "2.7.0", scheme = "hazelcast-multimap", title = "Hazelcast Multimap", - syntax = "hazelcast-multimap:cacheName", category = { Category.CACHE, Category.DATAGRID }) +@UriEndpoint(firstVersion = "2.7.0", scheme = SCHEME_MULTIMAP, title = "Hazelcast Multimap", + syntax = "hazelcast-multimap:cacheName", category = { Category.CACHE, Category.DATAGRID }, + headersClass = HazelcastConstants.class) public class HazelcastMultimapEndpoint extends HazelcastDefaultEndpoint { public HazelcastMultimapEndpoint(HazelcastInstance hazelcastInstance, String uri, String cacheName, diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueEndpoint.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueEndpoint.java index 660e61f..cfc2230 100644 --- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueEndpoint.java +++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueEndpoint.java @@ -25,16 +25,20 @@ 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.component.hazelcast.HazelcastOperation; import org.apache.camel.spi.UriEndpoint; import org.apache.camel.spi.UriParam; +import static org.apache.camel.component.hazelcast.HazelcastConstants.SCHEME_QUEUE; + /** * Perform operations on <a href="http://www.hazelcast.com/";>Hazelcast</a> distributed queue. */ -@UriEndpoint(firstVersion = "2.7.0", scheme = "hazelcast-queue", title = "Hazelcast Queue", - syntax = "hazelcast-queue:cacheName", category = { Category.CACHE, Category.DATAGRID, Category.MESSAGING }) +@UriEndpoint(firstVersion = "2.7.0", scheme = SCHEME_QUEUE, title = "Hazelcast Queue", + syntax = "hazelcast-queue:cacheName", category = { Category.CACHE, Category.DATAGRID, Category.MESSAGING }, + headersClass = HazelcastConstants.class) public class HazelcastQueueEndpoint extends HazelcastDefaultEndpoint { @UriParam diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/replicatedmap/HazelcastReplicatedmapEndpoint.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/replicatedmap/HazelcastReplicatedmapEndpoint.java index 764b615..4fb21a0 100644 --- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/replicatedmap/HazelcastReplicatedmapEndpoint.java +++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/replicatedmap/HazelcastReplicatedmapEndpoint.java @@ -22,15 +22,19 @@ 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.HazelcastDefaultComponent; import org.apache.camel.component.hazelcast.HazelcastDefaultEndpoint; import org.apache.camel.spi.UriEndpoint; +import static org.apache.camel.component.hazelcast.HazelcastConstants.SCHEME_REPLICATED_MAP; + /** * Perform operations on <a href="http://www.hazelcast.com/";>Hazelcast</a> replicated map. */ -@UriEndpoint(firstVersion = "2.16.0", scheme = "hazelcast-replicatedmap", title = "Hazelcast Replicated Map", - syntax = "hazelcast-replicatedmap:cacheName", category = { Category.CACHE, Category.DATAGRID }) +@UriEndpoint(firstVersion = "2.16.0", scheme = SCHEME_REPLICATED_MAP, title = "Hazelcast Replicated Map", + syntax = "hazelcast-replicatedmap:cacheName", category = { Category.CACHE, Category.DATAGRID }, + headersClass = HazelcastConstants.class) public class HazelcastReplicatedmapEndpoint extends HazelcastDefaultEndpoint { public HazelcastReplicatedmapEndpoint(HazelcastInstance hazelcastInstance, String uri, String cacheName, diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/ringbuffer/HazelcastRingbufferEndpoint.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/ringbuffer/HazelcastRingbufferEndpoint.java index 8bdeb5d..41e626e 100644 --- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/ringbuffer/HazelcastRingbufferEndpoint.java +++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/ringbuffer/HazelcastRingbufferEndpoint.java @@ -23,14 +23,18 @@ 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_RING_BUFFER; + /** * Perform operations on <a href="http://www.hazelcast.com/";>Hazelcast</a> distributed ringbuffer. */ -@UriEndpoint(firstVersion = "2.16.0", scheme = "hazelcast-ringbuffer", title = "Hazelcast Ringbuffer", - syntax = "hazelcast-ringbuffer:cacheName", producerOnly = true, category = { Category.CACHE, Category.DATAGRID }) +@UriEndpoint(firstVersion = "2.16.0", scheme = SCHEME_RING_BUFFER, title = "Hazelcast Ringbuffer", + syntax = "hazelcast-ringbuffer:cacheName", producerOnly = true, category = { Category.CACHE, Category.DATAGRID }, + headersClass = HazelcastConstants.class) public class HazelcastRingbufferEndpoint extends HazelcastDefaultEndpoint { public HazelcastRingbufferEndpoint(HazelcastInstance hazelcastInstance, String uri, Component component, diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaEndpoint.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaEndpoint.java index 70290c8..d6b4fbc 100644 --- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaEndpoint.java +++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/seda/HazelcastSedaEndpoint.java @@ -24,18 +24,21 @@ 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.HazelcastDefaultComponent; import org.apache.camel.component.hazelcast.HazelcastDefaultEndpoint; import org.apache.camel.spi.UriEndpoint; import org.apache.camel.spi.UriParam; import org.apache.camel.util.ObjectHelper; +import static org.apache.camel.component.hazelcast.HazelcastConstants.SCHEME_SEDA; + /** * Asynchronously send/receive Exchanges between Camel routes running on potentially distinct JVMs/hosts backed by * Hazelcast {@link BlockingQueue}. */ -@UriEndpoint(firstVersion = "2.7.0", scheme = "hazelcast-seda", title = "Hazelcast SEDA", syntax = "hazelcast-seda:cacheName", - category = { Category.CACHE, Category.DATAGRID }) +@UriEndpoint(firstVersion = "2.7.0", scheme = SCHEME_SEDA, title = "Hazelcast SEDA", syntax = "hazelcast-seda:cacheName", + category = { Category.CACHE, Category.DATAGRID }, headersClass = HazelcastConstants.class) public class HazelcastSedaEndpoint extends HazelcastDefaultEndpoint { private final BlockingQueue<Object> queue; diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/set/HazelcastSetEndpoint.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/set/HazelcastSetEndpoint.java index adc0bd1..ce4e279 100644 --- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/set/HazelcastSetEndpoint.java +++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/set/HazelcastSetEndpoint.java @@ -23,14 +23,17 @@ 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_SET; + /** * Perform operations on <a href="http://www.hazelcast.com/";>Hazelcast</a> distributed set. */ -@UriEndpoint(firstVersion = "2.7.0", scheme = "hazelcast-set", title = "Hazelcast Set", syntax = "hazelcast-set:cacheName", - category = { Category.CACHE, Category.DATAGRID }) +@UriEndpoint(firstVersion = "2.7.0", scheme = SCHEME_SET, title = "Hazelcast Set", syntax = "hazelcast-set:cacheName", + category = { Category.CACHE, Category.DATAGRID }, headersClass = HazelcastConstants.class) public class HazelcastSetEndpoint extends HazelcastDefaultEndpoint { public HazelcastSetEndpoint(HazelcastInstance hazelcastInstance, String endpointUri, Component component, diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/topic/HazelcastTopicEndpoint.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/topic/HazelcastTopicEndpoint.java index 8b5ecfc..3c83e85 100644 --- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/topic/HazelcastTopicEndpoint.java +++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/topic/HazelcastTopicEndpoint.java @@ -24,16 +24,20 @@ import org.apache.camel.MultipleConsumersSupport; 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.component.hazelcast.HazelcastOperation; import org.apache.camel.spi.UriEndpoint; import org.apache.camel.spi.UriParam; +import static org.apache.camel.component.hazelcast.HazelcastConstants.SCHEME_TOPIC; + /** * Send and receive messages to/from <a href="http://www.hazelcast.com/";>Hazelcast</a> distributed topic. */ -@UriEndpoint(firstVersion = "2.15.0", scheme = "hazelcast-topic", title = "Hazelcast Topic", - syntax = "hazelcast-topic:cacheName", category = { Category.CACHE, Category.DATAGRID }) +@UriEndpoint(firstVersion = "2.15.0", scheme = SCHEME_TOPIC, title = "Hazelcast Topic", + syntax = "hazelcast-topic:cacheName", category = { Category.CACHE, Category.DATAGRID }, + headersClass = HazelcastConstants.class) public class HazelcastTopicEndpoint extends HazelcastDefaultEndpoint implements MultipleConsumersSupport { @UriParam
