Title: [746] trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/jms/JMSFlow.java: ensure replies go back to the sender
- Revision
- 746
- Author
- rajdavies
- Date
- 2005-11-04 03:15:46 -0500 (Fri, 04 Nov 2005)
Log Message
ensure replies go back to the sender
Modified Paths
Diff
Modified: trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/jms/JMSFlow.java (745 => 746)
--- trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/jms/JMSFlow.java 2005-11-04 08:12:01 UTC (rev 745)
+++ trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/jms/JMSFlow.java 2005-11-04 08:15:46 UTC (rev 746)
@@ -343,7 +343,13 @@
// let ActiveMQ do the routing ...
try{
String componentName=cc.getComponentNameSpace().getName();
- Queue queue=inboundSession.createQueue(INBOUND_PREFIX+componentName);
+ String destination = "";
+ if (me.getRole() == Role.PROVIDER){
+ destination = INBOUND_PREFIX + componentName;
+ }else {
+ destination = INBOUND_PREFIX + id.getContainerName();
+ }
+ Queue queue=inboundSession.createQueue(destination);
ObjectMessage msg=inboundSession.createObjectMessage(me);
queueProducer.send(queue,msg);
}catch(JMSException e){
