Short pause to help ensure connection.close comes after last message ack, added to PropertyValueTest

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@518667 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 5 insertions, 3 deletions

diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/server/store/TestReferenceCounting.java b/qpid/java/systests/src/main/java/org/apache/qpid/server/store/TestReferenceCounting.java
index 2f0eaac29a..ab6d9742e4 100644
--- a/qpid/java/systests/src/main/java/org/apache/qpid/server/store/TestReferenceCounting.java
+++ b/qpid/java/systests/src/main/java/org/apache/qpid/server/store/TestReferenceCounting.java
@@ -80,7 +80,8 @@ public class TestReferenceCounting extends TestCase
         AMQMessage message = new AMQMessage(_store.getNewMessageId(), info,
                                             new NonTransactionalContext(_store, _storeContext, null, null, null),
                                             createPersistentContentHeader());
-        message.incrementReference();
+        message = message.takeReference();
+
         // we call routing complete to set up the handle
         message.routingComplete(_store, _storeContext, new MessageHandleFactory());
         assertTrue(_store.getMessageMetaDataMap().size() == 1);
@@ -128,11 +129,12 @@ public class TestReferenceCounting extends TestCase
                                             info,
                                             new NonTransactionalContext(_store, _storeContext, null, null, null),
                                             createPersistentContentHeader());
-        message.incrementReference();
+        
+        message = message.takeReference();
         // we call routing complete to set up the handle
         message.routingComplete(_store, _storeContext, new MessageHandleFactory());
         assertTrue(_store.getMessageMetaDataMap().size() == 1);
-        message.incrementReference();
+        message = message.takeReference();
         message.decrementReference(_storeContext);
         assertTrue(_store.getMessageMetaDataMap().size() == 1);
     }