Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * JBoss, Home of Professional Open Source
   * Copyright 2007, Red Hat Middleware LLC, and individual contributors
   * as indicated by the @author tags.
   * See the copyright.txt in the distribution for a
   * full listing of individual contributors.
   * This copyrighted material is made available to anyone wishing to use,
   * modify, copy, or redistribute it subject to the terms and conditions
   * of the GNU Lesser General Public License, v. 2.1.
  * This program is distributed in the hope that it will be useful, but WITHOUT A
  * 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,
  * v.2.1 along with this distribution; if not, write to the Free Software
  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
  * MA  02110-1301, USA.
  *
  * (C) 2007,
  * @author JBoss Inc.
  */
 package org.jboss.jbossts;
 
 
 import java.util.List;

$Id$
 
 public class XTSService implements XTSServiceMBean {
 
     // TODO expose as bean properties
     private int taskManagerMinWorkerCount = 0;
     private int taskManagerMaxWorkerCount = 10;
 
     public XTSService() {}
 
     public void start() throws Exception
     {
         ..info("JBossTS XTS Transaction Service - starting");
 
         //  execute startup for all registered initialisations
 
         XTSEnvironmentBean xtsEnvironmentBean = XTSPropertyManager.getXTSEnvironmentBean();
         Iterator<Stringiterator = xtsEnvironmentBean.getXtsInitialisations().iterator();
 
         while (iterator.hasNext()) {
             String className = iterator.next();
 
             Class<?> clazz = null;
 
             try {
                 clazz = CoordinatorRecoveryInitialisation.class.getClassLoader().loadClass(className);
             } catch (ClassNotFoundException cnfe) {
                 ..error_XTSService_1(classNamecnfe);
                 continue;
             }
 
             if (!XTSInitialisation.class.isAssignableFrom(clazz)) {
                 ..error_XTSService_2(className);
                 continue;
             }
 
             try {
                 XTSInitialisation initialisation = (XTSInitialisation)clazz.newInstance();
                 initialisation.startup();
                 .add(initialisation);
             } catch (InstantiationException ie) {
                 ..error_XTSService_3(classNameie);
             } catch (IllegalAccessException iae) {
                 ..error_XTSService_4(classNameiae);
             }
         }
 
         TaskManagerInitialisation();
     }
 
     public void stop() throws Exception
     {
         ..info("JBossTS XTS Transaction Service - stopping");
 
         TaskManager.getManager().shutdown() ; // com.arjuna.services.framework.admin.TaskManagerInitialisation
 
         // shutdown the activity service reaper
 
         ActivityReaper.shutdown();
 
         //  execute shutdown for all registered initialisations
 
         Iterator<XTSInitialisationiterator = .iterator();
 
        while (iterator.hasNext()) {
            XTSInitialisation xtsInitialisation = iterator.next();
            xtsInitialisation.shutdown();
        }
        .clear();
    }
    private void TaskManagerInitialisation()
    {
        final TaskManager taskManager = TaskManager.getManager() ;
        taskManager.setMinimumWorkerCount() ;
        taskManager.setMaximumWorkerCount() ;
    }
New to GrepCode? Check out our FAQ X