1 files changed, 4 insertions, 0 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SubscriptionImpl.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SubscriptionImpl.java
index e6e3a9cadb..230430ab12 100644
--- a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SubscriptionImpl.java
+++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SubscriptionImpl.java
@@ -537,6 +537,10 @@ public class SubscriptionImpl implements Subscription
 
     public void addToResendQueue(AMQMessage msg)
     {
+        //fixme - will this be ok as we need to ensure redelivery to same subscriber first
+        //release the message so it can be redelivered
+        msg.release();
+        
         // add to our resend queue
         getResendQueue().add(msg);