operator/src/main/java/oracle/kubernetes/operator/calls/AsyncRequestStep.java
void onFailure(AsyncFiber fiber, ApiException ae, int statusCode, Map<String, List<String>> responseHeaders) {
      if (firstTimeResumed()) {
        if (statusCode != CallBuilder.NOT_FOUND && LOGGER.isFineEnabled()) {
          logFailure(ae, statusCode, responseHeaders);
        }

        helper.recycle(client);
        addResponseComponent(Component.createFor(
              RetryStrategy.class, retryStrategy,
              createFailure(requestParams, ae, statusCode).withResponseHeaders(responseHeaders)));
        fiber.resume(packet);
      }
    }
// add the failure into the packet and prepare to try again.
add the failure into the packet and prepare to try again.
add the failure into the packet and prepare to try again .
void onFailure(AsyncFiber fiber, ApiException ae, int statusCode, Map<String, List<String>> responseHeaders) {
      if (firstTimeResumed()) {
        if (statusCode != CallBuilder.NOT_FOUND && LOGGER.isFineEnabled()) {
          logFailure(ae, statusCode, responseHeaders);
        }
        helper.recycle(client);
        addResponseComponent(Component.createFor(
              RetryStrategy.class, retryStrategy,
              createFailure(requestParams, ae, statusCode).withResponseHeaders(responseHeaders)));
        fiber.resume(packet);
      }
    }
void onFailure ( AsyncFiber fiber , ApiException ae , int statusCode , Map < String , List < String > > responseHeaders ) { if ( firstTimeResumed ( ) ) { if ( statusCode != CallBuilder . NOT_FOUND && LOGGER . isFineEnabled ( ) ) { logFailure ( ae , statusCode , responseHeaders ) ; } helper . recycle ( client ) ; addResponseComponent ( Component . createFor ( RetryStrategy . class , retryStrategy , createFailure ( requestParams , ae , statusCode ) . withResponseHeaders ( responseHeaders ) ) ) ; fiber . resume ( packet ) ; } }
add the failure into the packet and prepare to try again.
add the failure into the packet and prepare to try again .