1 files changed, 2 insertions, 2 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/queue/MessageHandleFactory.java b/java/broker/src/main/java/org/apache/qpid/server/queue/MessageHandleFactory.java
index 94ab935115..0b214ca336 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/queue/MessageHandleFactory.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/MessageHandleFactory.java
@@ -36,11 +36,11 @@ public class MessageHandleFactory
         // just hardcoded for now
         if (persistent)
         {
-            return new WeakReferenceMessageHandle(store);
+            return new WeakReferenceMessageHandle(messageId, store);
         }
         else
         {
-            return new InMemoryMessageHandle();
+            return new InMemoryMessageHandle(messageId);
         }
     }
 }