Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * JBoss, Home of Professional Open Source.
   * Copyright 2013, 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.webservices.dmr;
 
 import static org.jboss.as.controller.descriptions.ModelDescriptionConstants.OP_ADDR;
 import static org.jboss.as.webservices.WSMessages.MESSAGES;
 import static org.jboss.as.webservices.dmr.Constants.CLASS;
 import static org.jboss.as.webservices.dmr.PackageUtils.getConfigServiceName;
 import static org.jboss.as.webservices.dmr.PackageUtils.getHandlerChainServiceName;
 import static org.jboss.as.webservices.dmr.PackageUtils.getHandlerServiceName;
 
 import java.util.List;
 

Author(s):
Alessio Soldano
Richard Opalka
 
 final class HandlerAdd extends AbstractAddStepHandler {
 
     static final HandlerAdd INSTANCE = new HandlerAdd();
     static final AtomicInteger counter = new AtomicInteger(0);
 
     private HandlerAdd() {
         // forbidden instantiation
     }
 
     @Override
     protected void rollbackRuntime(final OperationContext contextfinal ModelNode operationfinal ModelNode modelfinal List<ServiceController<?>> controllers) {
         super.rollbackRuntime(contextoperationmodelcontrollers);
         if (!context.isBooting()) {
             context.revertReloadRequired();
         }
     }
 
     @Override
     protected void performRuntime(final OperationContext contextfinal ModelNode operationfinal ModelNode modelfinal ServiceVerificationHandler verificationHandlerfinal List<ServiceController<?>> newControllersthrows OperationFailedException {
         // modify the runtime if we're booting, otherwise set reload required and leave the runtime unchanged
         if (context.isBooting()) {
             final PathAddress address = PathAddress.pathAddress(operation.require());
             final PathElement confElem = address.getElement(address.size() - 3);
             final String configType = confElem.getKey();
             final String configName = confElem.getValue();
             final String handlerChainType = address.getElement(address.size() - 2).getKey();
             final String handlerChainId = address.getElement(address.size() - 2).getValue();
             final String handlerName = address.getElement(address.size() - 1).getValue();
             final String handlerClass = operation.require().asString();
 
             final HandlerService service = new HandlerService(handlerNamehandlerClass.incrementAndGet());
             final ServiceTarget target = context.getServiceTarget();
             final ServiceName configServiceName = getConfigServiceName(configTypeconfigName);
             final ServiceRegistry registry = context.getServiceRegistry(false);
             if (registry.getService(configServiceName) == null) {
                 throw .missingConfig(configName);
             }
             final ServiceName handlerChainServiceName = getHandlerChainServiceName(configServiceNamehandlerChainTypehandlerChainId);
             if (registry.getService(handlerChainServiceName) == null) {
                 throw .missingHandlerChain(configNamehandlerChainTypehandlerChainId);
             }
             final ServiceName handlerServiceName = getHandlerServiceName(handlerChainServiceNamehandlerName);
 
             final ServiceBuilder<?> handlerServiceBuilder = target.addService(handlerServiceNameservice);
             ServiceController<?> controller = handlerServiceBuilder.setInitialMode(..).install();
             if (newControllers != null) {
                 newControllers.add(controller);
             }
        } else {
            context.reloadRequired();
        }
    }
    @Override
    protected void populateModel(final ModelNode operationfinal ModelNode modelthrows OperationFailedException {
        ..validateAndSet(operationmodel);
    }
New to GrepCode? Check out our FAQ X