You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by ff...@apache.org on 2008/09/02 14:51:36 UTC
svn commit: r691222 -
/servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/endpoints/JmsProviderEndpoint.java
Author: ffang
Date: Tue Sep 2 05:51:35 2008
New Revision: 691222
URL: http://svn.apache.org/viewvc?rev=691222&view=rev
Log:
[SM-1513]apply patch on behalf of Ulhas
Modified:
servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/endpoints/JmsProviderEndpoint.java
Modified: servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/endpoints/JmsProviderEndpoint.java
URL: http://svn.apache.org/viewvc/servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/endpoints/JmsProviderEndpoint.java?rev=691222&r1=691221&r2=691222&view=diff
==============================================================================
--- servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/endpoints/JmsProviderEndpoint.java (original)
+++ servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-jms/src/main/java/org/apache/servicemix/jms/endpoints/JmsProviderEndpoint.java Tue Sep 2 05:51:35 2008
@@ -411,14 +411,12 @@
// Create selector
String jmsId = sendJmsMsg.getJMSMessageID();
String selector = MSG_SELECTOR_START + jmsId + MSG_SELECTOR_END;
- Message receiveJmsMsg;
- synchronized (template) {
- // Receiving JMS Message, Creating and Returning NormalizedMessage out
- receiveJmsMsg = template.receiveSelected(replyDest, selector);
- if (receiveJmsMsg == null) {
- throw new IllegalStateException("Unable to receive response");
- }
- }
+
+ // Receiving JMS Message, Creating and Returning NormalizedMessage out
+ Message receiveJmsMsg = template.receiveSelected(replyDest, selector);
+ if (receiveJmsMsg == null) {
+ throw new IllegalStateException("Unable to receive response");
+ }
marshaler.populateMessage(receiveJmsMsg, exchange, out);
}