From 09050dda629c5e7b7a422d8a3fed67283224a332 Mon Sep 17 00:00:00 2001 From: hindujaB Date: Fri, 22 Nov 2024 15:33:47 +0530 Subject: [PATCH 1/2] Update callMethod logic --- .../io/ballerina/stdlib/websub/NativeHttpToWebsubAdaptor.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/native/src/main/java/io/ballerina/stdlib/websub/NativeHttpToWebsubAdaptor.java b/native/src/main/java/io/ballerina/stdlib/websub/NativeHttpToWebsubAdaptor.java index 6db824f5..ff0f2886 100644 --- a/native/src/main/java/io/ballerina/stdlib/websub/NativeHttpToWebsubAdaptor.java +++ b/native/src/main/java/io/ballerina/stdlib/websub/NativeHttpToWebsubAdaptor.java @@ -147,10 +147,8 @@ private static Object invokeRemoteFunction(Environment env, BObject bSubscriberS Module module = ModuleUtils.getModule(); Object[] args = new Object[]{message}; ObjectType serviceType = (ObjectType) TypeUtils.getReferredType(TypeUtils.getType(bSubscriberService)); - boolean isIsolated = serviceType.isIsolated() && serviceType.isIsolated(remoteFunctionName); - StrandMetadata metadata = new StrandMetadata(isIsolated, null); try { - Object result = env.getRuntime().callMethod(bSubscriberService, remoteFunctionName, metadata, args); + Object result = env.getRuntime().callMethod(bSubscriberService, remoteFunctionName, null, args); ModuleUtils.notifySuccess(balFuture, result); return ModuleUtils.getResult(balFuture); } catch (BError bError) { From 11cb709086a8c0e077f6d1a24d9094f1bd97911a Mon Sep 17 00:00:00 2001 From: hindujaB Date: Fri, 22 Nov 2024 16:09:10 +0530 Subject: [PATCH 2/2] Fix checkstyle error --- .../io/ballerina/stdlib/websub/NativeHttpToWebsubAdaptor.java | 1 - 1 file changed, 1 deletion(-) diff --git a/native/src/main/java/io/ballerina/stdlib/websub/NativeHttpToWebsubAdaptor.java b/native/src/main/java/io/ballerina/stdlib/websub/NativeHttpToWebsubAdaptor.java index ff0f2886..96e21d88 100644 --- a/native/src/main/java/io/ballerina/stdlib/websub/NativeHttpToWebsubAdaptor.java +++ b/native/src/main/java/io/ballerina/stdlib/websub/NativeHttpToWebsubAdaptor.java @@ -20,7 +20,6 @@ import io.ballerina.runtime.api.Environment; import io.ballerina.runtime.api.Module; -import io.ballerina.runtime.api.concurrent.StrandMetadata; import io.ballerina.runtime.api.creators.ValueCreator; import io.ballerina.runtime.api.types.IntersectionType; import io.ballerina.runtime.api.types.MethodType;