You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by nt...@apache.org on 2015/11/19 15:09:39 UTC
ignite git commit: IGNITE-426 Cleanup code.
Repository: ignite
Updated Branches:
refs/heads/ignite-426-2 b63f86bd0 -> 23e30743b
IGNITE-426 Cleanup code.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/23e30743
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/23e30743
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/23e30743
Branch: refs/heads/ignite-426-2
Commit: 23e30743bb8a7616fe4e5119e2532ef6c60aedd2
Parents: b63f86b
Author: Tikhonov Nikolay <ti...@gmail.com>
Authored: Thu Nov 19 17:13:12 2015 +0300
Committer: Tikhonov Nikolay <ti...@gmail.com>
Committed: Thu Nov 19 17:13:12 2015 +0300
----------------------------------------------------------------------
.../query/continuous/CacheContinuousQueryManager.java | 12 +-----------
1 file changed, 1 insertion(+), 11 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/23e30743/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
index 144194b..ceb8b37 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
@@ -54,7 +54,6 @@ import org.apache.ignite.internal.processors.cache.GridCacheEntryEx;
import org.apache.ignite.internal.processors.cache.GridCacheManagerAdapter;
import org.apache.ignite.internal.processors.cache.KeyCacheObject;
import org.apache.ignite.internal.processors.continuous.GridContinuousHandler;
-import org.apache.ignite.internal.processors.timeout.GridTimeoutProcessor;
import org.apache.ignite.internal.util.typedef.CI2;
import org.apache.ignite.internal.util.typedef.F;
import org.apache.ignite.internal.util.typedef.internal.U;
@@ -111,9 +110,6 @@ public class CacheContinuousQueryManager extends GridCacheManagerAdapter {
/** Ordered topic prefix. */
private String topicPrefix;
- /** Timeout backup flush task. */
- private GridTimeoutProcessor.CancelableTask backTask;
-
/** {@inheritDoc} */
@Override protected void start0() throws IgniteCheckedException {
// Append cache name to the topic.
@@ -129,13 +125,7 @@ public class CacheContinuousQueryManager extends GridCacheManagerAdapter {
}
});
- backTask = cctx.time().schedule(new BackupCleanerTask(lsnrs, cctx.kernalContext()), BACKUP_ACK_FREQ, BACKUP_ACK_FREQ);
- }
-
- /** {@inheritDoc} */
- @Override protected void stop0(boolean cancel) {
- if (backTask != null)
- backTask.close();
+ cctx.time().schedule(new BackupCleanerTask(lsnrs, cctx.kernalContext()), BACKUP_ACK_FREQ, BACKUP_ACK_FREQ);
}
/** {@inheritDoc} */