diff --git a/component/src/test/java/io/siddhi/extension/io/mqtt/sink/MqttTestClient.java b/component/src/test/java/io/siddhi/extension/io/mqtt/sink/MqttTestClient.java
index 514ce3f..2cfe31b 100644
--- a/component/src/test/java/io/siddhi/extension/io/mqtt/sink/MqttTestClient.java
+++ b/component/src/test/java/io/siddhi/extension/io/mqtt/sink/MqttTestClient.java
@@ -93,7 +93,7 @@ public MqttTestClient(String brokerURL, String topic, int qos, ResultContainer r
             client.connect(connectionOptions);
         } catch (MqttException e) {
             throw new ConnectionUnavailableException(
-                "Error in connecting with the Mqtt server" + e.getMessage(), e);
+                    "Error in connecting with the Mqtt server" + e.getMessage(), e);
         }
         try {
             mqttReceiverCallBack = new MqttReceiverCallBack();