Return-Path: 
 <commits-return-44608-apmail-ignite-commits-archive=ignite.apache.org@ignite.incubator.apache.org>
X-Original-To: apmail-ignite-commits-archive@minotaur.apache.org
Delivered-To: apmail-ignite-commits-archive@minotaur.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id B727317F92
	for <apmail-ignite-commits-archive@minotaur.apache.org>;
 Tue, 21 Apr 2015 15:41:17 +0000 (UTC)
Received: (qmail 77370 invoked by uid 500); 21 Apr 2015 15:41:11 -0000
Delivered-To: apmail-ignite-commits-archive@ignite.apache.org
Received: (qmail 77339 invoked by uid 500); 21 Apr 2015 15:41:11 -0000
Mailing-List: contact commits-help@ignite.incubator.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:commits-help@ignite.incubator.apache.org>
List-Unsubscribe: <mailto:commits-unsubscribe@ignite.incubator.apache.org>
List-Post: <mailto:commits@ignite.incubator.apache.org>
List-Id: <commits.ignite.incubator.apache.org>
Reply-To: dev@ignite.incubator.apache.org
Delivered-To: mailing list commits@ignite.incubator.apache.org
Received: (qmail 77330 invoked by uid 99); 21 Apr 2015 15:41:11 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 21 Apr 2015 15:41:11 +0000
X-ASF-Spam-Status: No, hits=-0.0 required=5.0
	tests=SPF_PASS
X-Spam-Check-By: apache.org
Received-SPF: pass (athena.apache.org: local policy)
Received: from [54.164.171.186] (HELO mx1-us-east.apache.org) (54.164.171.186)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 21 Apr 2015 15:41:06 +0000
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by mx1-us-east.apache.org (ASF Mail Server at mx1-us-east.apache.org) with
 SMTP id B3BC243E6D
	for <commits@ignite.incubator.apache.org>;
 Tue, 21 Apr 2015 15:40:45 +0000 (UTC)
Received: (qmail 74511 invoked by uid 99); 21 Apr 2015 15:40:43 -0000
Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org)
 (140.211.11.23)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 21 Apr 2015 15:40:43 +0000
Received: by git1-us-west.apache.org (ASF Mail Server at
 git1-us-west.apache.org, from userid 33)
	id 69BCEDFF85; Tue, 21 Apr 2015 15:40:43 +0000 (UTC)
Content-Type: text/plain; charset="us-ascii"
MIME-Version: 1.0
Content-Transfer-Encoding: 7bit
From: vozerov@apache.org
To: commits@ignite.incubator.apache.org
Message-Id: <f36bed92fa8348329802ac7eb44e4f5f@git.apache.org>
X-Mailer: ASF-Git Admin Mailer
Subject: incubator-ignite git commit: # GG-9613 review: initialize filter
 explicitly
Date: Tue, 21 Apr 2015 15:40:43 +0000 (UTC)
X-Virus-Checked: Checked by ClamAV on apache.org

Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-gg-9613 11a080882 -> 0af90c221


# GG-9613 review: initialize filter explicitly


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

Branch: refs/heads/ignite-gg-9613
Commit: 0af90c221cca88b95bd9e451bb6378def405fbe2
Parents: 11a0808
Author: ptupitsyn <ptupitsyn@gridgain.com>
Authored: Tue Apr 21 18:36:10 2015 +0300
Committer: ptupitsyn <ptupitsyn@gridgain.com>
Committed: Tue Apr 21 18:36:10 2015 +0300

----------------------------------------------------------------------
 .../managers/communication/GridCloseableMessageFilter.java     | 5 +++++
 .../ignite/internal/managers/communication/GridIoManager.java  | 6 +++++-
 2 files changed, 10 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/0af90c22/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridCloseableMessageFilter.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridCloseableMessageFilter.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridCloseableMessageFilter.java
index e3888ab..27f0494 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridCloseableMessageFilter.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridCloseableMessageFilter.java
@@ -27,4 +27,9 @@ public interface GridCloseableMessageFilter<K, V> extends IgniteBiPredicate<K, V
      * Callback invoked when predicate is no longer needed.
      */
     public void onClose();
+
+    /**
+     * Initializes this instance.
+     */
+    public void init();
 }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/0af90c22/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java
index a1a882a..34d12c0 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java
@@ -1670,8 +1670,12 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa
             this.topic = topic;
             this.predLsnr = predLsnr;
 
-            if (predLsnr != null)
+            if (predLsnr != null) {
                 ctx.resource().injectGeneric(predLsnr);
+
+                if (predLsnr instanceof GridCloseableMessageFilter)
+                    ((GridCloseableMessageFilter)predLsnr).init();
+            }
         }
 
         /** {@inheritDoc} */