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 <[email protected]> Authored: Wed May 17 10:39:22 2017 +0200 Committer: Andrea Cosentino <[email protected]> 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();
