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@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)