[servicemix-scm] [716] trunk/components/base/src/main/java/org/servicemix/components/jms/JmsServiceComponent.java: Fix JmsServiceComponent.java to handle jms correlation ids.

[scm]

Title: [716] trunk/components/base/src/main/java/org/servicemix/components/jms/JmsServiceComponent.java: Fix JmsServiceComponent.java to handle jms correlation ids.

Revision

716

Author

gnt

Date

2005-11-01 19:31:12 -0500 (Tue, 01 Nov 2005)

Log Message

Fix JmsServiceComponent.java to handle jms correlation ids.

Modified Paths

• trunk/components/base/src/main/java/org/servicemix/components/jms/JmsServiceComponent.java

Diff

Modified: trunk/components/base/src/main/java/org/servicemix/components/jms/JmsServiceComponent.java (715 => 716)

--- trunk/components/base/src/main/java/org/servicemix/components/jms/JmsServiceComponent.java	2005-11-02 00:30:31 UTC (rev 715)
+++ trunk/components/base/src/main/java/org/servicemix/components/jms/JmsServiceComponent.java	2005-11-02 00:31:12 UTC (rev 716)
@@ -145,7 +145,7 @@
         this.selector = selector;
     }
 
-    public void onMessage(Message jmsMessage) {
+    public void onMessage(final Message jmsMessage) {
         try {
             final InOut messageExchange = getDeliveryChannel().createExchangeFactory().createInOutExchange();
             NormalizedMessage inMessage = messageExchange.createMessage();
@@ -159,6 +159,7 @@
                             public Message createMessage(Session session) throws JMSException {
                                 try {
                                     Message message = marshaler.createMessage(messageExchange.getOutMessage(), session);
+                                    message.setJMSCorrelationID(jmsMessage.getJMSCorrelationID());
                                     if (log.isTraceEnabled()) {
                                         log.trace("Sending message to: " + template.getDefaultDestinationName()
                                                 + " message: " + message);