Merge pull request #122 from ayyoob/das-ext

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,8 +114,20 @@ public class MQTTEventAdapter implements InputEventAdapter {
 
     @Override
     public void disconnect() {
-        if (mqttAdapterListener != null) {
-            mqttAdapterListener.stopListener(eventAdapterConfiguration.getName());
+        //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();
         }
     }