[hornetq-commits] JBoss hornetq SVN: r12175 - trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl.

[do-not-reply at jboss.org]

Author: borges
Date: 2012-02-23 04:39:34 -0500 (Thu, 23 Feb 2012)
New Revision: 12175

Modified:
   trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/ChannelImpl.java
Log:
Check returned value.

Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/ChannelImpl.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/ChannelImpl.java	2012-02-23 09:39:18 UTC (rev 12174)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/protocol/core/impl/ChannelImpl.java	2012-02-23 09:39:34 UTC (rev 12175)
@@ -36,7 +36,7 @@
  *
  * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
  */
-public class ChannelImpl implements Channel
+public final class ChannelImpl implements Channel
 {
    public enum CHANNEL_ID {
 
@@ -293,7 +293,10 @@
                   }
                   else
                   {
-                     failoverCondition.await(connection.getBlockingCallFailoverTimeout(), TimeUnit.MILLISECONDS);
+                     if (!failoverCondition.await(connection.getBlockingCallFailoverTimeout(), TimeUnit.MILLISECONDS))
+                     {
+                        log.debug("timed-out waiting for failover condition");
+                     }
                   }
                }
                catch (InterruptedException e)