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 <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
