From 5e222214b68fa72bc75665392fc5428f1275815d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Johan=20Andr=C3=A9n?= Date: Thu, 11 Jun 2020 16:57:32 +0200 Subject: [PATCH] Debug log for stashing while awaiting lease --- .../src/main/scala/akka/cluster/sharding/Shard.scala | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) 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 7303b5c409..c7765aa331 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 @@ -489,7 +489,9 @@ private[akka] class Shard( tryGetLease(lease.get) case ll: LeaseLost => receiveLeaseLost(ll) - case _ => + case msg => + if (verboseDebug) + log.debug("Got msg of type [{}] from [{}] while waiting for lease, stashing", msg.getClass, sender()) stash() } @@ -524,7 +526,10 @@ private[akka] class Shard( loadingEntityIdsFailed() case msg => if (verboseDebug) - log.debug("Got msg of type [{}] from [{}] while waiting for remember entitites", msg.getClass, sender()) + log.debug( + "Got msg of type [{}] from [{}] while waiting for remember entities, stashing", + msg.getClass, + sender()) stash() }