1 17 18 package org.apache.geronimo.timer.jdbc; 19 20 import java.sql.SQLException ; 21 import javax.sql.DataSource ; 22 import javax.transaction.TransactionManager ; 23 24 import edu.emory.mathcs.backport.java.util.concurrent.Executor; 25 26 import org.apache.geronimo.connector.outbound.ConnectionFactorySource; 27 import org.apache.geronimo.gbean.GBeanInfo; 28 import org.apache.geronimo.gbean.GBeanInfoBuilder; 29 import org.apache.geronimo.j2ee.j2eeobjectnames.NameFactory; 30 import org.apache.geronimo.kernel.Kernel; 31 import org.apache.geronimo.timer.NontransactionalExecutorTaskFactory; 32 import org.apache.geronimo.timer.PersistentTimer; 33 import org.apache.geronimo.timer.ThreadPooledTimer; 34 35 38 public class JDBCStoreThreadPooledNonTransactionalTimer extends ThreadPooledTimer { 39 40 public JDBCStoreThreadPooledNonTransactionalTimer(ConnectionFactorySource managedConnectionFactoryWrapper, 41 TransactionManager transactionManager, 42 Executor threadPool, 43 Kernel kernel) throws SQLException { 44 super(new NontransactionalExecutorTaskFactory(), 45 new JDBCWorkerPersistence(kernel.getKernelName(), (DataSource )managedConnectionFactoryWrapper.$getResource(), false), threadPool, transactionManager); 46 } 47 48 49 public static final GBeanInfo GBEAN_INFO; 50 51 static { 52 GBeanInfoBuilder infoFactory = GBeanInfoBuilder.createStatic(JDBCStoreThreadPooledNonTransactionalTimer.class); 53 infoFactory.addInterface(PersistentTimer.class); 54 55 infoFactory.addReference("ManagedConnectionFactoryWrapper", ConnectionFactorySource.class, NameFactory.JCA_MANAGED_CONNECTION_FACTORY); 56 infoFactory.addReference("ThreadPool", Executor.class, NameFactory.GERONIMO_SERVICE); 57 infoFactory.addReference("TransactionManager", TransactionManager .class, NameFactory.TRANSACTION_MANAGER); 58 59 infoFactory.addAttribute("kernel", Kernel.class, false); 60 61 infoFactory.setConstructor(new String []{"ManagedConnectionFactoryWrapper", "TransactionManager", "ThreadPool", "kernel"}); 62 GBEAN_INFO = infoFactory.getBeanInfo(); 63 } 64 65 public static GBeanInfo getGBeanInfo() { 66 return GBEAN_INFO; 67 } 68 } 69 | Popular Tags |