activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject git commit: https://issues.apache.org/jira/browse/AMQ-5198
Date Fri, 18 Jul 2014 14:11:52 GMT
Repository: activemq
Updated Branches:
  refs/heads/trunk 3c6912752 -> d54e0d6ab


https://issues.apache.org/jira/browse/AMQ-5198

member variable scheduler assignment escapes the synchronization block
before the scheduler instance is fully initialized. 

Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/d54e0d6a
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/d54e0d6a
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/d54e0d6a

Branch: refs/heads/trunk
Commit: d54e0d6ab590b6a6148a5e2629c45b95d3f40eb8
Parents: 3c69127
Author: Timothy Bish <tabish121@gmail.com>
Authored: Fri Jul 18 10:11:25 2014 -0400
Committer: Timothy Bish <tabish121@gmail.com>
Committed: Fri Jul 18 10:11:25 2014 -0400

----------------------------------------------------------------------
 .../src/main/java/org/apache/activemq/ActiveMQConnection.java   | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/d54e0d6a/activemq-client/src/main/java/org/apache/activemq/ActiveMQConnection.java
----------------------------------------------------------------------
diff --git a/activemq-client/src/main/java/org/apache/activemq/ActiveMQConnection.java b/activemq-client/src/main/java/org/apache/activemq/ActiveMQConnection.java
index 2df8607..9252310 100755
--- a/activemq-client/src/main/java/org/apache/activemq/ActiveMQConnection.java
+++ b/activemq-client/src/main/java/org/apache/activemq/ActiveMQConnection.java
@@ -2556,8 +2556,9 @@ public class ActiveMQConnection implements Connection, TopicConnection,
QueueCon
                 if (result == null) {
                     checkClosed();
                     try {
-                        result = scheduler = new Scheduler("ActiveMQConnection["+info.getConnectionId().getValue()+"]
Scheduler");
-                        scheduler.start();
+                        result = new Scheduler("ActiveMQConnection["+info.getConnectionId().getValue()+"]
Scheduler");
+                        result.start();
+                        scheduler = result;
                     } catch(Exception e) {
                         throw JMSExceptionSupport.create(e);
                     }


Mime
View raw message