Skip to content

Commit

Permalink
# gg-9792 - Minor
Browse files Browse the repository at this point in the history
  • Loading branch information
Valentin Kulichenko committed Feb 18, 2015
1 parent 3114cda commit 3c884b5
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
Expand Up @@ -51,7 +51,7 @@ public class IgnitePluginProcessor extends GridProcessorAdapter {
public IgnitePluginProcessor(GridKernalContext ctx, IgniteConfiguration cfg) { public IgnitePluginProcessor(GridKernalContext ctx, IgniteConfiguration cfg) {
super(ctx); super(ctx);


ExtensionRegistry registry = new ExtensionRegistry(); ExtensionRegistryImpl registry = new ExtensionRegistryImpl();


if (cfg.getPluginConfigurations() != null) { if (cfg.getPluginConfigurations() != null) {
for (PluginConfiguration pluginCfg : cfg.getPluginConfigurations()) { for (PluginConfiguration pluginCfg : cfg.getPluginConfigurations()) {
Expand Down Expand Up @@ -109,7 +109,7 @@ public IgnitePluginProcessor(GridKernalContext ctx, IgniteConfiguration cfg) {
* @param extensionItf Extension interface class. * @param extensionItf Extension interface class.
* @return Returns implementation for provided extension from all plugins. * @return Returns implementation for provided extension from all plugins.
*/ */
public <T> T[] extensions(Class<T> extensionItf) { @Nullable public <T extends Extension> T[] extensions(Class<T> extensionItf) {
Map<Class<?>, Object[]> extensions = this.extensions; Map<Class<?>, Object[]> extensions = this.extensions;


return (T[])extensions.get(extensionItf); return (T[])extensions.get(extensionItf);
Expand Down Expand Up @@ -200,12 +200,12 @@ public <T> T createComponent(Class<T> cls) {
/** /**
* *
*/ */
private static class ExtensionRegistry implements org.apache.ignite.plugin.ExtensionRegistry { private static class ExtensionRegistryImpl implements ExtensionRegistry {
/** */ /** */
private final Map<Class<?>, List<Object>> extensionsCollector = new HashMap<>(); private final Map<Class<?>, List<Object>> extensionsCollector = new HashMap<>();


/** {@inheritDoc} */ /** {@inheritDoc} */
@Override public <T> void registerExtension(Class<T> extensionItf, T extensionImpl) { @Override public <T extends Extension> void registerExtension(Class<T> extensionItf, T extensionImpl) {
List<Object> list = extensionsCollector.get(extensionItf); List<Object> list = extensionsCollector.get(extensionItf);


if (list == null) { if (list == null) {
Expand Down
Expand Up @@ -28,5 +28,5 @@ public interface ExtensionRegistry {
* @param extensionImpl Extension implementation. * @param extensionImpl Extension implementation.
* @param <T> Extension type. * @param <T> Extension type.
*/ */
public <T> void registerExtension(Class<T> extensionItf, T extensionImpl); public <T extends Extension> void registerExtension(Class<T> extensionItf, T extensionImpl);
} }

0 comments on commit 3c884b5

Please sign in to comment.