code: @Override
      public void end(final boolean now) {
          this.state.set(SHUTDOWN);
          this.jedisPubSub.unsubscribe();
          if (now) {
              final Thread workerThread = this.threadRef.get();
              if (workerThread != null) {
                  workerThread.interrupt();
              }
          }
      }
docs: {@inheritDoc}