[jbpm-commits] JBoss JBPM SVN: r1872 - jbpm4/pvm/trunk/modules/core/src/main/java/org/jbpm/pvm/internal/job.
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;
}