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 15:01:04 UTC
svn commit: r691229 -
/servicemix/components/bindings/servicemix-jms/trunk/src/main/java/org/apache/servicemix/jms/endpoints/JmsProviderEndpoint.java
Author: ffang
Date: Tue Sep 2 06:01:02 2008
New Revision: 691229
URL: http://svn.apache.org/viewvc?rev=691229&view=rev
Log:
[SM-1513]apply patch on behalf of Ulhas
Modified:
servicemix/components/bindings/servicemix-jms/trunk/src/main/java/org/apache/servicemix/jms/endpoints/JmsProviderEndpoint.java
Modified: servicemix/components/bindings/servicemix-jms/trunk/src/main/java/org/apache/servicemix/jms/endpoints/JmsProviderEndpoint.java
URL: http://svn.apache.org/viewvc/servicemix/components/bindings/servicemix-jms/trunk/src/main/java/org/apache/servicemix/jms/endpoints/JmsProviderEndpoint.java?rev=691229&r1=691228&r2=691229&view=diff
==============================================================================
--- servicemix/components/bindings/servicemix-jms/trunk/src/main/java/org/apache/servicemix/jms/endpoints/JmsProviderEndpoint.java (original)
+++ servicemix/components/bindings/servicemix-jms/trunk/src/main/java/org/apache/servicemix/jms/endpoints/JmsProviderEndpoint.java Tue Sep 2 06:01:02 2008
@@ -564,14 +564,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");
}
+
NormalizedMessage out = exchange.getMessage("out");
if (out == null) {
out = exchange.createMessage();