fixed config loading of SignalTransformer extension

* and configured NoOpSignalTransformer in gateway Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
eclipse-ditto · May 12, 2022 · b2313b5 · b2313b5
1 parent 801fb2e
commit b2313b5
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/edge/api/src/main/java/org/eclipse/ditto/edge/api/dispatching/SignalTransformer.java b/edge/api/src/main/java/org/eclipse/ditto/edge/api/dispatching/SignalTransformer.java
@@ -18,6 +18,7 @@
 import org.eclipse.ditto.base.model.signals.Signal;
 import org.eclipse.ditto.base.service.DittoExtensionPoint;
 import org.eclipse.ditto.internal.utils.akka.AkkaClassLoader;
+import org.eclipse.ditto.internal.utils.config.DefaultScopedConfig;
 
 import akka.actor.AbstractExtensionId;
 import akka.actor.ActorSystem;
@@ -54,7 +55,8 @@ private static final class ExtensionId extends AbstractExtensionId<SignalTransfo
 
         @Override
         public SignalTransformer createExtension(final ExtendedActorSystem system) {
-            final var implementation = system.settings().config().getString(CONFIG_PATH);
+            final DefaultScopedConfig dittoScoped = DefaultScopedConfig.dittoScoped(system.settings().config());
+            final var implementation = dittoScoped.getString(CONFIG_PATH);
 
             return AkkaClassLoader.instantiate(system, SignalTransformer.class,
                     implementation,

diff --git a/gateway/service/src/main/resources/gateway.conf b/gateway/service/src/main/resources/gateway.conf
@@ -1,5 +1,6 @@
 ditto {
   service-name = "gateway"
+  signal-transformer =  "org.eclipse.ditto.edge.api.dispatching.NoOpSignalTransformer"
   mapping-strategy.implementation = "org.eclipse.ditto.gateway.service.util.GatewayMappingStrategies"
 
   signal-enrichment {