in pekko-sample-persistence-dc-java/src/main/java/sample/persistence/res/auction/AuctionEntity.java [183:205]
public static Behavior<Command> create(
ReplicaId replica,
String name,
Bid initialBid,
Instant closingAt,
boolean responsibleForClosing) {
return Behaviors.setup(
ctx ->
Behaviors.withTimers(
timers ->
ReplicatedEventSourcing.commonJournalConfig(
new ReplicationId("Auction", name, replica),
ALL_REPLICAS,
CassandraReadJournal.Identifier(),
replicationCtx ->
new AuctionEntity(
ctx,
replicationCtx,
timers,
initialBid,
closingAt,
responsibleForClosing))));
}