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

Sharding request-to-start but already started logging (#29545)

Browse source
This commit is contained in:
Johan Andrén 2020-09-02 14:18:44 +02:00 • committed by GitHub
parent 9b709df2d0
commit 192be028a0
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -772,7 +772,8 @@ private[akka] class Shard(
private def startEntity(entityId: EntityId, ackTo: Option[ActorRef]): Unit = { private def startEntity(entityId: EntityId, ackTo: Option[ActorRef]): Unit = {
entities.entityState(entityId) match { entities.entityState(entityId) match {
case Active(_) => case Active(_) =>
log.debug("Request to start entity [{}] (Already started)", entityId) if (verboseDebug)
log.debug("Request to start entity [{}] (Already started)", entityId)
touchLastMessageTimestamp(entityId) touchLastMessageTimestamp(entityId)
ackTo.foreach(_ ! ShardRegion.StartEntityAck(entityId, shardId)) ackTo.foreach(_ ! ShardRegion.StartEntityAck(entityId, shardId))
case _: RememberingStart => case _: RememberingStart =>