You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by en...@apache.org on 2024/04/07 10:19:15 UTC
(pekko-projection) branch main updated (f83e999 -> 42a206c)
This is an automated email from the ASF dual-hosted git repository.
engelen pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-projection.git
from f83e999 pin-jackson-2.16 (#146)
new 86b8fe1 Update sbt-java-formatter to 0.8.0
new 5791799 Reformat with sbt-java-formatter 0.8.0
new 42a206c Add 'Reformat with sbt-java-formatter 0.8.0' to .git-blame-ignore-revs
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.git-blame-ignore-revs | 3 ++
.../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 +++++++++++-----------
project/plugins.sbt | 2 +-
.../testkit/javadsl/ProjectionTestKitTest.java | 22 ++++++-------
11 files changed, 65 insertions(+), 73 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org
(pekko-projection) 03/03: Add 'Reformat with sbt-java-formatter 0.8.0' to .git-blame-ignore-revs
Posted by en...@apache.org.
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 42a206cca78010496f1246e34e449c4e08204a2f
Author: scala-steward-asf[bot] <14...@users.noreply.github.com>
AuthorDate: Sun Apr 7 09:04:08 2024 +0000
Add 'Reformat with sbt-java-formatter 0.8.0' to .git-blame-ignore-revs
---
.git-blame-ignore-revs | 3 +++
1 file changed, 3 insertions(+)
diff --git a/.git-blame-ignore-revs b/.git-blame-ignore-revs
index 220aed3..092d3d8 100644
--- a/.git-blame-ignore-revs
+++ b/.git-blame-ignore-revs
@@ -4,3 +4,6 @@ af0dc3cc8635a1f5a7760bbdcc6259559d70c77a
# manual
11b119182338cb43cd45f5849684818be61ee493
ebead18d8114832ebe4f9d7196686af087fb2507
+
+# Scala Steward: Reformat with sbt-java-formatter 0.8.0
+74fc17aeef821e6a453862f3c0cfe48ff99b2dc4
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org
(pekko-projection) 02/03: Reformat with sbt-java-formatter 0.8.0
Posted by en...@apache.org.
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] <14...@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: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org
(pekko-projection) 01/03: Update sbt-java-formatter to 0.8.0
Posted by en...@apache.org.
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 86b8fe141806dfc454be9e3a1a2708ec8c7efabf
Author: scala-steward-asf[bot] <14...@users.noreply.github.com>
AuthorDate: Sun Apr 7 09:03:49 2024 +0000
Update sbt-java-formatter to 0.8.0
---
project/plugins.sbt | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/project/plugins.sbt b/project/plugins.sbt
index c9addb3..fec27a3 100644
--- a/project/plugins.sbt
+++ b/project/plugins.sbt
@@ -8,7 +8,7 @@
*/
addSbtPlugin("org.scalameta" % "sbt-scalafmt" % "2.5.2")
-addSbtPlugin("com.lightbend.sbt" % "sbt-java-formatter" % "0.7.0")
+addSbtPlugin("com.lightbend.sbt" % "sbt-java-formatter" % "0.8.0")
addSbtPlugin("de.heikoseeberger" % "sbt-header" % "5.10.0")
addSbtPlugin("com.github.sbt" % "sbt-dynver" % "5.0.1")
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org