@@ -236,39 +236,47 @@ private static Mono<Void> createApplication(
236236 .memory (64 )
237237 .name (name )
238238 .path (path )
239- .noStart (false )
239+ .noStart (false ));
240240 }
241241
242242 @ Test
243243 public void updateReadinessHealthCheckType () throws IOException {
244244 String applicationName = this .nameFactory .getApplicationName ();
245- Path path = new ClassPathResource ("test-application.zip" ).getFile ().toPath ();
245+ Path path = new ClassPathResource ("test-application.zip" ).getFile ().toPath ();
246246
247247 createApplication (this .cloudFoundryOperations , applicationName , path )
248- .then (getApplicationId (this .cloudFoundryOperations , applicationName ))
249- .flatMap (applicationId -> getProcessId (this .cloudFoundryClient , applicationId ))
250- .flatMap (processId -> this .cloudFoundryClient .processes ()
251- .update (UpdateProcessRequest .builder ()
252- .readinessHealthCheck (ReadinessHealthCheck
253- .builder ()
254- .data (Data
255- .builder ()
256- .endpoint ("/test_endpoint" )
257- .invocationTimeout (1 )
258- .interval (2 )
259- .build ())
260- .type (ReadinessHealthCheckType .PORT )
261- .build ())
262- .processId (processId )
263- .build ())
264- .then (Mono .just (processId )))
265- .flatMap (processId -> requestGetProcess (this .cloudFoundryClient , processId ))
266- .map (GetProcessResponse ::getReadinessHealthCheck )
267- .map (ReadinessHealthCheck ::getType )
268- .as (StepVerifier ::create )
269- .expectNext (ReadinessHealthCheckType .PORT )
270- .expectComplete ()
271- .verify (Duration .ofMinutes (5 ));
248+ .then (getApplicationId (this .cloudFoundryOperations , applicationName ))
249+ .flatMap (applicationId -> getProcessId (this .cloudFoundryClient , applicationId ))
250+ .flatMap (
251+ processId ->
252+ this .cloudFoundryClient
253+ .processes ()
254+ .update (
255+ UpdateProcessRequest .builder ()
256+ .readinessHealthCheck (
257+ ReadinessHealthCheck .builder ()
258+ .data (
259+ Data .builder ()
260+ .endpoint (
261+ "/test_endpoint" )
262+ .invocationTimeout (
263+ 1 )
264+ .interval (2 )
265+ .build ())
266+ .type (
267+ ReadinessHealthCheckType
268+ .PORT )
269+ .build ())
270+ .processId (processId )
271+ .build ())
272+ .then (Mono .just (processId )))
273+ .flatMap (processId -> requestGetProcess (this .cloudFoundryClient , processId ))
274+ .map (GetProcessResponse ::getReadinessHealthCheck )
275+ .map (ReadinessHealthCheck ::getType )
276+ .as (StepVerifier ::create )
277+ .expectNext (ReadinessHealthCheckType .PORT )
278+ .expectComplete ()
279+ .verify (Duration .ofMinutes (5 ));
272280 }
273281
274282 private static Mono <String > getApplicationId (
0 commit comments