diff --git a/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/Shard.scala b/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/Shard.scala index 6b421229f5..b2d2aea3e4 100644 --- a/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/Shard.scala +++ b/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/Shard.scala @@ -1061,7 +1061,7 @@ private[akka] class Shard( * of active entities. */ @InternalStableApi - def entityCreated(@unused id: EntityId): Int = entities.nrActiveEntities + def entityCreated(@unused id: EntityId): Int = entities.nrActiveEntities() // ===== buffering while busy saving a start or stop when remembering entities ===== def appendToMessageBuffer(id: EntityId, msg: Any, snd: ActorRef): Unit = { diff --git a/akka-persistence-typed-tests/src/test/java/jdocs/akka/persistence/typed/ReplicatedAuctionExampleTest.java b/akka-persistence-typed-tests/src/test/java/jdocs/akka/persistence/typed/ReplicatedAuctionExampleTest.java index e5b2497ddf..2401d1bfb9 100644 --- a/akka-persistence-typed-tests/src/test/java/jdocs/akka/persistence/typed/ReplicatedAuctionExampleTest.java +++ b/akka-persistence-typed-tests/src/test/java/jdocs/akka/persistence/typed/ReplicatedAuctionExampleTest.java @@ -90,7 +90,9 @@ public class ReplicatedAuctionExampleTest extends JUnitSuite { } // #setup -class AuctionEntity extends ReplicatedEventSourcedBehavior { +class AuctionEntity + extends ReplicatedEventSourcedBehavior< + AuctionEntity.Command, AuctionEntity.Event, AuctionEntity.AuctionState> { public static ReplicaId R1 = new ReplicaId("R1"); public static ReplicaId R2 = new ReplicaId("R2"); diff --git a/akka-persistence-typed-tests/src/test/scala/akka/persistence/typed/crdt/CounterSpec.scala b/akka-persistence-typed-tests/src/test/scala/akka/persistence/typed/crdt/CounterSpec.scala index 3d6a9468c9..54f4e7ab7d 100644 --- a/akka-persistence-typed-tests/src/test/scala/akka/persistence/typed/crdt/CounterSpec.scala +++ b/akka-persistence-typed-tests/src/test/scala/akka/persistence/typed/crdt/CounterSpec.scala @@ -44,8 +44,8 @@ object CounterSpec { case PlainCounter.Decrement => Effect.persist(Counter.Updated(-1)) case Get(replyTo) => - context.log.info("Get request. {} {}", state.value, state.value.longValue()) - replyTo ! state.value.longValue() + context.log.info("Get request. {} {}", state.value, state.value.longValue) + replyTo ! state.value.longValue Effect.none }, (counter, event) => {