public void throwExceptionOn(String message) {
            throw exception;
          }
        };
    eventBus.register(subscriber);
    eventBus.post(EVENT);

    assertEquals("Cause should be available.", exception, handler.exception);
    assertEquals("EventBus should be available.", eventBus, handler.context.getEventBus());
    assertEquals("Event should be available.", EVENT, handler.context.getEvent());

       * UncheckedExecutionException, which has the stack trace from this thread and which has its
       * cause set to the underlying exception (which may be from another thread). If we someday
       * learn that some other exception besides IllegalArgumentException is common, then we could
       * add another special case to throw an instance of it, too.
       */
      throw e;
    }
  }

   */
  public void testLoadingExceptionWithCause() {
    Exception cause = new Exception();
    UncheckedExecutionException uee = new UncheckedExecutionException(cause);
    ExecutionException ee = new ExecutionException(cause);

    LoadingCache<Object, Object> cacheUnchecked =
        CacheBuilder.newBuilder().build(exceptionLoader(uee));

                        return ans;
                    }
                    break;
                case RESOLVER_WINS:
                case RESOLVER_BCAST:
                    if (element == RESOLVER_WINS && name.name != NbtAddress.MASTER_BROWSER_NAME && name.hexCode != 0x1d) {
                        request.addr = NbtAddress.getWINSAddress();
                        request.isBroadcast = false;

        try {
            // Execute operations to generate metrics
            for (int i = 0; i < 5; i++) {
                cbWithEnhanced.executeWithCircuitBreaker(() -> "success");
            }

            // Cause some failures
            for (int i = 0; i < 2; i++) {
                try {
                    cbWithEnhanced.executeWithCircuitBreaker(() -> {
                        throw new RuntimeException("failure");

    // again with a different route.
    if (e is SSLHandshakeException) {
      // If the problem was a CertificateException from the X509TrustManager,
      // do not retry.
      if (e.cause is CertificateException) {
        return false
      }
    }
    if (e is SSLPeerUnverifiedException) {
      // e.g. a certificate pinning error.
      return false
    }

             * global profile manager which is required to build a POM like a CLI invocation does. Failure to consider
             * the activated profiles can cause repo declarations to be lost which in turn will result in artifact
             * resolution failures, in particular when using the enhanced local repo which guards access to local files

Of course, there are some cases where there's no problem in running the previous steps multiple times, in that case, it's a lot easier to handle.

/// tip

Also, keep in mind that depending on your setup, in some cases you **might not even need any previous steps** before starting your application.

In that case, you wouldn't have to worry about any of this. 🤷

    @DisplayName("Test readDataWireFormat with IOException throws ArrayIndexOutOfBoundsException")
    void testReadDataWireFormatWithIOException() throws Exception {
        // Create an invalid security descriptor buffer that will cause ArrayIndexOutOfBoundsException
        byte[] buffer = new byte[4];

        // Set error code to 0
        setErrorCode(response, 0);

        // ArrayIndexOutOfBoundsException is thrown when buffer is too small

	case errors.Is(err, errFaultyDisk):
		state = madmin.DriveStateFaulty
	case errors.Is(err, errDriveIsRoot):
		state = madmin.DriveStateRootMount
	case err == nil:
		state = madmin.DriveStateOk
	default:
		state = fmt.Sprintf("%s (cause: %s)", madmin.DriveStateUnknown, err)
	}

	return
}

func getOnlineOfflineDisksStats(disksInfo []madmin.Disk) (onlineDisks, offlineDisks madmin.BackendDisks) {