[servicemix-scm] [707] trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/jms: Fix jms/jca flows when using multiple components

[scm]

Title: [707] trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/jms: Fix jms/jca flows when using multiple components

Revision

707

Author

gnt

Date

2005-10-30 23:05:41 -0500 (Sun, 30 Oct 2005)

Log Message

Fix jms/jca flows when using multiple components

Modified Paths

• trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/jca/JCAFlow.java
• trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/jms/JMSFlow.java

Diff

Modified: trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/jca/JCAFlow.java (706 => 707)

--- trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/jca/JCAFlow.java	2005-10-29 02:55:08 UTC (rev 706)
+++ trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/jca/JCAFlow.java	2005-10-31 04:05:41 UTC (rev 707)
@@ -520,10 +520,10 @@
         if (set == null) {
             set = new CopyOnWriteArraySet();
             networkNodeKeyMap.put(containerName, set);
-            ComponentConnector cc = new ComponentConnector(packet);
-            log.info("Adding Remote Component: " + cc);
-            broker.getRegistry().addRemoteComponentConnector(cc);
         }
+        ComponentConnector cc = new ComponentConnector(packet);
+        log.info("Adding Remote Component: " + cc);
+        broker.getRegistry().addRemoteComponentConnector(cc);
         set.add(packet);
     }
 

Modified: trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/jms/JMSFlow.java (706 => 707)

--- trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/jms/JMSFlow.java	2005-10-29 02:55:08 UTC (rev 706)
+++ trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/jms/JMSFlow.java	2005-10-31 04:05:41 UTC (rev 707)
@@ -423,10 +423,10 @@
         if (set == null) {
             set = new CopyOnWriteArraySet();
             networkNodeKeyMap.put(containerName, set);
-            ComponentConnector cc = new ComponentConnector(packet);
-            log.info("Adding Remote Component: " + cc);
-            broker.getRegistry().addRemoteComponentConnector(cc);
         }
+        ComponentConnector cc = new ComponentConnector(packet);
+        log.info("Adding Remote Component: " + cc);
+        broker.getRegistry().addRemoteComponentConnector(cc);
         set.add(packet);
     }