2 files changed, 6 insertions, 4 deletions

diff --git a/bin/send_request b/bin/send_request
index aa84639..9c8696d 100755
--- a/bin/send_request
+++ b/bin/send_request
@@ -21,4 +21,5 @@ if __name__ == "__main__":
            'kwargs': {}
            }]
 
-    send_request(s, msg, guarantee=True, reply_requested=True)
+    while True:
+        send_request(s, msg, guarantee=True, reply_requested=True)
diff --git a/eventmq/jobmanager.py b/eventmq/jobmanager.py
index e94f16d..b6de15e 100644
--- a/eventmq/jobmanager.py
+++ b/eventmq/jobmanager.py
@@ -244,13 +244,14 @@ class JobManager(HeartbeatMixin, EMQPService):
 
     def check_worker_health(self):
         """
-        Checks for any dead processes in the pool and recreates them if necessary
+        Checks for any dead processes in the pool and recreates them if
+        necessary
         """
         self._workers = [w for w in self._workers if w.is_alive()]
 
         if len(self._workers) < conf.CONCURRENT_JOBS:
-            logger.warning("{} worker process(es) may have died...recreating")\
-                  .format(conf.CONCURRENT_JOBS - len(self._workers))
+            logger.warning("{} worker process(es) may have died...recreating"
+                           .format(conf.CONCURRENT_JOBS - len(self._workers)))
 
         for i in range(0, conf.CONCURRENT_JOBS - len(self._workers)):
             w = Worker(self.request_queue, self.finished_queue)