diff --git a/source/java/org/alfresco/repo/cache/CacheTest.java b/source/java/org/alfresco/repo/cache/CacheTest.java
index 621dd0e64e..c129c0ad50 100644
--- a/source/java/org/alfresco/repo/cache/CacheTest.java
+++ b/source/java/org/alfresco/repo/cache/CacheTest.java
@@ -774,6 +774,33 @@ public class CacheTest extends TestCase
         executeAndCheck(callback, false, COMMON_KEY, null);
         executeAndCheck(callback, true, COMMON_KEY, null);
     }
+    /**
+     * <ul>
+     *   <li>Remove from the backing cache</li>
+     *   <li>Add to the transactional cache</li>
+     *   <li>Add to the backing cache</li>
+     *   <li>Commit</li>
+     * </ul>
+     */
+    public void testConcurrentAddAgainstAdd_NoPreExisting()throws Throwable
+    {
+        RetryingTransactionCallback<Object> callback = new RetryingTransactionCallback<Object>()
+        {
+            public Object execute() throws Throwable
+            {
+                backingCache.remove(COMMON_KEY);
+                transactionalCache.put(COMMON_KEY, "aaa2-x");
+                backingCache.put(COMMON_KEY, "aaa2");
+                return null;
+            }
+        };
+        transactionalCache.setMutable(true);
+        executeAndCheck(callback, false, COMMON_KEY, null);
+        executeAndCheck(callback, true, COMMON_KEY, "aaa2");    // Doesn't write through
+        transactionalCache.setMutable(false);
+        executeAndCheck(callback, false, COMMON_KEY, "aaa2-x"); // Always overwrites
+        executeAndCheck(callback, true, COMMON_KEY, "aaa2-x");  // Always overwrites
+    }
     /**
      * <ul>
      *   <li>Add to the backing cache</li>
diff --git a/source/java/org/alfresco/repo/cache/TransactionalCache.java b/source/java/org/alfresco/repo/cache/TransactionalCache.java
index 50834f1c03..458f9cfba9 100644
--- a/source/java/org/alfresco/repo/cache/TransactionalCache.java
+++ b/source/java/org/alfresco/repo/cache/TransactionalCache.java
@@ -838,12 +838,9 @@ public class TransactionalCache<K extends Serializable, V extends Object>
             Object sharedObj = sharedCache.get(key);
             if (!mutable)
             {
-                // Value can't change
-                if (sharedObj == null)
-                {
-                    // Still nothing in the cache
-                    sharedCache.put(key, value);
-                }
+                // The value can't change so we can write through on the assumption
+                // that the value is always correct
+                sharedCache.put(key, value);
             }
             else if (readOnly)
             {