Make retry less aggressive by adding a delay (#134)

devsisters · Jul 18, 2024 · 28abde0 · 28abde0
1 parent 1510c21
commit 28abde0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/entities/src/main/scala/com/devsisters/shardcake/internal/EntityManager.scala b/entities/src/main/scala/com/devsisters/shardcake/internal/EntityManager.scala
@@ -130,7 +130,7 @@ private[shardcake] object EntityManager {
                        (replyId match {
                          case Some(replyId) => sharding.initReply(replyId, replyChannel) *> queue.offer(req)
                          case None          => queue.offer(req) *> replyChannel.end
-                       }).catchAllCause(_ => send(entityId, req, replyId, replyChannel))
+                       }).catchAllCause(_ => Clock.sleep(100 millis) *> send(entityId, req, replyId, replyChannel))
                  }
       } yield ()