ignite-1732 Fixed test to catch IgniteClientDisconnectedException.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/712e62bd Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/712e62bd Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/712e62bd Branch: refs/heads/ignite-1537 Commit: 712e62bd241cecac969d022461fc048453b3db6b Parents: c2d4d1d Author: sboikov <sboi...@gridgain.com> Authored: Fri Nov 27 13:12:55 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Fri Nov 27 13:12:55 2015 +0300 ---------------------------------------------------------------------- .../dht/IgniteAtomicLongChangingTopologySelfTest.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/712e62bd/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/IgniteAtomicLongChangingTopologySelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/IgniteAtomicLongChangingTopologySelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/IgniteAtomicLongChangingTopologySelfTest.java index a8d5801..56bc760 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/IgniteAtomicLongChangingTopologySelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/IgniteAtomicLongChangingTopologySelfTest.java @@ -31,6 +31,7 @@ import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicReferenceArray; import org.apache.ignite.Ignite; import org.apache.ignite.IgniteAtomicLong; +import org.apache.ignite.IgniteClientDisconnectedException; import org.apache.ignite.IgniteQueue; import org.apache.ignite.IgniteSet; import org.apache.ignite.configuration.AtomicConfiguration; @@ -214,7 +215,12 @@ public class IgniteAtomicLongChangingTopologySelfTest extends GridCommonAbstract while (System.currentTimeMillis() < stop) { log.info("Iteration: " + iter++); - c.apply(ignite); + try { + c.apply(ignite); + } + catch (IgniteClientDisconnectedException e) { + e.reconnectFuture().get(); + } } finished.set(true);