修改断开连接的时间

mqtt_binding/mqtt_client/mqtt_client.go

@@ -117,7 +117,7 @@ func (c *MqttClient) Connect() error {
 }
 
 func (c *MqttClient) Disconnect() {
-	c.client.Disconnect(10000)
+	c.client.Disconnect(250)
 }
 
 func (c *MqttClient) GetRouter(group string, handlers []router.Handler) *router.Router {

mqtt_binding_test.go

@@ -113,7 +113,7 @@ func TestMqttBinding(t *testing.T) {
 			return
 		}
 
-		defer mqttClient.Disconnect(10000)
+		defer mqttClient.Disconnect(250)
 
 		time.Sleep(2 * time.Second)