Merge pull request #50 from sideshowdave7/master

Send ready every time the event loop starts now that the worker IDENT…

3 files changed, 9 insertions, 3 deletions

diff --git a/eventmq/__init__.py b/eventmq/__init__.py
index 2d9ae34..37a6afb 100644
--- a/eventmq/__init__.py
+++ b/eventmq/__init__.py
@@ -1,5 +1,5 @@
 __author__ = 'EventMQ Contributors'
-__version__ = '0.3.4.7'
+__version__ = '0.3.4.8'
 
 PROTOCOL_VERSION = 'eMQP/1.0'
 
diff --git a/eventmq/jobmanager.py b/eventmq/jobmanager.py
index a3e2ed2..4bd4ccb 100644
--- a/eventmq/jobmanager.py
+++ b/eventmq/jobmanager.py
@@ -146,7 +146,13 @@ class JobManager(HeartbeatMixin, EMQPService):
         Starts the actual event loop. Usually called by :meth:`start`
         """
         # Acknowledgment has come
-        # Send a READY for each available worker
+        # 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
 
diff --git a/setup.py b/setup.py
index 3ecc478..ad91149 100644
--- a/setup.py
+++ b/setup.py
@@ -7,7 +7,7 @@ from setuptools import find_packages, setup
 
 setup(
     name='eventmq',
-    version='0.3.4.7',
+    version='0.3.4.8',
     description='EventMQ job execution and messaging system based on ZeroMQ',
     packages=find_packages(),
     install_requires=['pyzmq==15.4.0',