IronJacamarActivationResourceService.java

/*
 * JBoss, Home of Professional Open Source.
 * Copyright 2011, Red Hat, Inc., and individual contributors
 * as indicated by the @author tags. See the copyright.txt file in the
 * distribution for a full listing of individual contributors.
 *
 * This is free software; you can redistribute it and/or modify it
 * under the terms of the GNU Lesser General Public License as
 * published by the Free Software Foundation; either version 2.1 of
 * the License, or (at your option) any later version.
 *
 * This software is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this software; if not, write to the Free
 * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
 * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
 */

package org.jboss.as.connector.services.resourceadapters;

import static org.jboss.as.connector.logging.ConnectorLogger.ROOT_LOGGER;

import java.util.Collections;
import java.util.List;
import java.util.Locale;
import java.util.Map;

import org.jboss.as.connector.dynamicresource.ClearStatisticsHandler;
import org.jboss.as.connector.dynamicresource.StatisticsResourceDefinition;
import org.jboss.as.connector.metadata.deployment.ResourceAdapterDeployment;
import org.jboss.as.connector.services.mdr.AS7MetadataRepository;
import org.jboss.as.connector.subsystems.common.pool.PoolMetrics;
import org.jboss.as.connector.subsystems.resourceadapters.CommonAttributes;
import org.jboss.as.connector.subsystems.resourceadapters.Constants;
import org.jboss.as.connector.subsystems.resourceadapters.IronJacamarResource;
import org.jboss.as.connector.subsystems.resourceadapters.IronJacamarResourceCreator;
import org.jboss.as.connector.subsystems.resourceadapters.ResourceAdaptersExtension;
import org.jboss.as.controller.AttributeDefinition;
import org.jboss.as.controller.PathAddress;
import org.jboss.as.controller.PathElement;
import org.jboss.as.controller.ResourceBuilder;
import org.jboss.as.controller.descriptions.ModelDescriptionConstants;
import org.jboss.as.controller.descriptions.OverrideDescriptionProvider;
import org.jboss.as.controller.descriptions.StandardResourceDescriptionResolver;
import org.jboss.as.controller.registry.ManagementResourceRegistration;
import org.jboss.as.controller.registry.Resource;
import org.jboss.dmr.ModelNode;
import org.jboss.jca.core.api.management.AdminObject;
import org.jboss.jca.core.api.management.ConnectionFactory;
import org.jboss.jca.core.api.management.Connector;
import org.jboss.jca.core.api.management.ManagedConnectionFactory;
import org.jboss.jca.core.connectionmanager.ConnectionManager;
import org.jboss.jca.core.spi.statistics.StatisticsPlugin;
import org.jboss.jca.deployers.common.CommonDeployment;
import org.jboss.msc.inject.Injector;
import org.jboss.msc.service.Service;
import org.jboss.msc.service.StartContext;
import org.jboss.msc.service.StartException;
import org.jboss.msc.service.StopContext;
import org.jboss.msc.value.InjectedValue;

/**
 * Registers the {@link ManagementResourceRegistration} and {@link Resource} for displaying various
 * statistics reported by a {@link ResourceAdapterDeployment}. The available statistics depend on
 * the deployment implementation, so they cannot be known/registered before the deployment is processed.
 */
public final class IronJacamarActivationResourceService implements Service<ManagementResourceRegistration> {

    private static PathElement SUBSYSTEM_PATH_ELEMENT = PathElement.pathElement(ModelDescriptionConstants.SUBSYSTEM, ResourceAdaptersExtension.SUBSYSTEM_NAME);
    private static PathAddress RA_ADDRESS = PathAddress.pathAddress(SUBSYSTEM_PATH_ELEMENT,
            PathElement.pathElement(Constants.IRONJACAMAR_NAME, Constants.IRONJACAMAR_NAME),
            PathElement.pathElement(Constants.RESOURCEADAPTER_NAME));

    private final ManagementResourceRegistration registration;
    private final Resource deploymentResource;
    private final boolean statsEnabled;

    private final InjectedValue<ResourceAdapterDeployment> deployment = new InjectedValue<>();

    private final InjectedValue<AS7MetadataRepository> mdr = new InjectedValue<>();

    /**
     * create an instance *
     */
    public IronJacamarActivationResourceService(final ManagementResourceRegistration registration, final Resource deploymentResource,
                                                final boolean statsEnabled) {
        this.registration = registration;
        this.deploymentResource = deploymentResource;
        this.statsEnabled = statsEnabled;
    }


