Repository: incubator-ignite Updated Branches: refs/heads/ignite-gg-10272 [created] 787e756e5
# GG-10272: WIP. Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/787e756e Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/787e756e Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/787e756e Branch: refs/heads/ignite-gg-10272 Commit: 787e756e5ffbc3b0894a281d284e705fdba93740 Parents: 36805cc Author: vozerov-gridgain <voze...@gridgain.com> Authored: Mon May 18 16:02:11 2015 +0300 Committer: vozerov-gridgain <voze...@gridgain.com> Committed: Mon May 18 16:02:11 2015 +0300 ---------------------------------------------------------------------- .../ignite/internal/managers/communication/GridIoManager.java | 6 +++--- .../communication/GridLifecycleAwareMessageFilter.java | 5 ++++- 2 files changed, 7 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/787e756e/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 16d582b..c877d57 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 @@ -1697,10 +1697,10 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa this.predLsnr = predLsnr; if (predLsnr != null) { - ctx.resource().injectGeneric(predLsnr); - if (predLsnr instanceof GridLifecycleAwareMessageFilter) - ((GridLifecycleAwareMessageFilter)predLsnr).initialize(); + ((GridLifecycleAwareMessageFilter)predLsnr).initialize(ctx); + else + ctx.resource().injectGeneric(predLsnr); } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/787e756e/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridLifecycleAwareMessageFilter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridLifecycleAwareMessageFilter.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridLifecycleAwareMessageFilter.java index cb99d2e..f8cd78f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridLifecycleAwareMessageFilter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridLifecycleAwareMessageFilter.java @@ -17,6 +17,7 @@ package org.apache.ignite.internal.managers.communication; +import org.apache.ignite.internal.*; import org.apache.ignite.lang.*; /** @@ -25,8 +26,10 @@ import org.apache.ignite.lang.*; public interface GridLifecycleAwareMessageFilter<K, V> extends IgniteBiPredicate<K, V> { /** * Initializes the filter. + * + * @param ctx Kernal context. */ - public void initialize(); + public void initialize(GridKernalContext ctx); /** * Closes the filter.
