identing and reorering imports

Author: pedrolopes9-7

spring-cloud-modules/spring-cloud-openfeign-2/src/main/java/com/baeldung/cloud/openfeign/completablefuturefeignclient/PurchaseService.java

@@ -1,14 +1,15 @@
 package com.baeldung.cloud.openfeign.completablefuturefeignclient;
 
-import feign.FeignException;
-import feign.RetryableException;
-import org.springframework.stereotype.Service;
-
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
 
+import org.springframework.stereotype.Service;
+
+import feign.FeignException;
+import feign.RetryableException;
+
 @Service
 public class PurchaseService {
 
@@ -22,27 +23,27 @@ public PurchaseService(PaymentMethodClient paymentMethodClient, ReportClient rep
 
     public String executePurchase(String siteId) throws ExecutionException, InterruptedException {
         CompletableFuture<String> paymentMethodsFuture = CompletableFuture.supplyAsync(() -> paymentMethodClient.getAvailablePaymentMethods(siteId))
-                .orTimeout(400, TimeUnit.MILLISECONDS)
-                .exceptionally(ex -> {
-                    if (ex.getCause() instanceof FeignException && ((FeignException) ex.getCause()).status() == 404) {
-                        return "cash";
-                    }
+            .orTimeout(400, TimeUnit.MILLISECONDS)
+            .exceptionally(ex -> {
+                if (ex.getCause() instanceof FeignException && ((FeignException) ex.getCause()).status() == 404) {
+                    return "cash";
+                }
 
-                    if (ex.getCause() instanceof RetryableException) {
-                        // handle REST timeout
-                        throw new RuntimeException("REST call network timeout!");
-                    }
+                if (ex.getCause() instanceof RetryableException) {
+                    // handle REST timeout
+                    throw new RuntimeException("REST call network timeout!");
+                }
 
-                    if (ex instanceof TimeoutException) {
-                        // handle thread timeout
-                        throw new RuntimeException("Thread timeout!", ex);
-                    }
+                if (ex instanceof TimeoutException) {
+                    // handle thread timeout
+                    throw new RuntimeException("Thread timeout!", ex);
+                }
 
-                    throw new RuntimeException("Unrecoverable error!", ex);
-                });
+                throw new RuntimeException("Unrecoverable error!", ex);
+            });
 
         CompletableFuture.runAsync(() -> reportClient.sendReport("Purchase Order Report"))
-                .orTimeout(400, TimeUnit.MILLISECONDS);
+            .orTimeout(400, TimeUnit.MILLISECONDS);
 
         return String.format("Purchase executed with payment method %s", paymentMethodsFuture.get());
     }

spring-cloud-modules/spring-cloud-openfeign-2/src/test/java/com/baeldung/cloud/openfeign/completablefuturefeignclient/PurchaseServiceIntegrationTest.java

@@ -2,6 +2,7 @@
 
 import com.baeldung.cloud.openfeign.ExampleApplication;
 import com.github.tomakehurst.wiremock.WireMockServer;
+
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Disabled;
@@ -43,8 +44,7 @@ public void startWireMockServer() {
         configureFor("localhost", 8083);
         wireMockServer.start();
 
-        stubFor(post(urlEqualTo("/reports"))
-                .willReturn(aResponse().withStatus(HttpStatus.OK.value())));
+        stubFor(post(urlEqualTo("/reports")).willReturn(aResponse().withStatus(HttpStatus.OK.value())));
     }
 
     @AfterEach
@@ -53,10 +53,9 @@ public void stopWireMockServer() {
     }
 
     @Test
-    void givenRestCalls_whenBothReturnsOk_thenReturnCorrectResult()
-            throws ExecutionException, InterruptedException {
-        stubFor(get(urlEqualTo("/payment_methods?site_id=BR"))
-                .willReturn(aResponse().withStatus(HttpStatus.OK.value()).withBody("credit_card")));
+    void givenRestCalls_whenBothReturnsOk_thenReturnCorrectResult() throws ExecutionException, InterruptedException {
+        stubFor(get(urlEqualTo("/payment_methods?site_id=BR")).willReturn(aResponse().withStatus(HttpStatus.OK.value())
+            .withBody("credit_card")));
 
         String result = purchaseService.executePurchase("BR");
 
@@ -65,10 +64,8 @@ void givenRestCalls_whenBothReturnsOk_thenReturnCorrectResult()
     }
 
     @Test
-    void givenRestCalls_whenPurchaseReturns404_thenReturnDefault()
-            throws ExecutionException, InterruptedException {
-        stubFor(get(urlEqualTo("/payment_methods?site_id=BR"))
-                .willReturn(aResponse().withStatus(HttpStatus.NOT_FOUND.value())));
+    void givenRestCalls_whenPurchaseReturns404_thenReturnDefault() throws ExecutionException, InterruptedException {
+        stubFor(get(urlEqualTo("/payment_methods?site_id=BR")).willReturn(aResponse().withStatus(HttpStatus.NOT_FOUND.value())));
 
         String result = purchaseService.executePurchase("BR");
 
@@ -79,8 +76,7 @@ void givenRestCalls_whenPurchaseReturns404_thenReturnDefault()
     @Test
     @Disabled
     void givenRestCalls_whenPurchaseCompletableFutureTimeout_thenThrowNewException() {
-        stubFor(get(urlEqualTo("/payment_methods?site_id=BR"))
-                .willReturn(aResponse().withFixedDelay(550)));
+        stubFor(get(urlEqualTo("/payment_methods?site_id=BR")).willReturn(aResponse().withFixedDelay(550)));
 
         Throwable error = assertThrows(ExecutionException.class, () -> purchaseService.executePurchase("BR"));
 
@@ -89,8 +85,7 @@ void givenRestCalls_whenPurchaseCompletableFutureTimeout_thenThrowNewException()
 
     @Test
     void givenRestCalls_whenPurchaseRequestWebTimeout_thenThrowNewException() {
-        stubFor(get(urlEqualTo("/payment_methods?site_id=BR"))
-                .willReturn(aResponse().withFixedDelay(250)));
+        stubFor(get(urlEqualTo("/payment_methods?site_id=BR")).willReturn(aResponse().withFixedDelay(250)));
 
         Throwable error = assertThrows(ExecutionException.class, () -> purchaseService.executePurchase("BR"));