[jbpm-commits] JBoss JBPM SVN: r3920 - jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/type/variable.

[do-not-reply at jboss.org]

Author: tom.baeyens at jboss.com
Date: 2009-02-18 07:29:48 -0500 (Wed, 18 Feb 2009)
New Revision: 3920

Modified:
   jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/type/variable/BlobVariable.java
Log:
JBPM-1972 added cleanup of the old lob during blob variable updates

Modified: jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/type/variable/BlobVariable.java
===================================================================
--- jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/type/variable/BlobVariable.java	2009-02-18 12:07:12 UTC (rev 3919)
+++ jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/type/variable/BlobVariable.java	2009-02-18 12:29:48 UTC (rev 3920)
@@ -21,8 +21,10 @@
  */
 package org.jbpm.pvm.internal.type.variable;
 
+import org.jbpm.env.Environment;
 import org.jbpm.pvm.internal.lob.Lob;
 import org.jbpm.pvm.internal.type.Variable;
+import org.jbpm.session.DbSession;
 
 public class BlobVariable extends Variable {
 
@@ -41,6 +43,12 @@
   }
 
   public void setObject(Object value) {
+    if (this.lob!=null) {
+      DbSession dbSession = Environment.getFromCurrent(DbSession.class, false);
+      if (dbSession!=null) {
+        dbSession.delete(this.lob);
+      }
+    }
     this.lob = new Lob((byte[])value);
   }