1 files changed, 7 insertions, 5 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/framing/BasicRecoverBody.java b/java/common/src/main/java/org/apache/qpid/framing/BasicRecoverBody.java
index 2519f25fbe..e5490c4827 100644
--- a/java/common/src/main/java/org/apache/qpid/framing/BasicRecoverBody.java
+++ b/java/common/src/main/java/org/apache/qpid/framing/BasicRecoverBody.java
@@ -100,14 +100,16 @@ public class BasicRecoverBody extends AMQMethodBodyImpl implements EncodableAMQD
         return buf.toString();
     }
 
-    public static void process(final int channelId,
-                                final MarkableDataInput in,
-                                final ProtocolVersion protocolVersion,
-                                final MethodProcessor dispatcher) throws IOException
+    public static void process(final MarkableDataInput in,
+                               final ProtocolVersion protocolVersion,
+                               final ServerChannelMethodProcessor dispatcher) throws IOException
     {
         boolean requeue = (in.readByte() & 0x01) == 0x01;
         boolean sync = (ProtocolVersion.v8_0.equals(protocolVersion));
 
-        dispatcher.receiveBasicRecover(channelId, requeue, sync);
+        if(!dispatcher.ignoreAllButCloseOk())
+        {
+            dispatcher.receiveBasicRecover(requeue, sync);
+        }
     }
 }