camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acosent...@apache.org
Subject camel git commit: CAMEL-11290: Camel-Infinispan: Continuous Query, add support for recordUpdated event
Date Wed, 17 May 2017 08:40:35 GMT
Repository: camel
Updated Branches:
  refs/heads/master 4332c7e65 -> a11cec91a


CAMEL-11290: Camel-Infinispan: Continuous Query, add support for recordUpdated event


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/a11cec91
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a11cec91
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a11cec91

Branch: refs/heads/master
Commit: a11cec91a7705ed100f23443252d1d5be9073915
Parents: 4332c7e
Author: Andrea Cosentino <ancosen@gmail.com>
Authored: Wed May 17 10:39:22 2017 +0200
Committer: Andrea Cosentino <ancosen@gmail.com>
Committed: Wed May 17 10:40:02 2017 +0200

----------------------------------------------------------------------
 .../apache/camel/component/infinispan/InfinispanConstants.java  | 1 +
 .../apache/camel/component/infinispan/InfinispanConsumer.java   | 5 +++++
 .../camel/component/infinispan/InfinispanContinuousQueryIT.java | 1 -
 3 files changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/a11cec91/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanConstants.java
----------------------------------------------------------------------
diff --git a/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanConstants.java
b/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanConstants.java
index 1b2a86b..0ad16e1 100644
--- a/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanConstants.java
+++ b/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanConstants.java
@@ -38,6 +38,7 @@ public interface InfinispanConstants {
 
     String CACHE_ENTRY_JOINING = "CacheEntryJoining";
     String CACHE_ENTRY_LEAVING = "CacheEntryLeaving";
+    String CACHE_ENTRY_UPDATED = "CacheEntryUpdated";
 
     /**
      * @deprecated use {@link InfinispanOperation#PUT} instead.

http://git-wip-us.apache.org/repos/asf/camel/blob/a11cec91/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanConsumer.java
----------------------------------------------------------------------
diff --git a/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanConsumer.java
b/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanConsumer.java
index d847ae4..5131c7f 100644
--- a/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanConsumer.java
+++ b/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanConsumer.java
@@ -137,6 +137,11 @@ public class InfinispanConsumer extends DefaultConsumer {
         public void resultJoining(Object key, Object value) {
             processEvent(InfinispanConstants.CACHE_ENTRY_JOINING, false, cacheName, key,
value);
         }
+        
+        @Override
+        public void resultUpdated(Object key, Object value) {
+            processEvent(InfinispanConstants.CACHE_ENTRY_UPDATED, false, cacheName, key,
value);
+        }
 
         @Override
         public void resultLeaving(Object key) {

http://git-wip-us.apache.org/repos/asf/camel/blob/a11cec91/components/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/InfinispanContinuousQueryIT.java
----------------------------------------------------------------------
diff --git a/components/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/InfinispanContinuousQueryIT.java
b/components/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/InfinispanContinuousQueryIT.java
index 2558823..8cb684a 100644
--- a/components/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/InfinispanContinuousQueryIT.java
+++ b/components/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/InfinispanContinuousQueryIT.java
@@ -123,7 +123,6 @@ public class InfinispanContinuousQueryIT extends CamelTestSupport {
         for (int i = 0; i < 4; i++) {
             continuousQuery.message(i).outHeader(InfinispanConstants.KEY).isEqualTo(createKey(CQ_USERS[i
% 2]));
             continuousQuery.message(i).outHeader(InfinispanConstants.CACHE_NAME).isEqualTo(cache.getName());
-
             if (i >= 2) {
                 continuousQuery.message(i).outHeader(InfinispanConstants.EVENT_TYPE).isEqualTo(InfinispanConstants.CACHE_ENTRY_LEAVING);
                 continuousQuery.message(i).outHeader(InfinispanConstants.EVENT_DATA).isNull();


Mime
View raw message