You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2017/04/24 09:11:46 UTC
[20/26] ignite git commit: Fixed
CacheExchangeMessageDuplicatedStateTest.
Fixed CacheExchangeMessageDuplicatedStateTest.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/a4e8296f
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/a4e8296f
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/a4e8296f
Branch: refs/heads/ignite-1794
Commit: a4e8296f3ccc2fa532f7ac5f4ac28ed68b1ab3e5
Parents: a4d9148
Author: sboikov <sb...@gridgain.com>
Authored: Sat Apr 22 09:42:54 2017 +0300
Committer: sboikov <sb...@gridgain.com>
Committed: Sat Apr 22 09:42:54 2017 +0300
----------------------------------------------------------------------
.../cache/CacheExchangeMessageDuplicatedStateTest.java | 8 +++-----
1 file changed, 3 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/a4e8296f/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheExchangeMessageDuplicatedStateTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheExchangeMessageDuplicatedStateTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheExchangeMessageDuplicatedStateTest.java
index 6c74dae..a4dd3fe 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheExchangeMessageDuplicatedStateTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheExchangeMessageDuplicatedStateTest.java
@@ -80,11 +80,9 @@ public class CacheExchangeMessageDuplicatedStateTest extends GridCommonAbstractT
commSpi.record(new IgniteBiPredicate<ClusterNode, Message>() {
@Override public boolean apply(ClusterNode node, Message msg) {
- Message msg0 = ((GridIoMessage) msg).message();
-
- return (msg0.getClass() == GridDhtPartitionsSingleMessage.class ||
- msg0.getClass() == GridDhtPartitionsFullMessage.class) &&
- ((GridDhtPartitionsAbstractMessage) msg0).exchangeId() != null;
+ return (msg.getClass() == GridDhtPartitionsSingleMessage.class ||
+ msg.getClass() == GridDhtPartitionsFullMessage.class) &&
+ ((GridDhtPartitionsAbstractMessage)msg).exchangeId() != null;
}
});