1 files changed, 181 insertions, 19 deletions

diff --git a/genindex.html b/genindex.html
index 89b10e7..6186e51 100644
--- a/genindex.html
+++ b/genindex.html
@@ -175,18 +175,34 @@
   </dt>
 
         
+  <dt><a href="utils/classes.html#eventmq.utils.classes.EMQdeque.__init__">(eventmq.utils.classes.EMQdeque method)</a>
+  </dt>
+
+        
   <dt><a href="utils/classes.html#eventmq.utils.classes.HeartbeatMixin.__init__">(eventmq.utils.classes.HeartbeatMixin method)</a>
   </dt>
 
+        
+  <dt><a href="utils/timeutils.html#eventmq.utils.timeutils.IntervalIter.__init__">(eventmq.utils.timeutils.IntervalIter method)</a>
+  </dt>
+
       </dl></dd>
   </dl></td>
   <td style="width: 33%" valign="top"><dl>
       
-  <dt><a href="utils/classes.html#eventmq.utils.classes.HeartbeatMixin.__weakref__">__weakref__ (eventmq.utils.classes.HeartbeatMixin attribute)</a>
+  <dt><a href="utils/classes.html#eventmq.utils.classes.EMQdeque.__weakref__">__weakref__ (eventmq.utils.classes.EMQdeque attribute)</a>
   </dt>
 
       <dd><dl>
         
+  <dt><a href="utils/classes.html#eventmq.utils.classes.EMQPService.__weakref__">(eventmq.utils.classes.EMQPService attribute)</a>
+  </dt>
+
+        
+  <dt><a href="utils/classes.html#eventmq.utils.classes.HeartbeatMixin.__weakref__">(eventmq.utils.classes.HeartbeatMixin attribute)</a>
+  </dt>
+
+        
   <dt><a href="utils/classes.html#eventmq.utils.classes.ZMQReceiveMixin.__weakref__">(eventmq.utils.classes.ZMQReceiveMixin attribute)</a>
   </dt>
 
@@ -194,6 +210,10 @@
   <dt><a href="utils/classes.html#eventmq.utils.classes.ZMQSendMixin.__weakref__">(eventmq.utils.classes.ZMQSendMixin attribute)</a>
   </dt>
 
+        
+  <dt><a href="utils/timeutils.html#eventmq.utils.timeutils.IntervalIter.__weakref__">(eventmq.utils.timeutils.IntervalIter attribute)</a>
+  </dt>
+
       </dl></dd>
   </dl></td>
 </tr></table>
@@ -202,7 +222,7 @@
 <table style="width: 100%" class="indextable genindextable"><tr>
   <td style="width: 33%" valign="top"><dl>
       
-  <dt><a href="jobmanager.html#eventmq.jobmanager.JobManager.active_jobs">active_jobs (eventmq.jobmanager.JobManager attribute)</a>
+  <dt><a href="router.html#eventmq.router.Router.add_scheduler">add_scheduler() (eventmq.router.Router method)</a>
   </dt>
 
       
@@ -212,7 +232,11 @@
   </dl></td>
   <td style="width: 33%" valign="top"><dl>
       
-  <dt><a href="jobmanager.html#eventmq.jobmanager.JobManager.available_workers">available_workers (eventmq.jobmanager.JobManager attribute)</a>
+  <dt><a href="utils/classes.html#eventmq.utils.classes.EMQdeque.append">append() (eventmq.utils.classes.EMQdeque method)</a>
+  </dt>
+
+      
+  <dt><a href="utils/classes.html#eventmq.utils.classes.EMQdeque.appendleft">appendleft() (eventmq.utils.classes.EMQdeque method)</a>
   </dt>
 
   </dl></td>
@@ -232,6 +256,10 @@
 <table style="width: 100%" class="indextable genindextable"><tr>
   <td style="width: 33%" valign="top"><dl>
       
