Remove redundant method

ballerina-platform · Oct 12, 2024 · 4f1120e · 4f1120e
1 parent e7bca86
commit 4f1120e
Showing 1 changed file with 5 additions and 8 deletions.
diff --git a/native/src/main/java/io/ballerina/stdlib/email/server/EmailListener.java b/native/src/main/java/io/ballerina/stdlib/email/server/EmailListener.java
@@ -23,14 +23,15 @@
 import io.ballerina.runtime.api.utils.TypeUtils;
 import io.ballerina.runtime.api.values.BError;
 import io.ballerina.runtime.api.values.BObject;
-import io.ballerina.stdlib.email.util.EmailConstants;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import java.util.HashMap;
 import java.util.Map;
 import java.util.Set;
 
+import static io.ballerina.stdlib.email.util.EmailConstants.ON_CLOSE;
+import static io.ballerina.stdlib.email.util.EmailConstants.ON_ERROR;
 import static io.ballerina.stdlib.email.util.EmailConstants.ON_MESSAGE;
 
 /**
@@ -64,7 +65,7 @@ public boolean onMessage(EmailEvent emailEvent) {
         if (runtime != null) {
             Set<Map.Entry<String, BObject>> services = registeredServices.entrySet();
             for (Map.Entry<String, BObject> service : services) {
-                invokeAsyncCall(service.getValue(), ON_MESSAGE, email);
+                runtime.call(service.getValue(), ON_MESSAGE, email);
             }
         } else {
             log.error("Runtime should not be null.");
@@ -81,7 +82,7 @@ public void onError(Object error) {
         if (runtime != null) {
             Set<Map.Entry<String, BObject>> services = registeredServices.entrySet();
             for (Map.Entry<String, BObject> service : services) {
-                invokeAsyncCall(service.getValue(), EmailConstants.ON_ERROR, error);
+                runtime.call(service.getValue(), ON_ERROR, error);
             }
         } else {
             log.error("Runtime should not be null.");
@@ -99,7 +100,7 @@ public void onClose(Object error) {
         if (runtime != null) {
             Set<Map.Entry<String, BObject>> services = registeredServices.entrySet();
             for (Map.Entry<String, BObject> service : services) {
-                invokeAsyncCall(service.getValue(), EmailConstants.ON_CLOSE, error);
+                runtime.call(service.getValue(), ON_CLOSE, error);
             }
         } else {
             log.error("Runtime should not be null.");
@@ -115,8 +116,4 @@ protected void addService(BObject service) {
         }
     }
 
-    private void invokeAsyncCall(BObject service, String methodName, Object arg) {
-        runtime.call(service, methodName, arg);
-    }
-
 }