You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by ph...@apache.org on 2026/05/06 09:51:15 UTC
(pekko-projection) 02/02: Reformat with sbt-java-formatter 0.12.0
This is an automated email from the ASF dual-hosted git repository.
Philippus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-projection.git
commit f1199727a44fe3dab472589b19615a6bdf56768d
Author: Philippus <ph...@gmail.com>
AuthorDate: Mon May 4 08:36:39 2026 +0200
Reformat with sbt-java-formatter 0.12.0
---
examples/src/test/java/jdocs/guide/ShoppingCartApp.java | 1 +
.../src/test/java/jdocs/jdbc/JdbcProjectionDocExample.java | 5 +++++
examples/src/test/java/jdocs/kafka/KafkaDocExample.java | 5 +++++
examples/src/test/java/jdocs/testkit/TestKitDocExample.java | 1 -
.../java/jdocs/cassandra/CassandraProjectionDocExample.java | 12 ++++++++----
.../src/test/java/jdocs/cassandra/WordCountDocExample.java | 4 +++-
6 files changed, 22 insertions(+), 6 deletions(-)
diff --git a/examples/src/test/java/jdocs/guide/ShoppingCartApp.java b/examples/src/test/java/jdocs/guide/ShoppingCartApp.java
index 9bf96ee..6fffd08 100644
--- a/examples/src/test/java/jdocs/guide/ShoppingCartApp.java
+++ b/examples/src/test/java/jdocs/guide/ShoppingCartApp.java
@@ -35,6 +35,7 @@ import org.apache.pekko.projection.cassandra.javadsl.CassandraProjection;
import org.apache.pekko.projection.javadsl.AtLeastOnceProjection;
import org.apache.pekko.stream.connectors.cassandra.javadsl.CassandraSession;
import org.apache.pekko.stream.connectors.cassandra.javadsl.CassandraSessionRegistry;
+
// #guideProjectionImports
// #guideSetup
diff --git a/examples/src/test/java/jdocs/jdbc/JdbcProjectionDocExample.java b/examples/src/test/java/jdocs/jdbc/JdbcProjectionDocExample.java
index 9b9b63e..e973472 100644
--- a/examples/src/test/java/jdocs/jdbc/JdbcProjectionDocExample.java
+++ b/examples/src/test/java/jdocs/jdbc/JdbcProjectionDocExample.java
@@ -64,6 +64,7 @@ class JdbcProjectionDocExample {
interface OrderRepository {
void save(EntityManager entityManager, Order order);
}
+
// #repository
@SuppressWarnings("Convert2Lambda")
@@ -108,6 +109,7 @@ class JdbcProjectionDocExample {
connection.close();
}
}
+
// #jdbc-session
// #handler
@@ -133,6 +135,7 @@ class JdbcProjectionDocExample {
}
}
}
+
// #handler
// #grouped-handler
@@ -162,6 +165,7 @@ class JdbcProjectionDocExample {
}
}
}
+
// #grouped-handler
ActorSystem<Void> system = ActorSystem.create(Behaviors.empty(), "Example");
@@ -169,6 +173,7 @@ class JdbcProjectionDocExample {
// #sourceProvider
SourceProvider<Offset, EventEnvelope<ShoppingCart.Event>> sourceProvider =
EventSourcedProvider.eventsByTag(system, CassandraReadJournal.Identifier(), "carts-1");
+
// #sourceProvider
{
diff --git a/examples/src/test/java/jdocs/kafka/KafkaDocExample.java b/examples/src/test/java/jdocs/kafka/KafkaDocExample.java
index ee15108..1d243e8 100644
--- a/examples/src/test/java/jdocs/kafka/KafkaDocExample.java
+++ b/examples/src/test/java/jdocs/kafka/KafkaDocExample.java
@@ -106,6 +106,7 @@ public interface KafkaDocExample {
state.put(word, newCount);
}
}
+
// #handler
// #wordSource
@@ -153,6 +154,7 @@ public interface KafkaDocExample {
return 0L;
}
}
+
// #wordSource
// #wordPublisher
@@ -187,6 +189,7 @@ public interface KafkaDocExample {
return done;
}
}
+
// #wordPublisher
static SourceProvider<MergeableOffset<Long>, ConsumerRecord<String, String>>
@@ -247,12 +250,14 @@ public interface KafkaDocExample {
wordRepository.increment(session.entityManager, word);
}
}
+
// #exactly-once-jdbc-handler
// #repository
interface WordRepository {
void increment(EntityManager entityManager, String word);
}
+
// #repository
static void IllustrateSendingToKafka() {
diff --git a/examples/src/test/java/jdocs/testkit/TestKitDocExample.java b/examples/src/test/java/jdocs/testkit/TestKitDocExample.java
index fcefaa6..b611f85 100644
--- a/examples/src/test/java/jdocs/testkit/TestKitDocExample.java
+++ b/examples/src/test/java/jdocs/testkit/TestKitDocExample.java
@@ -41,7 +41,6 @@ import java.util.stream.Stream;
// #testkit-duration
// #testkit-assertion-import
-import static org.junit.Assert.assertEquals;
// #testkit-assertion-import
diff --git a/integration-examples/src/test/java/jdocs/cassandra/CassandraProjectionDocExample.java b/integration-examples/src/test/java/jdocs/cassandra/CassandraProjectionDocExample.java
index 4f686fd..15d1d11 100644
--- a/integration-examples/src/test/java/jdocs/cassandra/CassandraProjectionDocExample.java
+++ b/integration-examples/src/test/java/jdocs/cassandra/CassandraProjectionDocExample.java
@@ -100,6 +100,7 @@ public interface CassandraProjectionDocExample {
}
}
}
+
// #handler
// #grouped-handler
@@ -124,6 +125,7 @@ public interface CassandraProjectionDocExample {
return CompletableFuture.completedFuture(Done.getInstance());
}
}
+
// #grouped-handler
public static void illustrateAtLeastOnce() {
@@ -266,6 +268,7 @@ public interface CassandraProjectionDocExample {
SourceProvider<Offset, EventEnvelope<ShoppingCart.Event>> sourceProvider(String tag) {
return EventSourcedProvider.eventsByTag(system, CassandraReadJournal.Identifier(), tag);
}
+
// #running-source-provider
// #running-projection
@@ -277,6 +280,7 @@ public interface CassandraProjectionDocExample {
ProjectionId.of("shopping-carts", tag), sourceProvider(tag), ShoppingCartHandler::new)
.withSaveOffset(saveOffsetAfterEnvelopes, saveOffsetAfterDuration);
}
+
// #running-projection
public IllustrateRunningWithShardedDaemon() {
@@ -334,7 +338,7 @@ public interface CassandraProjectionDocExample {
ClusterSingleton.get(system)
.init(
SingletonActor.of(
- ProjectionBehavior.create(projection1), projection1.projectionId().id())
+ ProjectionBehavior.create(projection1), projection1.projectionId().id())
.withStopMessage(ProjectionBehavior.stopMessage()));
// #running-with-singleton
}
@@ -406,8 +410,7 @@ public interface CassandraProjectionDocExample {
// #is-paused
ProjectionId projectionId = ProjectionId.of("shopping-carts", "carts-1");
- CompletionStage<Boolean> paused =
- ProjectionManagement.get(system).isPaused(projectionId);
+ CompletionStage<Boolean> paused = ProjectionManagement.get(system).isPaused(projectionId);
// #is-paused
}
@@ -419,7 +422,8 @@ public interface CassandraProjectionDocExample {
ProjectionManagement mgmt = ProjectionManagement.get(system);
CompletionStage<Done> pauseDone = mgmt.pause(projectionId);
CompletionStage<Done> migrationDone = pauseDone.thenCompose(notUsed -> someDataMigration());
- CompletionStage<Done> resumeDone = migrationDone.thenCompose(notUsed -> mgmt.resume(projectionId));
+ CompletionStage<Done> resumeDone =
+ migrationDone.thenCompose(notUsed -> mgmt.resume(projectionId));
// #pause-resume
}
diff --git a/integration-examples/src/test/java/jdocs/cassandra/WordCountDocExample.java b/integration-examples/src/test/java/jdocs/cassandra/WordCountDocExample.java
index 4d3c34e..61e53dd 100644
--- a/integration-examples/src/test/java/jdocs/cassandra/WordCountDocExample.java
+++ b/integration-examples/src/test/java/jdocs/cassandra/WordCountDocExample.java
@@ -18,7 +18,6 @@ import org.apache.pekko.actor.typed.ActorSystem;
import org.apache.pekko.actor.typed.SupervisorStrategy;
import org.apache.pekko.actor.typed.javadsl.AskPattern;
import org.apache.pekko.actor.typed.javadsl.StashBuffer;
-import org.apache.pekko.projection.cassandra.CassandraProjectionTest;
import org.apache.pekko.projection.javadsl.ActorHandler;
import org.apache.pekko.projection.javadsl.StatefulHandler;
@@ -80,6 +79,7 @@ public interface WordCountDocExample {
CompletionStage<Done> save(String id, String word, int count);
}
+
// #repository
public class CassandraWordCountRepository implements WordCountRepository {
@@ -174,6 +174,7 @@ public interface WordCountDocExample {
return 0L;
}
}
+
// #sourceProvider
interface IllustrateVariables {
@@ -309,6 +310,7 @@ public interface WordCountDocExample {
});
}
}
+
// #actorHandler
// #behaviorLoadingInitialState
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org