Revert "Backport 0.4 handling of workers after death"

- This was a stab at a fix which didn't fix the issue we were seeing.
  It's possible that it caused a memory issue so it is being reverted.

This reverts commit 56cfa885b92b024dc2f70157a0f0b7826ad23e5b.

2 files changed, 9 insertions, 10 deletions

diff --git a/bin/send_msg b/bin/send_msg
index 33cfb1a..c3e88fa 100755
--- a/bin/send_msg
+++ b/bin/send_msg
@@ -22,7 +22,7 @@ if __name__ == "__main__":
             'callable': 'work_job',
             'class_args': ('blurp',),
             'class_kwargs': {'kwarg1': True},
-            'args': (1, ),
+            'args': (10, ),
             'kwargs': {}
             }]
 
diff --git a/eventmq/jobmanager.py b/eventmq/jobmanager.py
index c900495..c904d99 100644
--- a/eventmq/jobmanager.py
+++ b/eventmq/jobmanager.py
@@ -146,6 +146,14 @@ class JobManager(HeartbeatMixin, EMQPService):
         Starts the actual event loop. Usually called by :meth:`start`
         """
         # Acknowledgment has come
+        # When the job manager unexpectedly disconnects from the router and
+        # reconnects it needs to send a ready for each previously available
+        # worker.
+        # Send a READY for each previously available worker
+        if hasattr(self, '_workers'):
+            for _ in self._workers:
+                self.send_ready()
+
         self.status = STATUS.running
 
         try:
@@ -210,15 +218,6 @@ class JobManager(HeartbeatMixin, EMQPService):
         except Exception:
             logger.exception("Unhandled exception in main jobmanager loop")
 
-        # Cleanup
-        if hasattr(self, '_workers'):
-            del self._workers
-
-        # Flush the queues with workers
-        self.request_queue = mp_queue()
-        self.finished_queue = mp_queue()
-        logger.info("Reached end of event loop")
-
     def handle_response(self, resp):
         """
         Handles a response from a worker process to the jobmanager