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/05 16:08:49 UTC
svn commit: r1381191 -
/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java
Author: davsclaus
Date: Wed Sep 5 14:08:48 2012
New Revision: 1381191
URL: http://svn.apache.org/viewvc?rev=1381191&view=rev
Log:
AMQ-4016: Removed not used static thread pool from ActiveMQConnectionFactory.
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java?rev=1381191&r1=1381190&r2=1381191&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java Wed Sep 5 14:08:48 2012
@@ -21,10 +21,7 @@ import java.net.URISyntaxException;
import java.util.HashMap;
import java.util.Map;
import java.util.Properties;
-import java.util.concurrent.Executor;
import java.util.concurrent.RejectedExecutionHandler;
-import java.util.concurrent.ScheduledThreadPoolExecutor;
-import java.util.concurrent.ThreadFactory;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
@@ -69,15 +66,6 @@ public class ActiveMQConnectionFactory e
public static final String DEFAULT_PASSWORD = null;
public static final int DEFAULT_PRODUCER_WINDOW_SIZE = 0;
-
- protected static final Executor DEFAULT_CONNECTION_EXECUTOR = new ScheduledThreadPoolExecutor(5, new ThreadFactory() {
- public Thread newThread(Runnable run) {
- Thread thread = new Thread(run);
- thread.setPriority(ThreadPriorities.INBOUND_CLIENT_CONNECTION);
- return thread;
- }
- });
-
protected URI brokerURL;
protected String userName;
protected String password;
@@ -255,11 +243,10 @@ public class ActiveMQConnectionFactory e
*
* @return The newly created Transport.
* @throws JMSException If unable to create trasnport.
- * @author sepandm@gmail.com
*/
protected Transport createTransport() throws JMSException {
try {
- return TransportFactory.connect(brokerURL, DEFAULT_CONNECTION_EXECUTOR);
+ return TransportFactory.connect(brokerURL);
} catch (Exception e) {
throw JMSExceptionSupport.create("Could not create Transport. Reason: " + e, e);
}