+  <dt><a href="router.html#eventmq.router.Router.clean_up_dead_schedulers">clean_up_dead_schedulers() (eventmq.router.Router method)</a>
+  </dt>
+
+      
   <dt><a href="router.html#eventmq.router.Router.clean_up_dead_workers">clean_up_dead_workers() (eventmq.router.Router method)</a>
   </dt>
 
@@ -264,6 +292,14 @@
 <table style="width: 100%" class="indextable genindextable"><tr>
   <td style="width: 33%" valign="top"><dl>
       
+  <dt><a href="utils/classes.html#eventmq.utils.classes.EMQdeque">EMQdeque (class in eventmq.utils.classes)</a>
+  </dt>
+
+      
+  <dt><a href="utils/classes.html#eventmq.utils.classes.EMQPService">EMQPService (class in eventmq.utils.classes)</a>
+  </dt>
+
+      
   <dt><a href="client.html#module-eventmq.client">eventmq.client (module)</a>
   </dt>
 
@@ -298,7 +334,7 @@
   </dt>
 
       
-  <dt><a href="utils.html#module-eventmq.utils">eventmq.utils (module)</a>
+  <dt><a href="utils/index.html#module-eventmq.utils">eventmq.utils (module)</a>
   </dt>
 
       
@@ -306,10 +342,18 @@
   </dt>
 
       
+  <dt><a href="utils/devices.html#module-eventmq.utils.devices">eventmq.utils.devices (module)</a>
+  </dt>
+
+      
   <dt><a href="utils/messages.html#module-eventmq.utils.messages">eventmq.utils.messages (module)</a>
   </dt>
 
       
+  <dt><a href="utils/settings.html#module-eventmq.utils.settings">eventmq.utils.settings (module)</a>
+  </dt>
+
+      
   <dt><a href="utils/timeutils.html#module-eventmq.utils.timeutils">eventmq.utils.timeutils (module)</a>
   </dt>
 
@@ -317,6 +361,10 @@
   <dt><a href="exceptions.html#eventmq.exceptions.EventMQError">EventMQError</a>
   </dt>
 
+      
+  <dt><a href="utils/classes.html#eventmq.utils.classes.EMQdeque.extend">extend() (eventmq.utils.classes.EMQdeque method)</a>
+  </dt>
+
   </dl></td>
 </tr></table>
 
@@ -334,10 +382,20 @@
 <table style="width: 100%" class="indextable genindextable"><tr>
   <td style="width: 33%" valign="top"><dl>
       
+  <dt><a href="utils/devices.html#eventmq.utils.devices.generate_device_name">generate_device_name() (in module eventmq.utils.devices)</a>
+  </dt>
+
+      
   <dt><a href="utils/messages.html#eventmq.utils.messages.generate_msgid">generate_msgid() (in module eventmq.utils.messages)</a>
   </dt>
 
   </dl></td>
+  <td style="width: 33%" valign="top"><dl>
+      
+  <dt><a href="router.html#eventmq.router.Router.get_available_worker">get_available_worker() (eventmq.router.Router method)</a>
+  </dt>
+
+  </dl></td>
 </tr></table>
 
 <h2 id="H">H</h2>
@@ -354,17 +412,37 @@
 <table style="width: 100%" class="indextable genindextable"><tr>
   <td style="width: 33%" valign="top"><dl>
       
-  <dt><a href="jobmanager.html#eventmq.jobmanager.JobManager.incoming">incoming (eventmq.jobmanager.JobManager attribute)</a>
+  <dt><a href="utils/settings.html#eventmq.utils.settings.import_settings">import_settings() (in module eventmq.utils.settings)</a>
+  </dt>
+
+      
+  <dt><a href="utils/timeutils.html#eventmq.utils.timeutils.IntervalIter">IntervalIter (class in eventmq.utils.timeutils)</a>
   </dt>
 
       
   <dt><a href="exceptions.html#eventmq.exceptions.InvalidMessageError">InvalidMessageError</a>
   </dt>
 
