[jbpm-commits] JBoss JBPM SVN: r1872 - jbpm4/pvm/trunk/modules/core/src/main/java/org/jbpm/pvm/internal/job.

[do-not-reply at jboss.org]

Author: porcherg
Date: 2008-08-12 07:36:35 -0400 (Tue, 12 Aug 2008)
New Revision: 1872

Modified:
   jbpm4/pvm/trunk/modules/core/src/main/java/org/jbpm/pvm/internal/job/CommandMessage.java
Log:
job is deleted after being executed

Modified: jbpm4/pvm/trunk/modules/core/src/main/java/org/jbpm/pvm/internal/job/CommandMessage.java
===================================================================
--- jbpm4/pvm/trunk/modules/core/src/main/java/org/jbpm/pvm/internal/job/CommandMessage.java	2008-08-12 11:06:47 UTC (rev 1871)
+++ jbpm4/pvm/trunk/modules/core/src/main/java/org/jbpm/pvm/internal/job/CommandMessage.java	2008-08-12 11:36:35 UTC (rev 1872)
@@ -23,6 +23,7 @@
 
 import org.jbpm.pvm.env.Environment;
 import org.jbpm.pvm.internal.cmd.Command;
+import org.jbpm.pvm.internal.jobexecutor.JobDbSession;
 import org.jbpm.pvm.internal.wire.Descriptor;
 import org.jbpm.pvm.internal.wire.WireContext;
 
@@ -44,6 +45,9 @@
   public Object execute(Environment environment) throws Exception {
     Command<Object> command = (Command<Object>) WireContext.create(commandDescriptor);
     command.execute(environment);
+    
+    JobDbSession jobDbSession = environment.get(JobDbSession.class);
+    jobDbSession.delete(this);
     return null;
   }