Add back sending ready on reconnections.0.3.5.3

- without this the workers get starved.

3 files changed, 11 insertions, 2 deletions

diff --git a/eventmq/__init__.py b/eventmq/__init__.py
index ac30476..0f12b07 100644
--- a/eventmq/__init__.py
+++ b/eventmq/__init__.py
@@ -1,5 +1,5 @@
 __author__ = 'EventMQ Contributors'
-__version__ = '0.3.5.2'
+__version__ = '0.3.5.3'
 
 PROTOCOL_VERSION = 'eMQP/1.0'
 
diff --git a/eventmq/jobmanager.py b/eventmq/jobmanager.py
index f85bf66..78a080b 100644
--- a/eventmq/jobmanager.py
+++ b/eventmq/jobmanager.py
@@ -146,6 +146,15 @@ 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:
diff --git a/setup.py b/setup.py
index 3664ba9..15d5ab7 100644
--- a/setup.py
+++ b/setup.py
@@ -7,7 +7,7 @@ from setuptools import find_packages, setup
 
 setup(
     name='eventmq',
-    version='0.3.5.2',
+    version='0.3.5.3',
     description='EventMQ job execution and messaging system based on ZeroMQ',
     packages=find_packages(),
     install_requires=['pyzmq==15.4.0',