docs: private <T> Future<T> submitTaskToQueue(SQLQueueCallable<T> callable){
          if(acceptTasks.get()){
              return queue.submit(callable);
          } else {
              throw new RejectedExecutionException("Database is closed");
          }
      }