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