code: def _mq_callback(self, message):
          
          while threading.active_count() > settings.settings['bash_runnable_count'] + self.initial_thread_count:
              time.sleep(0.1)
  
          t = BashRunnable(self.logger, message, self.consumer, self.performance_tracker)
          t.daemon = True
          t.start()
docs: reads JSON request from the mq message and delivers it for processing