Prepare heartbeat sender to use our own thread factory

Author: michaelklishin

src/com/rabbitmq/client/impl/AMQConnection.java

@@ -266,7 +266,7 @@ public AMQConnection(String username,
         this._workService  = new ConsumerWorkService(executor);
         this._channelManager = null;
 
-        this._heartbeatSender = new HeartbeatSender(frameHandler);
+        this._heartbeatSender = new HeartbeatSender(frameHandler, threadFactory);
         this._brokerInitiatedShutdown = false;
 
         this._inConnectionNegotiation = true; // we start out waiting for the first protocol response

src/com/rabbitmq/client/impl/HeartbeatSender.java

@@ -22,6 +22,7 @@
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.Executors;
+import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.ScheduledFuture;
 import java.io.IOException;
@@ -39,6 +40,7 @@ final class HeartbeatSender {
     private final Object monitor = new Object();
 
     private final FrameHandler frameHandler;
+    private final ThreadFactory threadFactory;
 
     private ScheduledExecutorService executor;
 
@@ -48,8 +50,9 @@ final class HeartbeatSender {
 
     private volatile long lastActivityTime;
 
-    HeartbeatSender(FrameHandler frameHandler) {
+    HeartbeatSender(FrameHandler frameHandler, ThreadFactory threadFactory) {
         this.frameHandler = frameHandler;
+        this.threadFactory = threadFactory;
     }
 
     public void signalActivity() {
@@ -86,7 +89,7 @@ public void setHeartbeat(int heartbeatSeconds) {
     private ScheduledExecutorService createExecutorIfNecessary() {
         synchronized (this.monitor) {
             if (this.executor == null) {
-                this.executor = Executors.newSingleThreadScheduledExecutor();
+                this.executor = Executors.newSingleThreadScheduledExecutor(threadFactory);
             }
             return this.executor;
         }