Author: clebert.suconic(a)jboss.com Date: 2011-07-06 16:52:54 -0400 (Wed, 06 Jul 2011) New Revision: 10940 Modified: branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionBridge.java Log: fixing more tests Modified: branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionBridge.java =================================================================== --- branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionBridge.java 2011-07-06 20:07:47 UTC (rev 10939) +++ branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionBridge.java 2011-07-06 20:52:54 UTC (rev 10940) @@ -139,40 +139,6 @@ } } - public void connectionFailed(final HornetQException me, boolean failedOver) - { - - log.warn(this + "::Connection failed with failedOver=" + failedOver + "-" + me, me); - - try - { - // csf.cleanup(); - } - catch (Throwable dontCare) - { - } - - try - { - // session.cleanUp(false); - } - catch (Throwable dontCare) - { - } - - if (me.getCode() == HornetQException.DISCONNECTED) - { - fail(true); - } - else - { - fail(false); - scheduleRetryConnect(); - } - } - - - @Override protected ServerMessage beforeForward(ServerMessage message) {