diff --git a/source/java/org/alfresco/repo/forms/processor/node/MockClassAttributeDefinition.java b/source/java/org/alfresco/repo/forms/processor/node/MockClassAttributeDefinition.java
index f4e3200217..440d07a407 100644
--- a/source/java/org/alfresco/repo/forms/processor/node/MockClassAttributeDefinition.java
+++ b/source/java/org/alfresco/repo/forms/processor/node/MockClassAttributeDefinition.java
@@ -72,14 +72,19 @@ public class MockClassAttributeDefinition implements PropertyDefinition, Associa
     public static MockClassAttributeDefinition mockPropertyDefinition(QName name, QName dataTypeName)
     {
         MockClassAttributeDefinition mock = new MockClassAttributeDefinition(name);
-        mockDataTypeName(dataTypeName, mock);
+        mockDataTypeName(mock, dataTypeName, null);
         return mock;
     }
     
     public static MockClassAttributeDefinition mockPropertyDefinition(QName name, QName dataTypeName, String defaultValue)
+    {
+        return mockPropertyDefinition(name, dataTypeName, null, defaultValue);
+    }
+    
+    public static MockClassAttributeDefinition mockPropertyDefinition(QName name, QName dataTypeName, Class<?> typeClass, String defaultValue)
     {
         MockClassAttributeDefinition mock = new MockClassAttributeDefinition(name);
-        mockDataTypeName(dataTypeName, mock);
+        mockDataTypeName(mock, dataTypeName, typeClass);
         mock.defaultValue = defaultValue;
         return mock;
     }
@@ -94,7 +99,7 @@ public class MockClassAttributeDefinition implements PropertyDefinition, Associa
                 boolean multiValued)
     {
         MockClassAttributeDefinition mock = new MockClassAttributeDefinition(name, title, description, isProtected);
-        mockDataTypeName(dataTypeName, mock);
+        mockDataTypeName(mock, dataTypeName, null);
         mock.defaultValue = defaultValue;
         mock.mandatory = Mandatory;
         mock.multiValued = multiValued;
@@ -123,9 +128,13 @@ public class MockClassAttributeDefinition implements PropertyDefinition, Associa
         return mock;
     }
 
-    private static void mockDataTypeName(QName dataTypeName, MockClassAttributeDefinition mock)
+    private static void mockDataTypeName(MockClassAttributeDefinition mock, QName dataTypeName, Class<?> javaClass)
     {
         when(mock.dataType.getName()).thenReturn(dataTypeName);
+        if (javaClass!=null)
+        {
+            when(mock.dataType.getJavaClassName()).thenReturn(javaClass.getName());
+        }
     }
 
     private static void mockTargetClassName(QName targetClassName, MockClassAttributeDefinition mock)
diff --git a/source/java/org/alfresco/repo/forms/processor/node/PropertyFieldProcessor.java b/source/java/org/alfresco/repo/forms/processor/node/PropertyFieldProcessor.java
index 80098f7ba1..96825793ff 100644
--- a/source/java/org/alfresco/repo/forms/processor/node/PropertyFieldProcessor.java
+++ b/source/java/org/alfresco/repo/forms/processor/node/PropertyFieldProcessor.java
@@ -90,6 +90,9 @@ public class PropertyFieldProcessor extends QNameFieldProcessor<PropertyDefiniti
         return propDef;
     }
 
+    /**
+    * {@inheritDoc}
+     */
     @Override
     public Field makeField(PropertyDefinition propDef, Object value, FieldGroup group)
     {
diff --git a/source/java/org/alfresco/repo/forms/processor/workflow/TaskFormProcessorTest.java b/source/java/org/alfresco/repo/forms/processor/workflow/TaskFormProcessorTest.java
index 6c1e1f970d..3565c65b15 100644
--- a/source/java/org/alfresco/repo/forms/processor/workflow/TaskFormProcessorTest.java
+++ b/source/java/org/alfresco/repo/forms/processor/workflow/TaskFormProcessorTest.java
@@ -319,6 +319,16 @@ public class TaskFormProcessorTest extends TestCase
         assertEquals(value, actualProperties.get(DESC_NAME));
     }
 
