Author: clebert.suconic(a)jboss.com Date: 2011-07-18 21:14:41 -0400 (Mon, 18 Jul 2011) New Revision: 10998 Modified: branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java Log: tweak Modified: branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java =================================================================== --- branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java 2011-07-19 00:24:09 UTC (rev 10997) +++ branches/Branch_2_2_EAP_cluster_clean2/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java 2011-07-19 01:14:41 UTC (rev 10998) @@ -588,8 +588,6 @@ { MessageFlowRecordImpl record = new MessageFlowRecordImpl(targetNodeID, connector, queueName, queue); - records.put(targetNodeID, record); - Bridge bridge = createClusteredBridge(record); if (log.isDebugEnabled()) @@ -599,6 +597,8 @@ record.setBridge(bridge); + records.put(targetNodeID, record); + if (start) { bridge.start();