Author: clebert.suconic(a)jboss.com Date: 2011-08-05 09:10:52 -0400 (Fri, 05 Aug 2011) New Revision: 11137 Modified: branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/BridgeImpl.java Log: damn Modified: branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/BridgeImpl.java =================================================================== --- branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/BridgeImpl.java 2011-08-05 07:23:26 UTC (rev 11136) +++ branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/BridgeImpl.java 2011-08-05 13:10:52 UTC (rev 11137) @@ -792,18 +792,10 @@ { log.debug("stopping bridge " + BridgeImpl.this); -/////////////// -// if (session != null) -// { -// log.debug("Cleaning up session " + session); -// session.close(); -// -// } - - session.cleanUp(false); - if (session != null) { + log.debug("Cleaning up session " + session); + session.close(); session.removeFailureListener(BridgeImpl.this); }