Make retry less aggressive by adding a delay

ghostdogpr · ghostdogpr · commit 18ea1a4bd329 · 2024-07-18T14:20:43.000+09:00
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 ()
 

Original file line number	Diff line number	Diff line change
`@@ -130,7 +130,7 @@ private[shardcake] object EntityManager {`
`130`	`130`	`(replyId match {`
`131`	`131`	`case Some(replyId) => sharding.initReply(replyId, replyChannel) *> queue.offer(req)`
`132`	`132`	`case None => queue.offer(req) *> replyChannel.end`
`133`		`- }).catchAllCause(_ => send(entityId, req, replyId, replyChannel))`
	`133`	`+ }).catchAllCause(_ => Clock.sleep(100 millis) *> send(entityId, req, replyId, replyChannel))`
`134`	`134`	`}`
`135`	`135`	`} yield ()`
`136`	`136`