From 507f2475a621d9fefe100051837aff4872eea1c8 Mon Sep 17 00:00:00 2001
From: "Rafael H. Schloming" <rhs@apache.org>
Date: Thu, 26 Feb 2009 00:29:57 +0000
Subject: fixup of change for QPID-1642 and QPID-1643

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@747977 13f79535-47bb-0310-9956-ffa450edef68
---
 java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java    | 2 +-
 .../src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_8.java  | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

(limited to 'java/client/src/main')

diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java b/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java
index 356d0dae7b..ff8631c12e 100644
--- a/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java
+++ b/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_8.java
@@ -301,7 +301,7 @@ public final class AMQSession_0_8 extends AMQSession<BasicMessageConsumer_0_8, B
     {
         ExchangeDeclareBody body = getMethodRegistry().createExchangeDeclareBody(getTicket(),name,type,
                                                                                  name.toString().startsWith("amq."),
-                                                                                 false,false,false,nowait,null);
+                                                                                 false,false,false,false,null);
         AMQFrame exchangeDeclare = body.generateFrame(_channelId);
 
         protocolHandler.syncWrite(exchangeDeclare, ExchangeDeclareOkBody.class);
diff --git a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_8.java b/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_8.java
index db85ac37d0..308f04f082 100644
--- a/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_8.java
+++ b/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_8.java
@@ -85,7 +85,7 @@ public class BasicMessageConsumer_0_8 extends BasicMessageConsumer<UnprocessedMe
 
     Message receiveBrowse() throws JMSException
     {
-        return receive(1000);
+        return receive();
     }
 
 }
-- 
cgit v1.2.1