From 735f111e1274bb737b3ff59f42e7f0002fec7ad6 Mon Sep 17 00:00:00 2001
From: Martin Ritchie <ritchiem@apache.org>
Date: Wed, 21 Feb 2007 16:03:24 +0000
Subject: QPID-348 Reverted unecessary nowait addition to amqp Basic.Recover
 spec.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@510076 13f79535-47bb-0310-9956-ffa450edef68
---
 .../apache/qpid/server/handler/BasicRecoverMethodHandler.java | 11 ++++-------
 .../src/main/java/org/apache/qpid/client/AMQSession.java      |  1 -
 2 files changed, 4 insertions(+), 8 deletions(-)

(limited to 'java')

diff --git a/java/broker/src/main/java/org/apache/qpid/server/handler/BasicRecoverMethodHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/BasicRecoverMethodHandler.java
index 5a9b9b54af..bc11e4652c 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/handler/BasicRecoverMethodHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/BasicRecoverMethodHandler.java
@@ -56,12 +56,9 @@ public class BasicRecoverMethodHandler implements StateAwareMethodListener<Basic
 
         channel.resend(session, body.requeue);
 
-        if (!body.nowait)
-        {
-            // AMQP version change: Hardwire the version to 0-8 (major=8, minor=0)
-            // TODO: Connect this to the session version obtained from ProtocolInitiation for this session.
-            // Be aware of possible changes to parameter order as versions change.
-            session.writeFrame(BasicRecoverOkBody.createAMQFrame(evt.getChannelId(), (byte) 8, (byte) 0));
-        }
+        // AMQP version change: Hardwire the version to 0-8 (major=8, minor=0)
+        // TODO: Connect this to the session version obtained from ProtocolInitiation for this session.
+        // Be aware of possible changes to parameter order as versions change.
+        session.writeFrame(BasicRecoverOkBody.createAMQFrame(evt.getChannelId(), (byte) 8, (byte) 0));
     }
 }
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQSession.java b/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
index 81f5bbfcc2..ad600ddb40 100644
--- a/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
+++ b/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
@@ -838,7 +838,6 @@ public class AMQSession extends Closeable implements Session, QueueSession, Topi
             _connection.getProtocolHandler().syncWrite(BasicRecoverBody.createAMQFrame(_channelId,
                                                                                        getProtocolMajorVersion(),
                                                                                        getProtocolMinorVersion(),
-                                                                                       false,    // nowait
                                                                                        false)    // requeue
                     , BasicRecoverOkBody.class);
 
-- 
cgit v1.2.1