+      
+  <dt><a href="utils/classes.html#eventmq.utils.classes.HeartbeatMixin.is_dead">is_dead() (eventmq.utils.classes.HeartbeatMixin method)</a>
+  </dt>
+
   </dl></td>
   <td style="width: 33%" valign="top"><dl>
       
-  <dt><a href="utils/classes.html#eventmq.utils.classes.HeartbeatMixin.is_dead">is_dead() (eventmq.utils.classes.HeartbeatMixin method)</a>
+  <dt><a href="utils/classes.html#eventmq.utils.classes.EMQdeque.is_empty">is_empty() (eventmq.utils.classes.EMQdeque method)</a>
+  </dt>
+
+      
+  <dt><a href="utils/classes.html#eventmq.utils.classes.EMQdeque.is_full">is_full() (eventmq.utils.classes.EMQdeque method)</a>
+  </dt>
+
+      
+  <dt><a href="utils/classes.html#eventmq.utils.classes.EMQPService.is_heartbeat_enabled">is_heartbeat_enabled (eventmq.utils.classes.EMQPService attribute)</a>
+  </dt>
+
+      
+  <dt><a href="utils/classes.html#eventmq.utils.classes.EMQdeque.is_pfull">is_pfull() (eventmq.utils.classes.EMQdeque method)</a>
   </dt>
 
   </dl></td>
@@ -440,13 +518,19 @@
 
       </dl></dd>
   </dl></td>
+  <td style="width: 33%" valign="top"><dl>
+      
+  <dt><a href="exceptions.html#eventmq.exceptions.NoAvailableWorkerSlotsError">NoAvailableWorkerSlotsError</a>
+  </dt>
+
+  </dl></td>
 </tr></table>
 
 <h2 id="O">O</h2>
 <table style="width: 100%" class="indextable genindextable"><tr>
   <td style="width: 33%" valign="top"><dl>
       
-  <dt><a href="jobmanager.html#eventmq.jobmanager.JobManager.on_ack">on_ack() (eventmq.jobmanager.JobManager method)</a>
+  <dt><a href="utils/classes.html#eventmq.utils.classes.EMQPService.on_ack">on_ack() (eventmq.utils.classes.EMQPService method)</a>
   </dt>
 
       
@@ -463,12 +547,12 @@
   <dt><a href="router.html#eventmq.router.Router.on_inform">on_inform() (eventmq.router.Router method)</a>
   </dt>
 
-  </dl></td>
-  <td style="width: 33%" valign="top"><dl>
       
   <dt><a href="router.html#eventmq.router.Router.on_ready">on_ready() (eventmq.router.Router method)</a>
   </dt>
 
+  </dl></td>
+  <td style="width: 33%" valign="top"><dl>
       
   <dt><a href="router.html#eventmq.router.Router.on_receive_request">on_receive_request() (eventmq.router.Router method)</a>
   </dt>
@@ -477,6 +561,16 @@
   <dt><a href="jobmanager.html#eventmq.jobmanager.JobManager.on_request">on_request() (eventmq.jobmanager.JobManager method)</a>
   </dt>
 
+      <dd><dl>
+        
+  <dt><a href="router.html#eventmq.router.Router.on_request">(eventmq.router.Router method)</a>
+  </dt>
+
+      </dl></dd>
+      
+  <dt><a href="jobmanager.html#eventmq.jobmanager.JobManager.outgoing">outgoing (eventmq.jobmanager.JobManager attribute)</a>
+  </dt>
+
   </dl></td>
 </tr></table>
 
@@ -499,14 +593,26 @@
   <dt><a href="poller.html#eventmq.poller.Poller.poll">poll() (eventmq.poller.Poller method)</a>
   </dt>
 
+      
+  <dt><a href="poller.html#eventmq.poller.Poller">Poller (class in eventmq.poller)</a>
+  </dt>
+
   </dl></td>
   <td style="width: 33%" valign="top"><dl>
       