    @Override
    public void start(StartContext context) throws StartException {
        final CommonDeployment deploymentMD = deployment.getValue().getDeployment();
        final String deploymentName = deploymentMD.getDeploymentName();
        ROOT_LOGGER.debugf("Starting IronJacamarActivationResourceService %s", deploymentName);

        try {
            Connector connector = deploymentMD.getConnector();
            if (connector != null && connector.getResourceAdapter() != null) {

                final OverrideDescriptionProvider OD_PROVIDER = new OverrideDescriptionProvider() {
                    @Override
                    public Map<String, ModelNode> getAttributeOverrideDescriptions(Locale locale) {
                        return Collections.emptyMap();
                    }

                    @Override
                    public Map<String, ModelNode> getChildTypeOverrideDescriptions(Locale locale) {
                        return Collections.emptyMap();
                    }

                };

                final PathElement EXTENDED_STATS = PathElement.pathElement(Constants.STATISTICS_NAME, "extended");
                final PathAddress EXTENDED_STATS_ADDR = PathAddress.pathAddress(EXTENDED_STATS);
                final PathAddress CON_DEF_ADDR = PathAddress.EMPTY_ADDRESS.append(Constants.CONNECTIONDEFINITIONS_NAME);

                ManagementResourceRegistration raRegistration =
                        registration.getSubModel(RA_ADDRESS).registerOverrideModel(deploymentName, OD_PROVIDER);

                ResourceBuilder resourceBuilder = ResourceBuilder.Factory.create(EXTENDED_STATS,
                        new StandardResourceDescriptionResolver(Constants.STATISTICS_NAME + "." + Constants.WORKMANAGER_NAME, CommonAttributes.RESOURCE_NAME, CommonAttributes.class.getClassLoader()));

                ManagementResourceRegistration raStatsSubRegistration = raRegistration.registerSubModel(resourceBuilder.build());


                StatisticsPlugin raStats = connector.getResourceAdapter().getStatistics();
                if (raStats != null) {
                    raStats.setEnabled(statsEnabled);
                    PoolMetrics.ParametrizedPoolMetricsHandler handler = new PoolMetrics.ParametrizedPoolMetricsHandler(raStats);
                    for (AttributeDefinition attribute : StatisticsResourceDefinition.getAttributesFromPlugin(raStats)) {
                        raStatsSubRegistration.registerMetric(attribute, handler);
                    }
                    raStatsSubRegistration.registerOperationHandler(ClearStatisticsHandler.DEFINITION, new ClearStatisticsHandler(raStats));
                }

                List<ConnectionFactory> connectionFactories = connector.getConnectionFactories();
                if (connectionFactories != null) {
                    for (ConnectionFactory cf : connectionFactories) {
                        ManagedConnectionFactory mcf = cf.getManagedConnectionFactory();
                        StatisticsPlugin extendStats = mcf == null ? null : mcf.getStatistics();
                        if (extendStats != null) {
                            extendStats.setEnabled(statsEnabled);
                            if (extendStats.getNames().size() != 0) {

                                ManagementResourceRegistration cdRegistration = raRegistration.getSubModel(CON_DEF_ADDR);
                                ManagementResourceRegistration overrideCdRegistration =
                                        cdRegistration.registerOverrideModel(cf.getJndiName(), OD_PROVIDER);
                                if (overrideCdRegistration.getSubModel(EXTENDED_STATS_ADDR) == null) {
                                    overrideCdRegistration.registerSubModel(new StatisticsResourceDefinition(EXTENDED_STATS, CommonAttributes.RESOURCE_NAME, extendStats));
                                }
                            }
                        }
                    }
                }

                ConnectionManager[] connectionManagers = deploymentMD.getConnectionManagers();
                if (connectionManagers != null) {
                    PathElement POOL_STATS = PathElement.pathElement(Constants.STATISTICS_NAME, "pool");
                    PathAddress POOL_STATS_ADDR = PathAddress.pathAddress(POOL_STATS);
                    for (ConnectionManager cm : connectionManagers) {
                        if (cm.getPool() != null) {
                            StatisticsPlugin poolStats = cm.getPool().getStatistics();
                            poolStats.setEnabled(statsEnabled);

                            if (poolStats.getNames().size() != 0) {
                                ManagementResourceRegistration cdRegistration = raRegistration.getSubModel(CON_DEF_ADDR);
                                ManagementResourceRegistration overrideCdRegistration =
                                        cdRegistration.registerOverrideModel(cm.getJndiName(), OD_PROVIDER);
                                if (overrideCdRegistration.getSubModel(POOL_STATS_ADDR) == null) {
                                    overrideCdRegistration.registerSubModel(new StatisticsResourceDefinition(POOL_STATS, CommonAttributes.RESOURCE_NAME, poolStats));
                                }
                            }
                        }
                    }
                }

                List<AdminObject> adminObjects = connector.getAdminObjects();
                if (adminObjects != null) {
                    PathAddress AO_ADDR = PathAddress.EMPTY_ADDRESS.append(Constants.ADMIN_OBJECTS_NAME);
                    for (AdminObject ao : adminObjects) {
                        StatisticsPlugin extendStats = ao.getStatistics();
                        if (extendStats != null) {
                            extendStats.setEnabled(statsEnabled);
                            if (extendStats.getNames().size() != 0) {

                                ManagementResourceRegistration cdRegistration = raRegistration.getSubModel(AO_ADDR);
                                ManagementResourceRegistration overrideCdRegistration =
                                        cdRegistration.registerOverrideModel(ao.getJndiName(), OD_PROVIDER);
                                if (overrideCdRegistration.getSubModel(EXTENDED_STATS_ADDR) == null) {
                                    overrideCdRegistration.registerSubModel(new StatisticsResourceDefinition(EXTENDED_STATS, CommonAttributes.RESOURCE_NAME, extendStats));
                                }
                            }
                        }
                    }
                }

            }
        } catch (IllegalArgumentException e) {
            //ignore it, already restered
        }
        Resource subsystemResource;

        if (!deploymentResource.hasChild(SUBSYSTEM_PATH_ELEMENT)) {
            subsystemResource = new IronJacamarResource.IronJacamarRuntimeResource();
            deploymentResource.registerChild(SUBSYSTEM_PATH_ELEMENT, subsystemResource);
        } else {
            subsystemResource = deploymentResource.getChild(SUBSYSTEM_PATH_ELEMENT);
        }

        IronJacamarResourceCreator.INSTANCE.execute(subsystemResource, mdr.getValue(), deployment.getValue().getRaName());

    }

