# ignite-43
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/2f5d4d8a Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/2f5d4d8a Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/2f5d4d8a Branch: refs/heads/ignite-99 Commit: 2f5d4d8a4a76a41f04d642594197df915459ef8d Parents: 48dd7fb Author: sboikov <sboi...@gridgain.com> Authored: Tue Jan 13 12:47:33 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Tue Jan 13 12:47:33 2015 +0300 ---------------------------------------------------------------------- .../cache/IgniteCacheEntryListenerAbstractTest.java | 15 +++++++++++++++ 1 file changed, 15 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/2f5d4d8a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheEntryListenerAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheEntryListenerAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheEntryListenerAbstractTest.java index b35e1a8..f63ab9d 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheEntryListenerAbstractTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheEntryListenerAbstractTest.java @@ -12,6 +12,8 @@ package org.apache.ignite.internal.processors.cache; import org.apache.ignite.*; import org.apache.ignite.lang.*; import org.gridgain.grid.cache.*; +import org.gridgain.grid.kernal.*; +import org.gridgain.grid.kernal.processors.continuous.*; import org.gridgain.grid.util.lang.*; import org.gridgain.grid.util.typedef.internal.*; import org.gridgain.testframework.*; @@ -61,6 +63,19 @@ public abstract class IgniteCacheEntryListenerAbstractTest extends IgniteCacheAb return cfg; } + /** {@inheritDoc} */ + @Override protected void afterTest() throws Exception { + super.afterTest(); + + for (int i = 0; i < gridCount(); i++) { + GridContinuousProcessor proc = ((GridKernal)grid(i)).context().continuous(); + + ConcurrentMap<?, ?> syncMsgFuts = GridTestUtils.getFieldValue(proc, "syncMsgFuts"); + + assertEquals(0, syncMsgFuts.size()); + } + } + /** * @throws Exception If failed. */
