# ignite-746-1
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/036b9ba3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/036b9ba3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/036b9ba3 Branch: refs/heads/ignite-755 Commit: 036b9ba3ad651c69cd44c44ab0a0fabcc9681b32 Parents: fba8396 Author: sboikov <sboi...@gridgain.com> Authored: Thu Apr 16 15:10:41 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Thu Apr 16 15:10:41 2015 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/atomic/GridDhtAtomicCache.java | 11 ----------- 1 file changed, 11 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/036b9ba3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java index d23d55e..33faf17 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java @@ -86,13 +86,6 @@ public class GridDhtAtomicCache<K, V> extends GridDhtCacheAdapter<K, V> { /** */ private GridNearAtomicCache<K, V> near; - /** */ - private final GridDisconnectListener disconnectLsnr = new GridDisconnectListener() { - @Override public void onNodeDisconnected(UUID nodeId) { - scheduleAtomicFutureRecheck(); - } - }; - /** * Empty constructor required by {@link Externalizable}. */ @@ -224,16 +217,12 @@ public class GridDhtAtomicCache<K, V> extends GridDhtCacheAdapter<K, V> { } }); } - - ctx.io().addDisconnectListener(disconnectLsnr); } /** {@inheritDoc} */ @Override public void stop() { for (DeferredResponseBuffer buf : pendingResponses.values()) buf.finish(); - - ctx.io().removeDisconnectListener(disconnectLsnr); } /**
