# 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 <[email protected]> Authored: Fri Apr 17 15:17:36 2015 +0300 Committer: sevdokimov <[email protected]> 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()
