You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ha...@apache.org on 2008/04/22 14:44:47 UTC
svn commit: r650486 -
/activemq/camel/trunk/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsComponent.java
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;
}