diff --git a/‎java/srcPubnubApi/srcCore/com/pubnub/api/RequestManager.java‎
Lines changed: 10 additions & 0 deletions b/‎java/srcPubnubApi/srcCore/com/pubnub/api/RequestManager.java‎
Lines changed: 10 additions & 0 deletions
@@ -137,6 +137,7 @@ abstract class RequestManager {
     protected Hashtable headers;
     private static int count = 0;
     private boolean daemonThreads = false;
+    protected volatile boolean stop = false;
 
     protected static Logger log = new Logger(RequestManager.class);
 
@@ -154,6 +155,8 @@ private void initManager(int maxCalls, String name) {
         this.headers = new Hashtable();
         _workers = new Worker[maxCalls];
 
+        if (stop) return;
+
         synchronized (_workers) {
             for (int i = 0; i < maxCalls; ++i) {
                 Worker w = getWorker();
@@ -207,6 +210,9 @@ public void resetWorkers() {
                 resetter.start();
 
                 _workers[i].interruptWorker();
+
+                if (stop) return;
+
                 Worker w = getWorker();
 
                 PnThread thread = new PnThread(w, name + "-" + ++count);
@@ -249,10 +255,14 @@ public static void setWorkerCount(int count) {
     }
 
     public void stop() {
+        stop = true;
         synchronized (_workers) {
             for (int i = 0; i < _maxWorkers; ++i) {
                 Worker w = _workers[i];
                 w.die();
+                PnThread resetter = new PnThread(new ConnectionResetter(w));
+                resetter.setPnDaemon(daemonThreads);
+                resetter.start();
             }
         }
         synchronized (_waiting) {