resolve server shutdown issues

modules/iot-extensions/components/das-extensions/org.wso2.carbon.event.input.adapter.extensions/src/main/java/org/wso2/carbon/event/input/adapter/extensions/mqtt/MQTTEventAdapter.java

@@ -114,10 +114,22 @@ public class MQTTEventAdapter implements InputEventAdapter {
 
     @Override
     public void disconnect() {
+        //when mqtt and this feature  both together then this method becomes a blocking method, Therefore
+        // have used a thread to skip it.
+        try {
+            Thread thread = new Thread(new Runnable() {
+                public void run() {
                     if (mqttAdapterListener != null) {
                         mqttAdapterListener.stopListener(eventAdapterConfiguration.getName());
                     }
                 }
+            });
+            thread.start();
+            thread.join(2000);
+        } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
+        }
+    }
 
     @Override
     public void destroy() {