diff --git a/source/java/org/alfresco/repo/replication/ReplicationServiceIntegrationTest.java b/source/java/org/alfresco/repo/replication/ReplicationServiceIntegrationTest.java
index 7dd7cb7716..58b0cda889 100644
--- a/source/java/org/alfresco/repo/replication/ReplicationServiceIntegrationTest.java
+++ b/source/java/org/alfresco/repo/replication/ReplicationServiceIntegrationTest.java
@@ -133,7 +133,7 @@ public class ReplicationServiceIntegrationTest extends TestCase
     {
         if (AlfrescoTransactionSupport.getTransactionReadState() != TxnReadState.TXN_NONE)
         {
-            fail("Dangling transaction detected.");
+            fail("Dangling transaction detected, left by a previous test.");
         }
         
         replicationActionExecutor = (ReplicationActionExecutor) ctx.getBean("replicationActionExecutor");
@@ -239,6 +239,11 @@ public class ReplicationServiceIntegrationTest extends TestCase
         {
             // Ignore
         }
+        
+        if (AlfrescoTransactionSupport.getTransactionReadState() != TxnReadState.TXN_NONE)
+        {
+            fail("Dangling transaction detected, current test failed to tidy up.");
+        }
    }