[Jboss-cvs] JBossAS SVN: r55353 - trunk/connector/src/main/org/jboss/resource/adapter/quartz/inflow

[jboss-cvs-commits at lists.jboss.org]

Author: alesj
Date: 2006-08-05 18:07:25 -0400 (Sat, 05 Aug 2006)
New Revision: 55353

Added:
   trunk/connector/src/main/org/jboss/resource/adapter/quartz/inflow/JBossQuartzThreadPool.java
Log:
Quartz's ThreadPoll using JCA's thread pool.

Added: trunk/connector/src/main/org/jboss/resource/adapter/quartz/inflow/JBossQuartzThreadPool.java
===================================================================
--- trunk/connector/src/main/org/jboss/resource/adapter/quartz/inflow/JBossQuartzThreadPool.java	2006-08-05 20:02:45 UTC (rev 55352)
+++ trunk/connector/src/main/org/jboss/resource/adapter/quartz/inflow/JBossQuartzThreadPool.java	2006-08-05 22:07:25 UTC (rev 55353)
@@ -0,0 +1,104 @@
+/*
+* JBoss, Home of Professional Open Source
+* Copyright 2005, JBoss Inc., and individual contributors as indicated
+* by the @authors tag. See the copyright.txt 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.resource.adapter.quartz.inflow;
+
+import org.jboss.mx.util.MBeanServerLocator;
+import org.jboss.util.threadpool.RunnableTaskWrapper;
+import org.jboss.util.threadpool.ThreadPool;
+import org.quartz.SchedulerConfigException;
+
+import javax.management.MBeanServer;
+import javax.management.ObjectName;
+
+/**
+ * Thread pool used to fire Quartz Jobs.
+ *
+ * By default it uses 'in house' thread pool - JCA's WorkerManagerThreadPool.
+ * You can create your own instance of JBoss's thread pool and instantiate it in
+ * jbossjca-service.xml or any other -service.xml deploy file.
+ * Simply link it with JMX object name - see property threadPoolObjectName.
+ *
+ * @see quartz.properties
+ * #org.quartz.threadPool.threadPoolObjectName=jboss.jca:service=MyThreadPool
+ *
+ * @author ales.justin at genera-lynx.com
+ */
+public class JBossQuartzThreadPool implements org.quartz.spi.ThreadPool
+{
+   private static final String WORK_MANAGER_THREAD_POOL = "jboss.jca:service=WorkManagerThreadPool";
+
+   private String threadPoolObjectName = WORK_MANAGER_THREAD_POOL;
+
+   private int poolSize;
+
+   private org.jboss.util.threadpool.ThreadPool threadPool;
+
+   public void initialize() throws SchedulerConfigException
+   {
+      try
+      {
+         MBeanServer server = MBeanServerLocator.locateJBoss();
+         ObjectName tpObjectName = new ObjectName(getThreadPoolObjectName());
+         threadPool = (ThreadPool) server.getAttribute(tpObjectName, "Instance");
+         poolSize = ((Integer) server.getAttribute(tpObjectName, "MaximumPoolSize")).intValue();
+      }
+      catch (Exception e)
+      {
+         throw new SchedulerConfigException("Unable to use jboss thread pool.", e);
+      }
+   }
+
+   public int getPoolSize()
+   {
+      return poolSize;
+   }
+
+   public boolean runInThread(Runnable runnable)
+   {
+      RunnableTaskWrapper runnableTaskWrapper = new RunnableTaskWrapper(runnable, 0, 0);
+      threadPool.run(runnableTaskWrapper);
+      return runnableTaskWrapper.isComplete();
+   }
+
+   /**
+    * JBoss Thread Pool is stopped by ServiceController.
+    * By default it waits for threads (jobs) to finish.
+    *
+    * @see org.jboss.util.threadpool.BasicThreadPool#stop();
+    */
+   public void shutdown(boolean waitForJobsToComplete)
+   {
+   }
+
+   // -------- setters & getters
+
+   public String getThreadPoolObjectName()
+   {
+      return threadPoolObjectName;
+   }
+
+   public void setThreadPoolObjectName(String threadPoolObjectName)
+   {
+      this.threadPoolObjectName = threadPoolObjectName;
+   }
+
+}