reset flowchannel when channel endpoint is updated

coordinator.js

@@ -208,8 +208,21 @@ Coordinator.prototype.start = function() {
 		return true;
 		return true;
 	}
 	}
 	else {
 	else {
+		return true;
+	}
+}
+
+Coordinator.prototype.stop = function() {
+	if (this.started) {
+		this.started = false;
+		this.mqttclient.disconnect();
+
 		return false;
 		return false;
 	}
 	}
+	else {
+		return false;
+	}
+
 }
 }
 
 
 function create(param) {
 function create(param) {

flowagent.js

@@ -65,6 +65,11 @@ FlowAgent.prototype.start = function() {
     else return false;
     else return false;
 }
 }
 
 
+FlowAgent.prototype.stop = function() {
+    this.started = this.coordinator.stop();
+}
+
+
 FlowAgent.prototype.getInfo = function() {
 FlowAgent.prototype.getInfo = function() {
 	return {
 	return {
 	   	broker_uri : this.option.broker_uri,
 	   	broker_uri : this.option.broker_uri,

mqttclient.js

@@ -22,7 +22,7 @@ function sleep(ms) {
 MQTTClient.prototype.__proto__ = EventEmitter.prototype;
 MQTTClient.prototype.__proto__ = EventEmitter.prototype;
 
 
 MQTTClient.prototype.connect = function() {
 MQTTClient.prototype.connect = function() {
-    var that = this;
+    let that = this;
 
 
     if (this.client) delete this.client;
     if (this.client) delete this.client;
 
 
@@ -49,7 +49,10 @@ MQTTClient.prototype.connect = function() {
         console.log('MQClient Error:');
         console.log('MQClient Error:');
         console.log(error);
         console.log(error);
     });
     });
+}
 
 
+MQTTClient.prototype.disconnect = function() {
+    this.client.end();
 }
 }
 
 
 MQTTClient.prototype.resetbroker = function(topic, payload) {
 MQTTClient.prototype.resetbroker = function(topic, payload) {

package.json

 {
 {
   "name": "flowagent",
   "name": "flowagent",
-  "version": "1.2.1",
+  "version": "1.2.2",
   "description": "",
   "description": "",
   "main": "flowagent.js",
   "main": "flowagent.js",
   "scripts": {
   "scripts": {