reformatted code

Author: fcannizzohz

testing/src/main/java/com/hazelcast/samples/testing/HzOrderService.java

@@ -11,21 +11,6 @@
 public class HzOrderService
         implements OrderService {
 
-    static class OrderUpdatedListener
-            implements EntryUpdatedListener<String, Order>, Serializable {
-
-        private final Consumer<Order> listener;
-
-        OrderUpdatedListener(Consumer<Order> listener) {
-            this.listener = listener;
-        }
-
-        @Override
-        public void entryUpdated(EntryEvent<String, Order> event) {
-            listener.accept(event.getValue());
-        }
-    }
-
     private final HazelcastInstance instance;
 
     public HzOrderService(HazelcastInstance hz) {
@@ -66,5 +51,20 @@ public Order getOrder(String id) {
     public void updateOrder(Order order) {
         orderMap().put(order.id(), order);
     }
+
+    static class OrderUpdatedListener
+            implements EntryUpdatedListener<String, Order>, Serializable {
+
+        private final Consumer<Order> listener;
+
+        OrderUpdatedListener(Consumer<Order> listener) {
+            this.listener = listener;
+        }
+
+        @Override
+        public void entryUpdated(EntryEvent<String, Order> event) {
+            listener.accept(event.getValue());
+        }
+    }
 }
 

testing/src/test/java/com/hazelcast/samples/testing/junit5/OrderEnrichmentPipelineTest.java

@@ -85,7 +85,6 @@ void streamingEnrichmentWithInlineAssertion() {
         Job job = instance.getJet().newJob(pipeline);
 
         // The assertion will stop the job automatically via AssertionCompletedException by assertCollectedEventually
-        assertThatThrownBy(job::join)
-                .hasRootCauseInstanceOf(AssertionCompletedException.class);
+        assertThatThrownBy(job::join).hasRootCauseInstanceOf(AssertionCompletedException.class);
     }
 }

testing/src/test/java/com/hazelcast/samples/testing/samples/junit4/FlakyTest.java

@@ -49,7 +49,7 @@ public void testFlakyBehavior() {
         map.put("key", 0);
 
         boolean alwaysFail = true;
-        if(alwaysFail) {
+        if (alwaysFail) {
             // simulate intermittent behavior: succeed only half the time
             if (System.nanoTime() % 2 == 0) {
                 map.put("key", counter.incrementAndGet());

testing/src/test/java/com/hazelcast/samples/testing/samples/junit4/MyClusterTest.java

@@ -11,7 +11,6 @@
 import org.junit.Test;
 import org.junit.runner.RunWith;
 
-import java.util.Arrays;
 import java.util.concurrent.atomic.AtomicLong;
 
 import static org.assertj.core.api.Assertions.assertThat;

testing/src/test/java/com/hazelcast/samples/testing/samples/junit4/MyMapListenerTest.java

@@ -38,7 +38,7 @@ public void updateTriggersListener() {
             // verify the listener received the update
             verify(mockListener, timeout(1000).times(1)).entryUpdated(any(EntryEvent.class));
         } finally {
-            if(instance != null) {
+            if (instance != null) {
                 instance.shutdown();
             }
         }