-  <dt><a href="poller.html#eventmq.poller.Poller">Poller (class in eventmq.poller)</a>
+  <dt><a href="utils/classes.html#eventmq.utils.classes.EMQdeque.pop">pop() (eventmq.utils.classes.EMQdeque method)</a>
+  </dt>
+
+      
+  <dt><a href="utils/classes.html#eventmq.utils.classes.EMQdeque.popleft">popleft() (eventmq.utils.classes.EMQdeque method)</a>
+  </dt>
+
+      
+  <dt><a href="router.html#eventmq.router.Router.prioritize_queue_list">prioritize_queue_list() (eventmq.router.Router class method)</a>
   </dt>
 
       
-  <dt><a href="jobmanager.html#eventmq.jobmanager.JobManager.process_message">process_message() (eventmq.jobmanager.JobManager method)</a>
+  <dt><a href="utils/classes.html#eventmq.utils.classes.EMQPService.process_message">process_message() (eventmq.utils.classes.EMQPService method)</a>
   </dt>
 
       
@@ -536,7 +642,7 @@
 <table style="width: 100%" class="indextable genindextable"><tr>
   <td style="width: 33%" valign="top"><dl>
       
-  <dt><a href="utils.html#eventmq.utils.random_characters">random_characters() (in module eventmq.utils)</a>
+  <dt><a href="utils/index.html#eventmq.utils.random_characters">random_characters() (in module eventmq.utils)</a>
   </dt>
 
       
@@ -554,6 +660,10 @@
   </dt>
 
       
+  <dt><a href="router.html#eventmq.router.Router.received_disconnect">received_disconnect (eventmq.router.Router attribute)</a>
+  </dt>
+
+      
   <dt><a href="receiver.html#eventmq.receiver.Receiver">Receiver (class in eventmq.receiver)</a>
   </dt>
 
@@ -565,10 +675,18 @@
   <dt><a href="utils/classes.html#eventmq.utils.classes.ZMQReceiveMixin.recv_multipart">recv_multipart() (eventmq.utils.classes.ZMQReceiveMixin method)</a>
   </dt>
 
+      
+  <dt><a href="poller.html#eventmq.poller.Poller.register">register() (eventmq.poller.Poller method)</a>
+  </dt>
+
   </dl></td>
   <td style="width: 33%" valign="top"><dl>
       
-  <dt><a href="poller.html#eventmq.poller.Poller.register">register() (eventmq.poller.Poller method)</a>
+  <dt><a href="utils/classes.html#eventmq.utils.classes.EMQdeque.remove">remove() (eventmq.utils.classes.EMQdeque method)</a>
+  </dt>
+
+      
+  <dt><a href="jobmanager.html#eventmq.jobmanager.JobManager.request_queue">request_queue (eventmq.jobmanager.JobManager attribute)</a>
   </dt>
 
       
@@ -576,13 +694,19 @@
   </dt>
 
       
-  <dt><a href="jobmanager.html#eventmq.jobmanager.JobManager.reset">reset() (eventmq.jobmanager.JobManager method)</a>
+  <dt><a href="utils/classes.html#eventmq.utils.classes.EMQPService.reset">reset() (eventmq.utils.classes.EMQPService method)</a>
   </dt>
 
       
-  <dt><a href="utils/classes.html#eventmq.utils.classes.HeartbeatMixin.reset_heartbeat_counters">reset_heartbeat_counters() (eventmq.utils.classes.HeartbeatMixin method)</a>
+  <dt><a href="router.html#eventmq.router.Router.reset_heartbeat_counters">reset_heartbeat_counters() (eventmq.router.Router method)</a>
   </dt>
 
+      <dd><dl>
+        
+  <dt><a href="utils/classes.html#eventmq.utils.classes.HeartbeatMixin.reset_heartbeat_counters">(eventmq.utils.classes.HeartbeatMixin method)</a>
+  </dt>
+
+      </dl></dd>
       
   <dt><a href="router.html#eventmq.router.Router">Router (class in eventmq.router)</a>
   </dt>
@@ -598,6 +722,18 @@
 <table style="width: 100%" class="indextable genindextable"><tr>
   <td style="width: 33%" valign="top"><dl>
       