    @Override
    public void stop(StopContext context) {

        final CommonDeployment deploymentMD = deployment.getValue().getDeployment();
        final String deploymentName = deploymentMD.getDeploymentName();

        ROOT_LOGGER.debugf("Stopping IronJacamarActivationResourceService %s", deploymentName);

        Connector connector = deploymentMD.getConnector();
        if (connector != null && connector.getResourceAdapter() != null) {

            // We may have registered override resource registrations so we need to remove those
            ManagementResourceRegistration raReg = registration.getSubModel(RA_ADDRESS.getParent().append(Constants.RESOURCEADAPTER_NAME, deploymentName));
            ManagementResourceRegistration cdefReg = raReg.getSubModel(PathAddress.pathAddress(PathElement.pathElement(Constants.CONNECTIONDEFINITIONS_NAME)));

            List<ConnectionFactory> connectionFactories = connector.getConnectionFactories();
            if (connectionFactories != null) { // code reads that it won't be null but it's not documented, so...
                for (ConnectionFactory cf : connectionFactories) {
                    // We might not have registered an override for this one but it's no harm to remove
                    // and simpler to just do it vs analyzing to see if we did
                    cdefReg.unregisterOverrideModel(cf.getJndiName());
                }
            }

            ConnectionManager[] connectionManagers = deploymentMD.getConnectionManagers();
            if (connectionManagers != null) {
                for (ConnectionManager cm : connectionManagers) {
                    // We might not have registered an override for this one but it's no harm to remove
                    // and simpler to just do it vs analyzing to see if we did
                    cdefReg.unregisterOverrideModel(cm.getJndiName());
                }
            }

            List<AdminObject> adminObjects = connector.getAdminObjects();
            if (adminObjects != null) { // code reads that it won't be null but it's not documented, so...
                ManagementResourceRegistration aoReg = raReg.getSubModel(PathAddress.pathAddress(PathElement.pathElement(Constants.ADMIN_OBJECTS_NAME)));
                for (AdminObject ao : adminObjects) {
                    // We might not have registered an override for this one but it's no harm to remove
                    // and simpler to just do it vs analyzing to see if we did
                    aoReg.unregisterOverrideModel(ao.getJndiName());
                }
            }

            ManagementResourceRegistration raBaseReg = registration.getSubModel(RA_ADDRESS);
            raBaseReg.unregisterOverrideModel(deploymentName);
        }

        deploymentResource.removeChild(SUBSYSTEM_PATH_ELEMENT);
    }


    @Override
    public ManagementResourceRegistration getValue() throws IllegalStateException, IllegalArgumentException {
        return registration;
    }

    public Injector<AS7MetadataRepository> getMdrInjector() {
        return mdr;
    }

    public Injector<ResourceAdapterDeployment> getResourceAdapterDeploymentInjector() {
        return deployment;
    }

}