raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

fix compilation errors

Browse source
This commit is contained in:
Patrik Nordwall 2020-09-03 12:48:53 +02:00
parent 4629cd44e4
commit bb985b82c6
3 changed files with 6 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-cluster-sharding/src/main/scala/akka/cluster/sharding/Shard.scala
View file

@ -1061,7 +1061,7 @@ private[akka] class Shard(
* of active entities. * of active entities.
*/ */
@InternalStableApi @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 ===== // ===== buffering while busy saving a start or stop when remembering entities =====
def appendToMessageBuffer(id: EntityId, msg: Any, snd: ActorRef): Unit = { def appendToMessageBuffer(id: EntityId, msg: Any, snd: ActorRef): Unit = {

4
akka-persistence-typed-tests/src/test/java/jdocs/akka/persistence/typed/ReplicatedAuctionExampleTest.java
View file

@ -90,7 +90,9 @@ public class ReplicatedAuctionExampleTest extends JUnitSuite {
} }
// #setup // #setup
class AuctionEntity extends ReplicatedEventSourcedBehavior<Command, Event, AuctionState> { class AuctionEntity
extends ReplicatedEventSourcedBehavior<
AuctionEntity.Command, AuctionEntity.Event, AuctionEntity.AuctionState> {
public static ReplicaId R1 = new ReplicaId("R1"); public static ReplicaId R1 = new ReplicaId("R1");
public static ReplicaId R2 = new ReplicaId("R2"); public static ReplicaId R2 = new ReplicaId("R2");

4
akka-persistence-typed-tests/src/test/scala/akka/persistence/typed/crdt/CounterSpec.scala
View file

@ -44,8 +44,8 @@ object CounterSpec {
case PlainCounter.Decrement => case PlainCounter.Decrement =>
Effect.persist(Counter.Updated(-1)) Effect.persist(Counter.Updated(-1))
case Get(replyTo) => case Get(replyTo) =>
context.log.info("Get request. {} {}", state.value, state.value.longValue()) context.log.info("Get request. {} {}", state.value, state.value.longValue)
replyTo ! state.value.longValue() replyTo ! state.value.longValue
Effect.none Effect.none
}, },
(counter, event) => { (counter, event) => {