+    public void testPersistConvertsPropertyValueToCorrectType()
+    {
+        String fieldName = PROP_PRIORITY.toPrefixString(namespaceService);
+        String dataKey = makeDataKeyName(fieldName);
+        String value = "2"; // String value for property of type Integer!
+
+        processPersist(dataKey, value);
+        assertEquals(2, actualProperties.get(PROP_PRIORITY));
+    }
+    
     public void testPersistPropertyWith_() throws Exception
     {
         String fieldName = PROP_WITH_.toPrefixString(namespaceService);
@@ -671,6 +681,13 @@ public class TaskFormProcessorTest extends TestCase
         PropertyDefinition pckgItemAction = MockClassAttributeDefinition.mockPropertyDefinition(pckgItemActionGroup,
                     textType, "read_package_item_actions");
         properties.put(pckgItemActionGroup, pckgItemAction);
+        
+        
+        // Add a priority property
+        QName priorityName = PROP_PRIORITY;
+        PropertyDefinition priorityDef = 
+            MockClassAttributeDefinition.mockPropertyDefinition(priorityName, DataTypeDefinition.INT, Integer.class, "0");
+        properties.put(priorityName, priorityDef);
 
         return properties;
     }
diff --git a/source/java/org/alfresco/repo/forms/processor/workflow/TypedPropertyValueGetter.java b/source/java/org/alfresco/repo/forms/processor/workflow/TypedPropertyValueGetter.java
index 0f8eb1400f..ac31a647b4 100644
--- a/source/java/org/alfresco/repo/forms/processor/workflow/TypedPropertyValueGetter.java
+++ b/source/java/org/alfresco/repo/forms/processor/workflow/TypedPropertyValueGetter.java
@@ -27,6 +27,7 @@ import java.util.List;
 import org.alfresco.repo.forms.FormException;
 import org.alfresco.service.cmr.dictionary.DataTypeDefinition;
 import org.alfresco.service.cmr.dictionary.PropertyDefinition;
+import org.alfresco.service.cmr.repository.datatype.DefaultTypeConverter;
 import org.json.JSONArray;
 import org.json.JSONException;
 import org.springframework.extensions.surf.util.I18NUtil;
@@ -48,19 +49,20 @@ public class TypedPropertyValueGetter
             return null;
         }
 
-        Serializable typedValue = null;
         // before persisting check data type of property
         if (propDef.isMultiValued()) 
         {
-            typedValue = processMultiValuedType(value);
+            return processMultiValuedType(value);
         }
-        else if (isBooleanProperty(propDef)) 
+        
+        
+        if (isBooleanProperty(propDef)) 
         {
-            typedValue = processBooleanValue(value);
+            return processBooleanValue(value);
         }
         else if (isLocaleProperty(propDef)) 
         {
-            typedValue = processLocaleValue(value);
+            return processLocaleValue(value);
         }
         else if (value instanceof String)
         {
@@ -68,24 +70,23 @@ public class TypedPropertyValueGetter
 
             // make sure empty strings stay as empty strings, everything else
             // should be represented as null
-            if (valStr.length() == 0 && !isTextProperty(propDef))
+            if (isTextProperty(propDef))
             {
-                // Do nothing, leave typedValue as null.
+                return valStr;
             }
-            else
+            if(valStr.isEmpty())
             {
-                typedValue = valStr;
+                return null;
             }
         }
-        else if (value instanceof Serializable)
+        if (value instanceof Serializable)
         {
-            typedValue = (Serializable) value;
+            return (Serializable) DefaultTypeConverter.INSTANCE.convert(propDef.getDataType(), value);
         }
         else
         {
             throw new FormException("Property values must be of a Serializable type! Value type: " + value.getClass());
         }
-        return typedValue;
     }
 
     private boolean isTextProperty(PropertyDefinition propDef)