From 2bffcbc6d1329902a35d86fa969a8c8024c7003b Mon Sep 17 00:00:00 2001
From: aashikam <arshika.nm@gmail.com>
Date: Tue, 9 Apr 2024 09:59:27 +0530
Subject: [PATCH] Add changes from code review

---
 .../stdlib/nats/basic/consumer/DefaultMessageHandler.java       | 2 +-
 1 file changed, 1 insertion(+), 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
index 31df52cc..fbf8faad 100644
--- 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;
     }