[jboss-svn-commits] JBL Code SVN: r34148 - in labs/jbossrules/branches/trunk_20100722_esteban_diega/drools-persistence-jpa/src: test/java/org/drools/persistence/processinstance/timer and 1 other directory.

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

Author: diegoll
Date: 2010-07-23 15:47:12 -0400 (Fri, 23 Jul 2010)
New Revision: 34148

Modified:
   labs/jbossrules/branches/trunk_20100722_esteban_diega/drools-persistence-jpa/src/main/java/org/drools/persistence/processinstance/timer/JPACheckerProcessTimerJobService.java
   labs/jbossrules/branches/trunk_20100722_esteban_diega/drools-persistence-jpa/src/test/java/org/drools/persistence/processinstance/timer/JPAPersistentTimerServiceTest.java
Log:
external timer trigger working

Modified: labs/jbossrules/branches/trunk_20100722_esteban_diega/drools-persistence-jpa/src/main/java/org/drools/persistence/processinstance/timer/JPACheckerProcessTimerJobService.java
===================================================================
--- labs/jbossrules/branches/trunk_20100722_esteban_diega/drools-persistence-jpa/src/main/java/org/drools/persistence/processinstance/timer/JPACheckerProcessTimerJobService.java	2010-07-23 19:01:45 UTC (rev 34147)
+++ labs/jbossrules/branches/trunk_20100722_esteban_diega/drools-persistence-jpa/src/main/java/org/drools/persistence/processinstance/timer/JPACheckerProcessTimerJobService.java	2010-07-23 19:47:12 UTC (rev 34148)
@@ -1,6 +1,7 @@
 package org.drools.persistence.processinstance.timer;
 
 import java.util.List;
+import java.util.concurrent.atomic.AtomicBoolean;
 
 import javax.persistence.EntityManager;
 import javax.persistence.EntityManagerFactory;
@@ -52,7 +53,7 @@
 	private EntityManagerFactory entityManagerFactory;
 	private KnowledgeBase kbase;
 	private int sessionId;
-	private boolean running = false;
+	private AtomicBoolean running = new AtomicBoolean(false);
 	private long poolingTime = DEFAULT_POOLING_TIME;
 	
 	public JPACheckerProcessTimerJobService(int sessionId, KnowledgeBase kbase) {
@@ -110,11 +111,11 @@
 	}
 
 	private boolean isRunning() {
-		return running;
+		return running.get();
 	}
 
 	private void setRunning(boolean running) {
-		this.running = running;
+		this.running.set(running);
 	}
 	
 	@SuppressWarnings("unchecked")

Modified: labs/jbossrules/branches/trunk_20100722_esteban_diega/drools-persistence-jpa/src/test/java/org/drools/persistence/processinstance/timer/JPAPersistentTimerServiceTest.java
===================================================================
--- labs/jbossrules/branches/trunk_20100722_esteban_diega/drools-persistence-jpa/src/test/java/org/drools/persistence/processinstance/timer/JPAPersistentTimerServiceTest.java	2010-07-23 19:01:45 UTC (rev 34147)
+++ labs/jbossrules/branches/trunk_20100722_esteban_diega/drools-persistence-jpa/src/test/java/org/drools/persistence/processinstance/timer/JPAPersistentTimerServiceTest.java	2010-07-23 19:47:12 UTC (rev 34148)
@@ -155,7 +155,9 @@
         env.set( EnvironmentName.ENTITY_MANAGER_FACTORY, emf );
         env.set( EnvironmentName.GLOBALS, new MapGlobalResolver() );
         env.set(EnvironmentName.PROCESS_TIMER_STRATEGY, new JPAProcessTimerPersistenceStrategy(emf));
+        env.set(EnvironmentName.TRANSACTION_MANAGER, TransactionManagerServices.getTransactionManager());
 
+
         StatefulKnowledgeSession ksession = JPAKnowledgeService.newStatefulKnowledgeSession( kbase, null, env );
         int id = ksession.getId();
         ksession.dispose();