Add changes from code review

ballerina-platform · Apr 9, 2024 · 2bffcbc · 2bffcbc
1 parent a75ef86
commit 2bffcbc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/native/src/main/java/io/ballerina/stdlib/nats/basic/consumer/DefaultMessageHandler.java b/native/src/main/java/io/ballerina/stdlib/nats/basic/consumer/DefaultMessageHandler.java
@@ -342,7 +342,7 @@ private static RecordType getRecordType(Type type) {
 
     private static Type getPayloadType(Type definedType) {
         if (definedType.getTag() == INTERSECTION_TAG) {
-            return ((IntersectionType) definedType).getConstituentTypes().get(0);
+            return TypeUtils.getReferredType(definedType);
         }
         return definedType;
     }