final void rejectAsyncResults(@NotNull ExceptionHandler exceptionHandler) {
    if (!messageCallbackMap.isEmpty()) {
      for (AsyncPromise<?> promise : messageCallbackMap.values()) {
        try {
          promise.setError("rejected");
        }
        catch (Throwable e) {
          exceptionHandler.exceptionCaught(e);
        }
      }
    }
  }
final void rejectAsyncResults(@NotNull ExceptionHandler exceptionHandler)