This is an automated email from the ASF dual-hosted git repository.
mdedetrich pushed a commit to branch 1.3.x
in repository https://gitbox.apache.org/repos/asf/pekko.git
The following commit(s) were added to refs/heads/1.3.x by this push:
new acd2956896 Use duration converters for close()
acd2956896 is described below
commit acd2956896772c1732add2f9b178fe89642935ba
Author: Matthew de Detrich <[email protected]>
AuthorDate: Tue Nov 18 11:56:27 2025 +0100
Use duration converters for close()
(cherry picked from commit 29b7d22e29625a59e3424f5352e4cd7c3b59d984)
---
actor/src/main/scala/org/apache/pekko/actor/ActorSystem.scala | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
diff --git a/actor/src/main/scala/org/apache/pekko/actor/ActorSystem.scala
b/actor/src/main/scala/org/apache/pekko/actor/ActorSystem.scala
index 4ea8f2253e..1f10d2163b 100644
--- a/actor/src/main/scala/org/apache/pekko/actor/ActorSystem.scala
+++ b/actor/src/main/scala/org/apache/pekko/actor/ActorSystem.scala
@@ -41,6 +41,7 @@ import pekko.japi.Util.immutableSeq
import pekko.serialization.SerializationExtension
import pekko.util._
import pekko.util.FutureConverters._
+import pekko.util.JavaDurationConverters._
import pekko.util.OptionConverters._
import pekko.util.Helpers.toRootLowerCase
import pekko.util.ccompat.JavaConverters._
@@ -1104,10 +1105,8 @@ private[pekko] class ActorSystemImpl(
override def close(): Unit = {
terminate()
- val duration =
-
Duration(settings.config.getDuration("pekko.coordinated-shutdown.close-actor-system-timeout").toMillis,
- TimeUnit.MILLISECONDS)
- Await.result(whenTerminated, duration)
+ Await.result(whenTerminated,
+
settings.config.getDuration("pekko.coordinated-shutdown.close-actor-system-timeout").asScala)
}
override private[pekko] def finalTerminate(): Unit = {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
