ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sevdoki...@apache.org
Subject [3/4] incubator-ignite git commit: # IGNITE-499 Refactoring: use F.instanceOf(Class cld)
Date Fri, 17 Apr 2015 12:23:42 GMT
# IGNITE-499 Refactoring: use F.instanceOf(Class cld)


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/68d0ac06
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/68d0ac06
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/68d0ac06

Branch: refs/heads/ignite-499_1
Commit: 68d0ac06313e2c25a875f6965fb405f5cde93208
Parents: 22dcbb3
Author: sevdokimov <sevdokimov@gridgain.com>
Authored: Fri Apr 17 15:17:36 2015 +0300
Committer: sevdokimov <sevdokimov@gridgain.com>
Committed: Fri Apr 17 15:17:36 2015 +0300

----------------------------------------------------------------------
 .../ignite/spi/communication/tcp/TcpCommunicationSpi.java      | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/68d0ac06/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
index 98db27d..d438456 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
@@ -1023,11 +1023,7 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter
 
                 GridDirectParser parser = new GridDirectParser(msgFactory, msgFormatter);
 
-                IgnitePredicate<Message> skipRecoveryPred = new IgnitePredicate<Message>()
{
-                    @Override public boolean apply(Message msg) {
-                        return msg instanceof RecoveryLastReceivedMessage;
-                    }
-                };
+                IgnitePredicate<Message> skipRecoveryPred = F.instanceOf(RecoveryLastReceivedMessage.class);
 
                 GridNioServer<Message> srvr =
                     GridNioServer.<Message>builder()


Mime
View raw message