Fixed GenericRequestPayload translation

Signed-off-by: Alberto Codutti <[email protected]>
eclipse · Mar 23, 2021 · f252762 · f252762
1 parent 8dde961
commit f252762
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/...va/org/eclipse/kapua/translator/kura/kapua/AbstractSimpleTranslatorResponseKuraKapua.java b/...va/org/eclipse/kapua/translator/kura/kapua/AbstractSimpleTranslatorResponseKuraKapua.java
@@ -27,6 +27,7 @@
 import org.eclipse.kapua.service.device.management.message.response.KapuaResponsePayload;
 import org.eclipse.kapua.service.device.management.request.GenericRequestFactory;
 import org.eclipse.kapua.service.device.management.request.message.response.GenericResponseMessage;
+import org.eclipse.kapua.service.device.management.request.message.response.GenericResponsePayload;
 import org.eclipse.kapua.translator.exception.InvalidChannelException;
 import org.eclipse.kapua.translator.exception.InvalidPayloadException;
 import org.eclipse.kapua.translator.exception.TranslatorErrorCodes;
@@ -91,7 +92,14 @@ public Class<TO_M> getClassTo() {
     @Override
     protected TO_P translatePayload(KuraResponsePayload kuraResponsePayload) throws InvalidPayloadException {
         try {
-            TO_P appResponsePayload = payloadClazz.newInstance();
+            GenericRequestFactory genericRequestFactory = LOCATOR.getFactory(GenericRequestFactory.class);
+
+            TO_P appResponsePayload;
+            if (payloadClazz.equals(GenericResponsePayload.class)) {
+                appResponsePayload = this.payloadClazz.cast(genericRequestFactory.newResponsePayload());
+            } else {
+                appResponsePayload = payloadClazz.newInstance();
+            }
 
             appResponsePayload.setExceptionMessage(kuraResponsePayload.getExceptionMessage());