You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2016/06/17 14:57:39 UTC
camel git commit: CAMEL-10068: Distribuited map,
retrieve hashmap keys. Thanks to Fabrizio Spataro for the patch.
Repository: camel
Updated Branches:
refs/heads/master e78476132 -> 241cc204e
CAMEL-10068: Distribuited map, retrieve hashmap keys. Thanks to Fabrizio Spataro for the patch.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/241cc204
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/241cc204
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/241cc204
Branch: refs/heads/master
Commit: 241cc204eb694a43712822985e277bae31f2ba92
Parents: e784761
Author: Andrea Cosentino <an...@gmail.com>
Authored: Fri Jun 17 16:56:29 2016 +0200
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Fri Jun 17 16:56:29 2016 +0200
----------------------------------------------------------------------
.../camel-hazelcast/src/main/docs/hazelcast.adoc | 2 +-
.../hazelcast/HazelcastComponentHelper.java | 1 +
.../component/hazelcast/HazelcastConstants.java | 1 +
.../hazelcast/map/HazelcastMapProducer.java | 15 +++++++++++++--
4 files changed, 16 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/241cc204/components/camel-hazelcast/src/main/docs/hazelcast.adoc
----------------------------------------------------------------------
diff --git a/components/camel-hazelcast/src/main/docs/hazelcast.adoc b/components/camel-hazelcast/src/main/docs/hazelcast.adoc
index ea6ac69..f14620d 100644
--- a/components/camel-hazelcast/src/main/docs/hazelcast.adoc
+++ b/components/camel-hazelcast/src/main/docs/hazelcast.adoc
@@ -128,7 +128,7 @@ Header Variables for the request message:
[width="100%",cols="10%,10%,80%",options="header",]
|=======================================================================
|Name |Type |Description
-|`CamelHazelcastOperationType` |`String` |valid values are: put, delete, get, update, query, getAll, putIfAbsent, clear.
+|`CamelHazelcastOperationType` |`String` |valid values are: put, delete, get, update, query, getAll, putIfAbsent, clear, keySet.
|`CamelHazelcastObjectId` |`String` |the object id to store / find your object inside the cache (not needed for the query operation)
|=======================================================================
http://git-wip-us.apache.org/repos/asf/camel/blob/241cc204/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastComponentHelper.java
----------------------------------------------------------------------
diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastComponentHelper.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastComponentHelper.java
index a2d63e9..ba7c6de 100644
--- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastComponentHelper.java
+++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastComponentHelper.java
@@ -103,6 +103,7 @@ public final class HazelcastComponentHelper {
addMapping("valueCount", HazelcastConstants.VALUE_COUNT_OPERATION);
addMapping("containsKey", HazelcastConstants.CONTAINS_KEY_OPERATION);
addMapping("containsValue", HazelcastConstants.CONTAINS_VALUE_OPERATION);
+ addMapping("keySet", HazelcastConstants.GET_KEYS_OPERATION);
// multimap
addMapping("removevalue", HazelcastConstants.REMOVEVALUE_OPERATION);
http://git-wip-us.apache.org/repos/asf/camel/blob/241cc204/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/HazelcastConstants.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 e4e8405..f2ef662 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
@@ -74,6 +74,7 @@ public final class HazelcastConstants {
public static final int VALUE_COUNT_OPERATION = 14;
public static final int CONTAINS_KEY_OPERATION = 15;
public static final int CONTAINS_VALUE_OPERATION = 16;
+ public static final int GET_KEYS_OPERATION = 41;
// multimap
public static final int REMOVEVALUE_OPERATION = 17;
http://git-wip-us.apache.org/repos/asf/camel/blob/241cc204/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/map/HazelcastMapProducer.java
----------------------------------------------------------------------
diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/map/HazelcastMapProducer.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/map/HazelcastMapProducer.java
index 563fe75..8d01721 100644
--- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/map/HazelcastMapProducer.java
+++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/map/HazelcastMapProducer.java
@@ -97,7 +97,11 @@ public class HazelcastMapProducer extends HazelcastDefaultProducer {
case HazelcastConstants.GET_ALL_OPERATION:
this.getAll(oid, exchange);
break;
-
+
+ case HazelcastConstants.GET_KEYS_OPERATION:
+ this.getKeys(exchange);
+ break;
+
case HazelcastConstants.CONTAINS_KEY_OPERATION:
this.containsKey(oid, exchange);
break;
@@ -264,4 +268,11 @@ public class HazelcastMapProducer extends HazelcastDefaultProducer {
Object body = exchange.getIn().getBody();
exchange.getOut().setBody(this.cache.containsValue(body));
}
-}
\ No newline at end of file
+
+ /**
+ * get keys set of objects and give it back
+ */
+ private void getKeys(Exchange exchange) {
+ exchange.getOut().setBody(this.cache.keySet());
+ }
+}