svn commit: r650486 - /activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsComponent.java

[hadrian]

Author: hadrian
Date: Tue Apr 22 05:44:31 2008
New Revision: 650486

URL: http://svn.apache.org/viewvc?rev=650486&view=rev
Log:
Cleanup sync in camel-jms

Modified:
    
activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsComponent.java

Modified: 
activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsComponent.java
URL: 
http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsComponent.java?rev=650486&r1=650485&r2=650486&view=diff
==============================================================================
--- 
activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsComponent.java
 (original)
+++ 
activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsComponent.java
 Tue Apr 22 05:44:31 2008
@@ -58,7 +58,7 @@
     private static final String DEFAULT_QUEUE_BROWSE_STRATEGY = 
"org.apache.camel.component.jms.DefaultQueueBrowseStrategy";
     private JmsConfiguration configuration;
     private ApplicationContext applicationContext;
-    private volatile Requestor requestor;
+    private Requestor requestor;
     private QueueBrowseStrategy queueBrowseStrategy;
     private boolean attemptedToCreateQueueBrowserStrategy;
 
@@ -314,10 +314,8 @@
 
     public synchronized Requestor getRequestor() throws Exception {
         if (requestor == null) {
-               synchronized (this) {
-                requestor = new Requestor(getConfiguration(), 
getExecutorService());
-                requestor.start();
-               }
+            requestor = new Requestor(getConfiguration(), 
getExecutorService());
+            requestor.start();
         }
         return requestor;
     }