IGNITE-1359: Created logic for platform processor instantiation.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/ff6c2c83 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/ff6c2c83 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/ff6c2c83 Branch: refs/heads/ignite-1349 Commit: ff6c2c83f387ade46c712fa253771bcfbb8cd3b2 Parents: 9910b6f Author: vozerov-gridgain <[email protected]> Authored: Wed Sep 2 17:26:44 2015 +0300 Committer: vozerov-gridgain <[email protected]> Committed: Wed Sep 2 17:26:44 2015 +0300 ---------------------------------------------------------------------- .../java/org/apache/ignite/internal/IgniteKernal.java | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/ff6c2c83/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java index d9fef86..5ce646e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java @@ -3101,13 +3101,19 @@ public class IgniteKernal implements IgniteEx, IgniteMXBean, Externalizable { if (cls.equals(DiscoveryNodeValidationProcessor.class)) return (T)new OsDiscoveryNodeValidationProcessor(ctx); - if (cls.equals(PlatformProcessor.class)) - return (T)new PlatformNoopProcessor(ctx); - Class<T> implCls = null; try { - implCls = (Class<T>)Class.forName(componentClassName(cls)); + String clsName; + + // Handle special case for PlatformProcessor + if (cls.equals(PlatformProcessor.class)) + clsName = ctx.config().getPlatformConfiguration() == null ? + PlatformNoopProcessor.class.getName() : cls.getName() + "Impl"; + else + clsName = componentClassName(cls); + + implCls = (Class<T>)Class.forName(clsName); } catch (ClassNotFoundException ignore) { // No-op.
