Repository: incubator-ignite Updated Branches: refs/heads/ignite-143 155ebc0f6 -> 8230c8c74
# IGNITE-143 - Minor Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/8178340d Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/8178340d Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/8178340d Branch: refs/heads/ignite-143 Commit: 8178340deb2ce6eb6338a9909c7627cd3e2ccdb6 Parents: 155ebc0 Author: Valentin Kulichenko <vkuliche...@gridgain.com> Authored: Thu Feb 12 17:38:31 2015 -0800 Committer: Valentin Kulichenko <vkuliche...@gridgain.com> Committed: Thu Feb 12 17:38:31 2015 -0800 ---------------------------------------------------------------------- .../cache/query/continuous/CacheContinuousQueryEntry.java | 2 +- .../cache/query/continuous/CacheContinuousQueryHandler.java | 2 +- .../cache/query/continuous/CacheContinuousQueryListener.java | 6 +++++- 3 files changed, 7 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8178340d/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEntry.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEntry.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEntry.java index 72269c8..aa4ce54 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEntry.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEntry.java @@ -30,7 +30,7 @@ import java.io.*; import static org.apache.ignite.internal.processors.cache.GridCacheValueBytes.*; /** - * Continuous query event. + * Continuous query entry. */ class CacheContinuousQueryEntry<K, V> implements GridCacheDeployable, Externalizable { /** */ http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8178340d/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java index ece5a01..4ad664a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java @@ -39,7 +39,7 @@ import static org.apache.ignite.events.EventType.*; /** * Continuous query handler. */ -public class CacheContinuousQueryHandler<K, V> implements GridContinuousHandler { +class CacheContinuousQueryHandler<K, V> implements GridContinuousHandler { /** */ private static final long serialVersionUID = 0L; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8178340d/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryListener.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryListener.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryListener.java index 21c45f9..3695bad 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryListener.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryListener.java @@ -29,7 +29,8 @@ interface CacheContinuousQueryListener<K, V> { /** * Entry update callback. * - * @param e Entry. + * @param evt Event + * @param primary Primary flag. * @param recordIgniteEvt Whether to record event. */ public void onEntryUpdated(CacheContinuousQueryEvent<K, V> evt, boolean primary, boolean recordIgniteEvt); @@ -39,5 +40,8 @@ interface CacheContinuousQueryListener<K, V> { */ public void onUnregister(); + /** + * @return Whether old value is required. + */ public boolean oldValueRequired(); }
