code: protected void checkPaused() throws IOException {
          if (this.paused.get()) {
              synchronized (this.paused) {
                  if (this.paused.get()) {
                      this.jedis.set(key(WORKER, this.name), pauseMsg());
                  }
                  while (this.paused.get()) {
                      try {
                          this.paused.wait();
                      } catch (InterruptedException ie) {
                          LOG.warn("Worker interrupted", ie);
                      }
                  }
                  this.jedis.del(key(WORKER, this.name));
              }
          }
      }
docs: Checks to see if worker is paused. If so, wait until unpaused.
  
  @throws IOException if there was an error creating the pause message