This is an automated email from the ASF dual-hosted git repository.
engelen pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-projection.git
commit 5791799541ac7638c4e6cd687656a77f1885c9a3
Author: scala-steward-asf[bot]
<147768647+scala-steward-asf[bot]@users.noreply.github.com>
AuthorDate: Sun Apr 7 09:04:08 2024 +0000
Reformat with sbt-java-formatter 0.8.0
Executed command: sbt javafmtAll
---
.../projection/ProjectionBehaviorCompileTest.java | 5 +--
.../test/java/jdocs/eventsourced/ShoppingCart.java | 9 +++---
.../test/java/jdocs/guide/EventGeneratorApp.java | 17 +++++-----
.../guide/ItemPopularityProjectionHandler.java | 5 ++-
.../guide/ItemPopularityProjectionRepository.java | 5 ++-
.../java/jdocs/guide/ShoppingCartClusterApp.java | 12 +++----
.../test/java/jdocs/jdbc/JdbcHibernateTest.java | 21 ++++++------
.../pekko/projection/jdbc/JdbcProjectionTest.java | 37 +++++++++++-----------
.../testkit/javadsl/ProjectionTestKitTest.java | 22 ++++++-------
9 files changed, 61 insertions(+), 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
index 69850c4..8e185fd 100644
---
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
index 3801235..feffbbe 100644
--- 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.EventHandler;
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
index 45ff2cf..c6fd524 100644
--- 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.EventHandler;
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
index 9509f01..5cc03ec 100644
--- a/examples/src/test/java/jdocs/guide/ItemPopularityProjectionHandler.java
+++ b/examples/src/test/java/jdocs/guide/ItemPopularityProjectionHandler.java
@@ -14,6 +14,8 @@
// #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;
@@ -21,9 +23,6 @@ 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
index 87ce498..6375d98 100644
--- 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
index 2e44aeb..259099e 100644
--- 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
index 6bcf163..26b706b 100644
--- 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.JdbcOffsetStore;
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.Option;
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
index 2d05a2e..d7ed26d 100644
---
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.projection.testkit.javadsl.TestSourceProvider;
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.PartialFunction;
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
index d133eb8..3879431 100644
---
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,6 +13,15 @@
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;
@@ -20,10 +29,9 @@ 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.Option;
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 =
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
