[servicemix-scm] [745] trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/AbstractFlow.java: Ensure that MessageExchange's from another Container are routed correctly

[scm]

Title: [745] trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/AbstractFlow.java: Ensure that MessageExchange's from another Container are routed correctly

Revision

745

Author

rajdavies

Date

2005-11-04 03:12:01 -0500 (Fri, 04 Nov 2005)

Log Message

Ensure that MessageExchange's from another Container are routed correctly

Modified Paths

trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/AbstractFlow.java

Diff

Modified: trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/AbstractFlow.java (744 => 745)

--- trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/AbstractFlow.java	2005-11-04 08:04:36 UTC (rev 744)
+++ trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/AbstractFlow.java	2005-11-04 08:12:01 UTC (rev 745)
@@ -163,7 +163,10 @@
      */
     public void doRouting(MessageExchangeImpl me) throws MessagingException {
         ComponentNameSpace id = me.getRole() == Role.PROVIDER ? me.getDestinationId() : me.getSourceId();
-        LocalComponentConnector lcc = broker.getRegistry().getLocalComponentConnector(id);
+        //As the MessageExchange could come from another container - ensure we get the local Component
+        ComponentNameSpace copy = id.copy();
+        copy.setContainerName(broker.getContainerName());
+        LocalComponentConnector lcc = broker.getRegistry().getLocalComponentConnector(copy);
         if (lcc != null) {
             lcc.getDeliveryChannel().processInBound(me);
         }