From 016f5c4273c9315a55d620ef7fdeb41a04aec230 Mon Sep 17 00:00:00 2001 From: Andrzej Ludwikowski Date: Thu, 16 Jan 2025 11:07:31 +0100 Subject: [PATCH] implementation improvements --- .../src/main/scala/akka/javasdk/impl/SdkRunner.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/akka-javasdk/src/main/scala/akka/javasdk/impl/SdkRunner.scala b/akka-javasdk/src/main/scala/akka/javasdk/impl/SdkRunner.scala index f2dbaaa47..e34364887 100644 --- a/akka-javasdk/src/main/scala/akka/javasdk/impl/SdkRunner.scala +++ b/akka-javasdk/src/main/scala/akka/javasdk/impl/SdkRunner.scala @@ -590,7 +590,7 @@ private final class Sdk( // service setup + integration test config val combinedDisabledComponents = - serviceSetup.map(_.disabledComponents().asScala.toSet).getOrElse(Set.empty) ++ disabledComponents + (serviceSetup.map(_.disabledComponents().asScala.toSet).getOrElse(Set.empty) ++ disabledComponents).map(_.getName) val descriptors = (eventSourcedEntityDescriptors ++ @@ -664,9 +664,9 @@ private final class Sdk( healthCheck = () => SdkRunner.FutureDone) } - private def isDisabled(disabledComponents: Set[Class[_]])(componentDescriptor: spi.ComponentDescriptor): Boolean = { + private def isDisabled(disabledComponents: Set[String])(componentDescriptor: spi.ComponentDescriptor): Boolean = { val className = componentDescriptor.implementationName - if (disabledComponents.map(_.getName).contains(className)) { + if (disabledComponents.contains(className)) { logger.info("Ignoring component [{}] as it is disabled", className) true } else