svn commit: r498690 - /incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/BlockingMethodFrameListener.java

[ritchiem]

Author: ritchiem
Date: Mon Jan 22 08:47:06 2007
New Revision: 498690

URL: http://svn.apache.org/viewvc?view=rev&rev=498690
Log:
QPID-308 Configurable timeout on blockForFrame.
Stopping on InterruptedException is not correct logic.
 

Modified:
    
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/BlockingMethodFrameListener.java

Modified: 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/BlockingMethodFrameListener.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/BlockingMethodFrameListener.java?view=diff&rev=498690&r1=498689&r2=498690
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/BlockingMethodFrameListener.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/BlockingMethodFrameListener.java
 Mon Jan 22 08:47:06 2007
@@ -119,11 +119,11 @@
                 catch (InterruptedException e)
                 {
                     // IGNORE    -- //fixme this isn't ideal as being 
interrupted isn't equivellant to sucess
-                    if (!_ready && timeout != -1)
-                    {
-                        _error = new AMQException("Server did not respond 
timely");
-                        _ready = true;
-                    }
+//                    if (!_ready && timeout != -1)
+//                    {
+//                        _error = new AMQException("Server did not respond 
timely");
+//                        _ready = true;
+//                    }
                 }
             }
         }