Reformat with sbt-java-formatter 0.8.0

Executed command: sbt javafmtAll
apache · Apr 7, 2024 · 5791799 · 5791799
1 parent 86b8fe1
commit 5791799
Show file tree

Hide file tree

Showing 9 changed files with 61 additions and 72 deletions.
diff --git a/core-test/src/test/java/org/apache/pekko/projection/ProjectionBehaviorCompileTest.java b/core-test/src/test/java/org/apache/pekko/projection/ProjectionBehaviorCompileTest.java
@@ -13,21 +13,18 @@
 
 package org.apache.pekko.projection;
 
+import java.time.Duration;
 import org.apache.pekko.Done;
-import org.apache.pekko.NotUsed;
 import org.apache.pekko.actor.testkit.typed.javadsl.ActorTestKit;
 import org.apache.pekko.actor.typed.ActorRef;
 import org.apache.pekko.actor.typed.ActorSystem;
 import org.apache.pekko.projection.internal.ActorHandlerInit;
 import org.apache.pekko.projection.internal.NoopStatusObserver;
-import org.apache.pekko.projection.internal.ProjectionSettings;
 import org.apache.pekko.stream.scaladsl.Source;
 import scala.Option;
 import scala.concurrent.Future;
 import scala.concurrent.duration.FiniteDuration;
 
