You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by da...@apache.org on 2012/09/07 14:05:53 UTC
svn commit: r1381987 -
/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java
Author: davsclaus
Date: Fri Sep 7 12:05:53 2012
New Revision: 1381987
URL: http://svn.apache.org/viewvc?rev=1381987&view=rev
Log:
AMQ-3451: Ensure thread pools is shutdown properly to avoid any leaks. Do not use the old @deprecated thread pool.
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java?rev=1381987&r1=1381986&r2=1381987&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java Fri Sep 7 12:05:53 2012
@@ -288,11 +288,12 @@ public class VMTransport implements Tran
throw new TransportDisposedIOException("The Transport has been disposed");
}
+ String name = "ActiveMQ VMTransport: " + toString();
if (taskRunnerFactory == null) {
- taskRunnerFactory = new TaskRunnerFactory("ActiveMQ VMTransport: " + toString());
+ taskRunnerFactory = new TaskRunnerFactory(name);
taskRunnerFactory.init();
}
- taskRunner = result = taskRunnerFactory.createTaskRunner(this, "VMTransport: " + toString());
+ taskRunner = result = taskRunnerFactory.createTaskRunner(this, name);
}
}
}