From ac52442d012930e92285c8dae669630fbb33285e Mon Sep 17 00:00:00 2001 From: ravinperera00 Date: Wed, 9 Oct 2024 15:41:01 +0530 Subject: [PATCH] Fix spotBug issues --- .../stdlib/mqtt/listener/MqttListenerCallbackImpl.java | 8 -------- 1 file changed, 8 deletions(-) diff --git a/native/src/main/java/io/ballerina/stdlib/mqtt/listener/MqttListenerCallbackImpl.java b/native/src/main/java/io/ballerina/stdlib/mqtt/listener/MqttListenerCallbackImpl.java index f72fda9..7054d50 100644 --- a/native/src/main/java/io/ballerina/stdlib/mqtt/listener/MqttListenerCallbackImpl.java +++ b/native/src/main/java/io/ballerina/stdlib/mqtt/listener/MqttListenerCallbackImpl.java @@ -19,9 +19,7 @@ package io.ballerina.stdlib.mqtt.listener; import io.ballerina.runtime.api.Environment; -import io.ballerina.runtime.api.Module; import io.ballerina.runtime.api.Runtime; -import io.ballerina.runtime.api.async.StrandMetadata; import io.ballerina.runtime.api.creators.ValueCreator; import io.ballerina.runtime.api.types.RemoteMethodType; import io.ballerina.runtime.api.types.ServiceType; @@ -92,7 +90,6 @@ public void deliveryComplete(IMqttToken token) { private void invokeOnMessage(MqttMessage message, String topic) { BMap bMqttMessage = getBMqttMessage(message, topic); - StrandMetadata metadata = getStrandMetadata(MqttConstants.ONMESSAGE); boolean callerExists = isCallerAvailable(); Object result; if (!isMethodImplemented(MqttConstants.ONMESSAGE)) { @@ -170,9 +167,4 @@ private Optional getRemoteMethodType(String methodName) { } return Optional.empty(); } - - private StrandMetadata getStrandMetadata(String parentFunctionName) { - Module module = getModule(); - return new StrandMetadata(module.getOrg(), module.getName(), module.getMajorVersion(), parentFunctionName); - } }