diff --git a/serviceLibrary/src/main/java/info/mqtt/android/service/MqttConnection.kt b/serviceLibrary/src/main/java/info/mqtt/android/service/MqttConnection.kt
index a118803b..04820b57 100755
--- a/serviceLibrary/src/main/java/info/mqtt/android/service/MqttConnection.kt
+++ b/serviceLibrary/src/main/java/info/mqtt/android/service/MqttConnection.kt
@@ -364,10 +364,8 @@ internal class MqttConnection(
                 val message = MqttMessage(payload)
                 message.qos = qos.value
                 message.isRetained = retained
-                CoroutineScope(Dispatchers.IO).launch {
-                    sendToken = myClient!!.publish(topic, payload, qos.value, retained, invocationContext, listener)
-                    storeSendDetailsInMemory(topic, message, sendToken, invocationContext, activityToken)
-                }
+                sendToken = myClient!!.publish(topic, payload, qos.value, retained, invocationContext, listener)
+                storeSendDetailsInMemory(topic, message, sendToken, invocationContext, activityToken)
             } catch (e: Exception) {
                 handleException(resultBundle, e)
             }