ThreadPoolExecutor in BrokerService throws unneeded exception

new RejectedExecutionHandler() {
    @Override
    public void rejectedExecution(final Runnable r, final ThreadPoolExecutor executor) {
       try{ 
          executor.getQueue().offer(r, 60, TimeUnit.SECONDS); 
       }
       catch (InterruptedException e) { 
         throw new RejectedExecutionException("Interrupted waiting for BrokerService.worker"); 
       }
       throw new RejectedExecutionException("Timed Out while attempting to enqueue Task.");
    }
 }

// заполнитель кода

public void rejectedExecution(final Runnable r, final ThreadPoolExecutor executor) {
     try { 
          if (!executor.getQueue().offer(r, 60, TimeUnit.SECONDS)) {
              throw new RejectedExecutionException("Timed Out while attempting to enqueue Task."); 
          }
     }
     catch (InterruptedException e){
           throw new RejectedExecutionException("Interrupted waiting for BrokerService.worker");
     }
}