@Override
    public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
      try {
        blockingQueue.put(r);
      } catch (InterruptedException ex) {
        Thread.currentThread().interrupt(); // preserve the state
        throw new RejectedExecutionException("interrupted", ex);
      }
    }
Used for P2P Reader Threads in ConnectionTable
geode-core/src/main/java/org/apache/geode/internal/logging/CoreLoggingExecutors.java