+  <dt><a href="client/messages.html#eventmq.client.messages.schedule">schedule() (in module eventmq.client.messages)</a>
+  </dt>
+
+      
+  <dt><a href="router.html#eventmq.router.Router.scheduler_queue">scheduler_queue (eventmq.router.Router attribute)</a>
+  </dt>
+
+      
+  <dt><a href="router.html#eventmq.router.Router.schedulers">schedulers (eventmq.router.Router attribute)</a>
+  </dt>
+
+      
   <dt><a href="utils/timeutils.html#eventmq.utils.timeutils.seconds_until">seconds_until() (in module eventmq.utils.timeutils)</a>
   </dt>
 
@@ -628,7 +764,7 @@
 
       </dl></dd>
       
-  <dt><a href="jobmanager.html#eventmq.jobmanager.JobManager.send_inform">send_inform() (eventmq.jobmanager.JobManager method)</a>
+  <dt><a href="utils/classes.html#eventmq.utils.classes.EMQPService.send_inform">send_inform() (eventmq.utils.classes.EMQPService method)</a>
   </dt>
 
   </dl></td>
@@ -646,6 +782,14 @@
   </dt>
 
       
+  <dt><a href="client/messages.html#eventmq.client.messages.send_schedule_request">send_schedule_request() (in module eventmq.client.messages)</a>
+  </dt>
+
+      
+  <dt><a href="router.html#eventmq.router.Router.send_schedulers_heartbeats">send_schedulers_heartbeats() (eventmq.router.Router method)</a>
+  </dt>
+
+      
   <dt><a href="router.html#eventmq.router.Router.send_workers_heartbeats">send_workers_heartbeats() (eventmq.router.Router method)</a>
   </dt>
 
@@ -654,12 +798,16 @@
   </dt>
 
       
-  <dt><a href="jobmanager.html#eventmq.jobmanager.JobManager.start">start() (eventmq.jobmanager.JobManager method)</a>
+  <dt><a href="router.html#eventmq.router.Router.sighup_handler">sighup_handler() (eventmq.router.Router method)</a>
+  </dt>
+
+      
+  <dt><a href="router.html#eventmq.router.Router.start">start() (eventmq.router.Router method)</a>
   </dt>
 
       <dd><dl>
         
-  <dt><a href="router.html#eventmq.router.Router.start">(eventmq.router.Router method)</a>
+  <dt><a href="utils/classes.html#eventmq.utils.classes.EMQPService.start">(eventmq.utils.classes.EMQPService method)</a>
   </dt>
 
       </dl></dd>
@@ -689,6 +837,10 @@
   </dt>
 
       </dl></dd>
+      
+  <dt><a href="exceptions.html#eventmq.exceptions.UnknownQueueError">UnknownQueueError</a>
+  </dt>
+
   </dl></td>
   <td style="width: 33%" valign="top"><dl>
       
@@ -708,9 +860,15 @@
   </dl></td>
   <td style="width: 33%" valign="top"><dl>
       
-  <dt><a href="router.html#eventmq.router.Router.workers">workers (eventmq.router.Router attribute)</a>
+  <dt><a href="jobmanager.html#eventmq.jobmanager.JobManager.workers">workers (eventmq.jobmanager.JobManager attribute)</a>
   </dt>
 
+      <dd><dl>
+        
+  <dt><a href="router.html#eventmq.router.Router.workers">(eventmq.router.Router attribute)</a>
+  </dt>
+
+      </dl></dd>
   </dl></td>
 </tr></table>
 
@@ -728,6 +886,10 @@
 
       </dl></dd>
       
+  <dt><a href="utils/index.html#eventmq.utils.zero_index_cmp">zero_index_cmp() (in module eventmq.utils)</a>
+  </dt>
+
+      
   <dt><a href="utils/classes.html#eventmq.utils.classes.ZMQReceiveMixin">ZMQReceiveMixin (class in eventmq.utils.classes)</a>
   </dt>