This closes #87 - a few test fixes

tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/cluster/distribution/ClusterTestBase.java

@@ -1201,16 +1201,16 @@ public abstract class ClusterTestBase extends ServiceTestBase
 
             ClientMessage message = holder.consumer.receive(WAIT_TIMEOUT);
 
-            message.acknowledge();
-
-            consumers[consumerIDs[count]].session.commit();
-
             Assert.assertNotNull("consumer " + consumerIDs[count] + " did not receive message " + i, message);
 
             Assert.assertEquals("consumer " + consumerIDs[count] + " message " + i,
                                 i,
                                 message.getObjectProperty(ClusterTestBase.COUNT_PROP));
 
+            message.acknowledge();
+
+            consumers[consumerIDs[count]].session.commit();
+
          }
 
          count++;

tests/integration-tests/src/test/java/org/apache/activemq/tests/integration/persistence/DuplicateCacheTest.java

@@ -71,9 +71,6 @@ public class DuplicateCacheTest extends StorageManagerTestBase
       cache.deleteFromCache(id);
 
       assertFalse(cache.contains(id));
-
-      cache.deleteFromCache(id);
-
    }