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

[do-not-reply at jboss.org]

Author: koen.aers at jboss.com
Date: 2009-10-05 14:42:07 -0400 (Mon, 05 Oct 2009)
New Revision: 5699

Modified:
   jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/repository/ProcessDeployer.java
Log:
perform migration during deployment if migration info available

Modified: jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/repository/ProcessDeployer.java
===================================================================
--- jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/repository/ProcessDeployer.java	2009-10-05 18:41:14 UTC (rev 5698)
+++ jbpm4/trunk/modules/pvm/src/main/java/org/jbpm/pvm/internal/repository/ProcessDeployer.java	2009-10-05 18:42:07 UTC (rev 5699)
@@ -29,6 +29,8 @@
 import org.jbpm.api.ProcessDefinitionQuery;
 import org.jbpm.internal.log.Log;
 import org.jbpm.pvm.internal.env.EnvironmentImpl;
+import org.jbpm.pvm.internal.migration.InstanceMigrator;
+import org.jbpm.pvm.internal.migration.MigrationDescriptor;
 import org.jbpm.pvm.internal.model.ProcessDefinitionImpl;
 import org.jbpm.pvm.internal.session.RepositorySession;
 import org.jbpm.pvm.internal.xml.Parse;
@@ -84,7 +86,7 @@
                 processDefinition.setId(id);
                 processDefinition.setKey(key);
                 processDefinition.setVersion(version.intValue());
-
+            
               } else {
                 checkKey(processDefinition, deployment);
                 checkVersion(processDefinition, deployment);
@@ -95,6 +97,11 @@
                 deployment.setProcessDefinitionVersion(processDefinitionName, new Long(processDefinition.getVersion()));
               }
 
+              MigrationDescriptor migrationDescription = processDefinition.getMigrationDescriptor();
+              if (migrationDescription != null) {
+                InstanceMigrator.migrateAll(processDefinition, migrationDescription);
+              }
+
               deployment.addObject(processDefinitionName, processDefinition);
             }
           }