activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r663178 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
Date Wed, 04 Jun 2008 15:15:58 GMT
Author: chirino
Date: Wed Jun  4 08:15:57 2008
New Revision: 663178

URL: http://svn.apache.org/viewvc?rev=663178&view=rev
Log:
make sure that the task runner is the first thing setup since other startup bits might want
to do an async send.


Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java?rev=663178&r1=663177&r2=663178&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
Wed Jun  4 08:15:57 2008
@@ -847,14 +847,13 @@
         starting = true;
         try {
                synchronized(this) {
-                   transport.start();
-
                    if (taskRunnerFactory != null) {
                        taskRunner = taskRunnerFactory.createTaskRunner(this, "ActiveMQ Connection
Dispatcher: "
                                                                              + getRemoteAddress());
                    } else {
                        taskRunner = null;
                    }
+                   transport.start();
 
                    active = true;
                    this.processDispatch(connector.getBrokerInfo());



Mime
View raw message