Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@activemq.apache.org
Content-Type: text/plain; charset="utf-8"
MIME-Version: 1.0
Content-Transfer-Encoding: 7bit
Subject: svn commit: r1381191 -
 /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java
Date: Wed, 05 Sep 2012 14:08:49 -0000
To: commits@activemq.apache.org
From: davsclaus@apache.org
Message-Id: <20120905140850.14B7823888EA@eris.apache.org>

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);
         }