-import java.time.Duration;
-
 /** Compile test: this class serves only for exercising the Java API. */
 public class ProjectionBehaviorCompileTest {
 

diff --git a/examples/src/test/java/jdocs/eventsourced/ShoppingCart.java b/examples/src/test/java/jdocs/eventsourced/ShoppingCart.java
@@ -13,6 +13,10 @@
 
 package jdocs.eventsourced;
 
+import com.fasterxml.jackson.annotation.JsonCreator;
+import java.time.Duration;
+import java.time.Instant;
+import java.util.*;
 import org.apache.pekko.actor.typed.ActorRef;
 import org.apache.pekko.actor.typed.ActorSystem;
 import org.apache.pekko.actor.typed.Behavior;
@@ -27,11 +31,6 @@
 import org.apache.pekko.persistence.typed.javadsl.EventSourcedBehaviorWithEnforcedReplies;
 import org.apache.pekko.persistence.typed.javadsl.ReplyEffect;
 import org.apache.pekko.persistence.typed.javadsl.RetentionCriteria;
-import com.fasterxml.jackson.annotation.JsonCreator;
-
-import java.time.Duration;
-import java.time.Instant;
-import java.util.*;
 
 /**
  * This is an event sourced actor. It has a state, {@link ShoppingCart.State}, which stores the

diff --git a/examples/src/test/java/jdocs/guide/EventGeneratorApp.java b/examples/src/test/java/jdocs/guide/EventGeneratorApp.java
@@ -14,6 +14,14 @@
 // #guideEventGeneratorApp
 package jdocs.guide;
 
+import com.typesafe.config.Config;
+import com.typesafe.config.ConfigFactory;
+import java.time.Duration;
+import java.time.Instant;
+import java.util.*;
+import java.util.stream.Collectors;
+import java.util.stream.IntStream;
+import java.util.stream.Stream;
 import org.apache.pekko.actor.typed.ActorSystem;
 import org.apache.pekko.actor.typed.Behavior;
 import org.apache.pekko.actor.typed.javadsl.Behaviors;
@@ -28,18 +36,9 @@
 import org.apache.pekko.persistence.typed.javadsl.EventSourcedBehavior;
 import org.apache.pekko.stream.javadsl.Sink;
 import org.apache.pekko.stream.javadsl.Source;
-import com.typesafe.config.Config;
-import com.typesafe.config.ConfigFactory;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.time.Duration;
-import java.time.Instant;
-import java.util.*;
-import java.util.stream.Collectors;
-import java.util.stream.IntStream;
-import java.util.stream.Stream;
-
 /**
  * Generate a shopping cart every 1 second and check it out. Each cart will contain a variety of
  * `ItemAdded`, `ItemQuantityAdjusted` and `ItemRemoved` events preceding the the cart `Checkout`

diff --git a/examples/src/test/java/jdocs/guide/ItemPopularityProjectionHandler.java b/examples/src/test/java/jdocs/guide/ItemPopularityProjectionHandler.java
@@ -14,16 +14,15 @@
 // #guideProjectionHandler
 package jdocs.guide;
 
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.CompletionStage;
 import org.apache.pekko.Done;
 import org.apache.pekko.actor.typed.ActorSystem;
 import org.apache.pekko.projection.eventsourced.EventEnvelope;
 import org.apache.pekko.projection.javadsl.Handler;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.CompletionStage;
-
 public class ItemPopularityProjectionHandler
     extends Handler<EventEnvelope<ShoppingCartEvents.Event>> {
   public final int LogInterval = 10;

diff --git a/examples/src/test/java/jdocs/guide/ItemPopularityProjectionRepository.java b/examples/src/test/java/jdocs/guide/ItemPopularityProjectionRepository.java
@@ -14,11 +14,10 @@
 // #guideProjectionRepo
 package jdocs.guide;
 
-import org.apache.pekko.Done;
-import org.apache.pekko.stream.connectors.cassandra.javadsl.CassandraSession;
-
 import java.util.Optional;
 import java.util.concurrent.CompletionStage;
+import org.apache.pekko.Done;
+import org.apache.pekko.stream.connectors.cassandra.javadsl.CassandraSession;
 
 interface ItemPopularityProjectionRepository {
   CompletionStage<Done> update(String itemId, int delta);

diff --git a/examples/src/test/java/jdocs/guide/ShoppingCartClusterApp.java b/examples/src/test/java/jdocs/guide/ShoppingCartClusterApp.java
@@ -14,20 +14,20 @@
 // #guideClusterSetup
 package jdocs.guide;
 
+import com.typesafe.config.Config;
+import com.typesafe.config.ConfigFactory;
 import org.apache.pekko.actor.typed.ActorSystem;
 import org.apache.pekko.actor.typed.javadsl.Behaviors;
 import org.apache.pekko.cluster.sharding.typed.javadsl.ShardedDaemonProcess;
-import org.apache.pekko.projection.ProjectionBehavior;
-import org.apache.pekko.projection.eventsourced.EventEnvelope;
-import com.typesafe.config.Config;
-import com.typesafe.config.ConfigFactory;
 import org.apache.pekko.persistence.cassandra.query.javadsl.CassandraReadJournal;
 import org.apache.pekko.persistence.query.Offset;
-import org.apache.pekko.projection.eventsourced.javadsl.EventSourcedProvider;
-import org.apache.pekko.projection.javadsl.SourceProvider;
+import org.apache.pekko.projection.ProjectionBehavior;
 import org.apache.pekko.projection.ProjectionId;
 import org.apache.pekko.projection.cassandra.javadsl.CassandraProjection;
+import org.apache.pekko.projection.eventsourced.EventEnvelope;
+import org.apache.pekko.projection.eventsourced.javadsl.EventSourcedProvider;
 import org.apache.pekko.projection.javadsl.AtLeastOnceProjection;
+import org.apache.pekko.projection.javadsl.SourceProvider;
 import org.apache.pekko.stream.connectors.cassandra.javadsl.CassandraSession;
 import org.apache.pekko.stream.connectors.cassandra.javadsl.CassandraSessionRegistry;
 

diff --git a/examples/src/test/java/jdocs/jdbc/JdbcHibernateTest.java b/examples/src/test/java/jdocs/jdbc/JdbcHibernateTest.java
@@ -13,6 +13,15 @@
 
 package jdocs.jdbc;
 
+import static org.junit.Assert.assertEquals;
+
+import com.typesafe.config.Config;
+import com.typesafe.config.ConfigFactory;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.UUID;
+import java.util.concurrent.TimeUnit;
 import org.apache.pekko.NotUsed;
 import org.apache.pekko.actor.testkit.typed.javadsl.LogCapturing;
 import org.apache.pekko.actor.testkit.typed.javadsl.TestKitJunitResource;
@@ -23,11 +32,9 @@
 import org.apache.pekko.projection.jdbc.internal.JdbcSettings;
 import org.apache.pekko.projection.jdbc.javadsl.JdbcHandler;
 import org.apache.pekko.projection.jdbc.javadsl.JdbcProjection;
-import org.apache.pekko.projection.testkit.javadsl.TestSourceProvider;
 import org.apache.pekko.projection.testkit.javadsl.ProjectionTestKit;
+import org.apache.pekko.projection.testkit.javadsl.TestSourceProvider;
 import org.apache.pekko.stream.javadsl.Source;
-import com.typesafe.config.Config;
-import com.typesafe.config.ConfigFactory;
 import org.junit.BeforeClass;
 import org.junit.ClassRule;
 import org.junit.Rule;
@@ -37,14 +44,6 @@
 import scala.concurrent.Await;
 import scala.concurrent.Future;
 
-import java.util.Arrays;
-import java.util.HashMap;
-import java.util.Map;
-import java.util.UUID;
-import java.util.concurrent.TimeUnit;
-
-import static org.junit.Assert.assertEquals;
-
 public class JdbcHibernateTest extends JUnitSuite {
   private static final Map<String, Object> configuration = new HashMap<>();
 

diff --git a/jdbc/src/test/java/org/apache/pekko/projection/jdbc/JdbcProjectionTest.java b/jdbc/src/test/java/org/apache/pekko/projection/jdbc/JdbcProjectionTest.java
@@ -13,6 +13,24 @@
 
 package org.apache.pekko.projection.jdbc;
 
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertTrue;
+
+import com.typesafe.config.Config;
+import com.typesafe.config.ConfigFactory;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.SQLException;
+import java.time.Duration;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.UUID;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
+import java.util.function.Predicate;
+import java.util.function.Supplier;
 import org.apache.pekko.Done;
 import org.apache.pekko.NotUsed;
 import org.apache.pekko.actor.testkit.typed.javadsl.LogCapturing;
@@ -33,8 +51,6 @@
 import org.apache.pekko.stream.javadsl.FlowWithContext;
 import org.apache.pekko.stream.javadsl.Source;
 import org.apache.pekko.stream.testkit.TestSubscriber;
-import com.typesafe.config.Config;
-import com.typesafe.config.ConfigFactory;
 import org.junit.BeforeClass;
 import org.junit.ClassRule;
 import org.junit.Rule;
@@ -45,23 +61,6 @@
 import scala.concurrent.Await;
 import scala.concurrent.Future;
 
-import java.sql.Connection;
-import java.sql.DriverManager;
-import java.sql.SQLException;
-import java.time.Duration;
-import java.util.Arrays;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.UUID;
-import java.util.concurrent.CountDownLatch;
-import java.util.concurrent.TimeUnit;
-import java.util.function.Predicate;
-import java.util.function.Supplier;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertTrue;
-
 public class JdbcProjectionTest extends JUnitSuite {
 
   private static final Map<String, Object> configuration = new HashMap<>();

diff --git a/testkit/src/test/java/org/apache/pekko/projection/testkit/javadsl/ProjectionTestKitTest.java b/testkit/src/test/java/org/apache/pekko/projection/testkit/javadsl/ProjectionTestKitTest.java
@@ -13,17 +13,25 @@
 
 package org.apache.pekko.projection.testkit.javadsl;
 
+import static org.junit.Assert.assertEquals;
+
+import java.time.Duration;
+import java.util.List;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.CompletionStage;
+import java.util.function.Predicate;
+import java.util.stream.Collectors;
+import java.util.stream.IntStream;
 import org.apache.pekko.Done;
 import org.apache.pekko.NotUsed;
 import org.apache.pekko.actor.testkit.typed.javadsl.TestKitJunitResource;
 import org.apache.pekko.actor.typed.ActorSystem;
 import org.apache.pekko.japi.function.Function;
 import org.apache.pekko.projection.Projection;
 import org.apache.pekko.projection.ProjectionId;
-import org.apache.pekko.projection.internal.ActorHandlerInit;
-import org.apache.pekko.projection.internal.ProjectionSettings;
 import org.apache.pekko.projection.RunningProjection;
 import org.apache.pekko.projection.StatusObserver;
+import org.apache.pekko.projection.internal.ActorHandlerInit;
 import org.apache.pekko.projection.internal.NoopStatusObserver;
 import org.apache.pekko.stream.DelayOverflowStrategy;
 import org.apache.pekko.stream.KillSwitches;
@@ -41,16 +49,6 @@
 import scala.concurrent.Future;
 import scala.concurrent.duration.FiniteDuration;
 
-import java.time.Duration;
-import java.util.List;
-import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.CompletionStage;
-import java.util.function.Predicate;
-import java.util.stream.Collectors;
-import java.util.stream.IntStream;
-
-import static org.junit.Assert.assertEquals;
-
 public class ProjectionTestKitTest extends JUnitSuite {
 
   private final List<Integer> elements =