executor.setRejectedExecutionHandler(new RejectedExecutionHandler() {

      @Override
      public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
        try {
          e.getQueue().put(r);
        } catch (InterruptedException ie) {
          throw new RejectedExecutionException(ie);
        }
      }
    })