code: @Override
  	public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
  		int counts = rejectCounts.incrementAndGet();
  		if(logger.isWarnEnabled()) {
  			int t = counts % 100;
  			if (t == 0)
  			{
  				logger.warn(new StringBuilder().append("Task[Import DB Data to Elasticsearch] rejected  ").append(counts).append(" times.").toString());
  			}
  		}
  //
  		try {
  			executor.getQueue().put(r);
  		} catch (InterruptedException e1) {
  			throw new RejectedExecutionException(e1);
  		}
  	}
docs: Always log per 1000 mults rejects.
  @param r
  @param executor