Merge pull request #344 from HindujaB/fix-getType-API

Fix object getType() API usage
ballerina-attic · May 2, 2023 · b8e97b3 · b8e97b3
2 parents 6b1f5ed + c34285e
commit b8e97b3
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 5 deletions.
diff --git a/native/src/main/java/io/ballerina/stdlib/stan/Utils.java b/native/src/main/java/io/ballerina/stdlib/stan/Utils.java
@@ -60,7 +60,7 @@ public static byte[] convertDataIntoByteArray(Object data) {
 
     public static MethodType getAttachedFunctionType(BObject serviceObject, String functionName) {
         MethodType function = null;
-        ObjectType objectType = (ObjectType) TypeUtils.getReferredType(serviceObject.getType());
+        ObjectType objectType = (ObjectType) TypeUtils.getReferredType(TypeUtils.getType(serviceObject));
         MethodType[] resourceFunctions = objectType.getMethods();
         for (MethodType resourceFunction : resourceFunctions) {
             if (functionName.equals(resourceFunction.getName())) {

diff --git a/native/src/main/java/io/ballerina/stdlib/stan/consumer/Attach.java b/native/src/main/java/io/ballerina/stdlib/stan/consumer/Attach.java
@@ -47,7 +47,7 @@ public static Object attach(Environment environment, BObject streamingListener,
                                        Object serviceName) {
         String subject;
         Object streamingConnectionUrl = streamingListener.getNativeData(Constants.URL.getValue());
-        ObjectType serviceType = (ObjectType) TypeUtils.getReferredType(service.getType());
+        ObjectType serviceType = (ObjectType) TypeUtils.getReferredType(TypeUtils.getType(service));
         @SuppressWarnings("unchecked")
         BMap<BString, Object> annotation = (BMap<BString, Object>) serviceType
                 .getAnnotation(StringUtils.fromString(Utils.getModule().getOrg() + ORG_NAME_SEPARATOR +
@@ -73,7 +73,7 @@ public static Object attach(Environment environment, BObject streamingListener,
     }
 
     private static boolean getAckMode(BObject service) {
-        ObjectType serviceType = (ObjectType) TypeUtils.getReferredType(service.getType());
+        ObjectType serviceType = (ObjectType) TypeUtils.getReferredType(TypeUtils.getType(service));
         @SuppressWarnings("unchecked")
         BMap<BString, Object> serviceConfig = (BMap<BString, Object>) serviceType
                 .getAnnotation(StringUtils.fromString(Utils.getModule().getOrg() + ORG_NAME_SEPARATOR +

diff --git a/native/src/main/java/io/ballerina/stdlib/stan/consumer/StreamingListener.java b/native/src/main/java/io/ballerina/stdlib/stan/consumer/StreamingListener.java
@@ -127,7 +127,7 @@ private void executeResource(String subject, Object[] args, Type returnType) {
         CountDownLatch countDownLatch = new CountDownLatch(1);
         StrandMetadata metadata = new StrandMetadata(Utils.getModule().getOrg(), Utils.getModule().getName(),
                                                      Utils.getModule().getVersion(), Constants.ON_MESSAGE_RESOURCE);
-        ObjectType serviceType = (ObjectType) TypeUtils.getReferredType(service.getType());
+        ObjectType serviceType = (ObjectType) TypeUtils.getReferredType(TypeUtils.getType(service));
         if (ObserveUtils.isTracingEnabled()) {
             Map<String, Object> properties = new HashMap<>();
             NatsObserverContext observerContext = new NatsObserverContext(NatsObservabilityConstants.CONTEXT_CONSUMER,

diff --git a/native/src/main/java/io/ballerina/stdlib/stan/consumer/Subscribe.java b/native/src/main/java/io/ballerina/stdlib/stan/consumer/Subscribe.java
@@ -87,7 +87,7 @@ public static void streamingSubscribe(BObject streamingListener) {
     private static Subscription createSubscription(BObject service, StreamingListener messageHandler,
                                                    io.nats.streaming.StreamingConnection streamingConnection,
                                                    NatsMetricsReporter natsMetricsReporter) {
-        ObjectType serviceType = (ObjectType) TypeUtils.getReferredType(service.getType());
+        ObjectType serviceType = (ObjectType) TypeUtils.getReferredType(TypeUtils.getType(service));
         BMap<BString, Object> annotation = (BMap<BString, Object>) serviceType
                 .getAnnotation(StringUtils.fromString(Utils.getModule().getOrg() + ORG_NAME_SEPARATOR +
                                                               Utils.getModule().getName() + VERSION_SEPARATOR +