[plugins/asyncapi-spring-cloud-streams3] adds support for `modelNameP…

…refix` and `modelNameSuffix`
ZenWave360 · Sep 1, 2024 · e6bf3e4 · e6bf3e4
1 parent 5dfb6ab
commit e6bf3e4
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/zenwave-sdk-cli/src/main/java/io/zenwave360/sdk/processors/AsyncApiProcessor.java b/zenwave-sdk-cli/src/main/java/io/zenwave360/sdk/processors/AsyncApiProcessor.java
@@ -232,8 +232,9 @@ public void calculateMessageParamType(Map<String, Object> apiModel, Map<String,
         if ("asyncapi".equals(schemaFormat) || "openapi".equals(schemaFormat)) {
             javaType = normalizeTagName(JSONPath.getFirst(message, "$.payload.schema.x--schema-name", "$.payload.x--schema-name"));
             if (javaType == null) {
-                javaType = modelNamePrefix + normalizeTagName((String) message.getOrDefault("x-javaType", message.getOrDefault("messageId", message.get("name")))) + modelNameSuffix;
+                javaType = normalizeTagName((String) message.getOrDefault("x-javaType", message.getOrDefault("messageId", message.get("name"))));
             }
+            javaType = modelNamePrefix + javaType + modelNameSuffix;
         }
 
         if (javaType != null) {