Thread factory should be set via ConnectionFactory

Author: michaelklishin

src/com/rabbitmq/client/ConnectionFactory.java

@@ -34,6 +34,7 @@
 import javax.net.ssl.TrustManager;
 
 import com.rabbitmq.client.impl.AMQConnection;
+import com.rabbitmq.client.impl.DefaultThreadFactory;
 import com.rabbitmq.client.impl.FrameHandler;
 import com.rabbitmq.client.impl.SocketFrameHandler;
 
@@ -89,6 +90,7 @@ public class ConnectionFactory implements Cloneable {
     private SocketFactory factory                 = SocketFactory.getDefault();
     private SaslConfig saslConfig                 = DefaultSaslConfig.PLAIN;
     private ExecutorService sharedExecutor;
+    private ThreadFactory threadFactory           = new DefaultThreadFactory();
 
     /** @return number of consumer threads in default {@link ExecutorService} */
     @Deprecated
@@ -398,6 +400,24 @@ public void setSharedExecutor(ExecutorService executor) {
         this.sharedExecutor = executor;
     }
 
+    /**
+     * Retrieve the socket factory used to instantiate new threads.
+     * @see com.rabbitmq.client.ThreadFactory
+     * @see com.rabbitmq.client.impl.DefaultThreadFactory
+     */
+    public ThreadFactory getThreadFactory() {
+        return threadFactory;
+    }
+
+    /**
+     * Set the thread factory to use for newly created connections.
+     * @see com.rabbitmq.client.ThreadFactory
+     * @see com.rabbitmq.client.impl.DefaultThreadFactory
+     */
+    public void setThreadFactory(ThreadFactory threadFactory) {
+        this.threadFactory = threadFactory;
+    }
+
     public boolean isSSL(){
         return getSocketFactory() instanceof SSLSocketFactory;
     }
@@ -527,6 +547,7 @@ public Connection newConnection(ExecutorService executor, Address[] addrs)
                                       requestedChannelMax,
                                       requestedHeartbeat,
                                       saslConfig);
+                conn.setThreadFactory(this.threadFactory);
                 conn.start();
                 return conn;
             } catch (IOException e) {