=

liangdas · liangdas · commit f2ece7fc0e46 · 2019-10-29T15:10:15.000+08:00
diff --git a/go.mod b/go.mod
@@ -6,8 +6,8 @@ require (
 	github.com/eclipse/paho.mqtt.golang v1.2.0
 	github.com/gorilla/mux v1.7.3
 	github.com/liangdas/armyant v0.0.0-20181120080818-50ccc5936868
-	github.com/liangdas/mqant v2.5.0+incompatible
-	github.com/liangdas/mqant-modules v1.1.0+incompatible
+	github.com/liangdas/mqant v2.5.1+incompatible
+	github.com/liangdas/mqant-modules v2.5.1+incompatible
 	github.com/nats-io/go-nats v1.7.3-0.20190608183121-73ffc26dfe70
 	github.com/pkg/errors v0.8.1
 	github.com/yireyun/go-queue v0.0.0-20180809062148-5e6897360dac
diff --git a/go.sum b/go.sum
@@ -103,10 +103,10 @@ github.com/kr/text v0.1.0 h1:45sCR5RtlFHMR4UwH9sdQ5TC8v0qDQCHnXt+kaKSTVE=
 github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
 github.com/liangdas/armyant v0.0.0-20181120080818-50ccc5936868 h1:84Vsk7F5AG9kFF1VuWdmY4DR+TbmVVEhKzBnUhOJVg8=
 github.com/liangdas/armyant v0.0.0-20181120080818-50ccc5936868/go.mod h1:AgpkN9LqG5QT47ca4Efu+QZ43DBNn0TLZAMdXbVjXAc=
-github.com/liangdas/mqant v2.5.0+incompatible h1:uHlk6y8UbmNR+W2yR3Xtw3BoMYdcytxgkqAFhwQ0rkU=
-github.com/liangdas/mqant v2.5.0+incompatible/go.mod h1:I8tAjiMZ7Wi4xw3jxO7TN8MU8oRTYvctIYq//EW5Wpg=
-github.com/liangdas/mqant-modules v1.1.0+incompatible h1:N0JENDDQP1lsFpotwQ3mIilznIr2WAUnNbMc2d1lBKA=
-github.com/liangdas/mqant-modules v1.1.0+incompatible/go.mod h1:Tai+bdPfbsW3cWhwp2MWXDgsWMZ8xAv8wTfcVo0sW9k=
+github.com/liangdas/mqant v2.5.1+incompatible h1:MS576mzOdKkqZAFS9MhxKuF8utc3RYRAx+3GwD1+Aow=
+github.com/liangdas/mqant v2.5.1+incompatible/go.mod h1:I8tAjiMZ7Wi4xw3jxO7TN8MU8oRTYvctIYq//EW5Wpg=
+github.com/liangdas/mqant-modules v2.5.1+incompatible h1:f6R0ENuxdbbHCBCwUy3MHP3VmOGS8ulQYVDRYHSCsto=
+github.com/liangdas/mqant-modules v2.5.1+incompatible/go.mod h1:lMvfs4zaPrIVj68ae1ivOi/M//k+euV6iddo4bRjXYs=
 github.com/mattn/go-colorable v0.0.9/go.mod h1:9vuHe8Xs5qXnSaW/c/ABM9alt+Vo+STaOChaDxuIBZU=
 github.com/mattn/go-isatty v0.0.3/go.mod h1:M+lRXTBqGeGNdLjl/ufCoiOlB5xdOkqRJdNxMWT7Zi4=
 github.com/matttproud/golang_protobuf_extensions v1.0.1/go.mod h1:D8He9yQNgCq6Z5Ld7szi9bcBfOoFv/3dc6xSMkL2PC0=
diff --git a/robot/xaba/work.go b/robot/xaba/work.go
@@ -30,8 +30,8 @@ func NewWork(manager *Manager) *Work {
 	this := new(Work)
 	this.manager = manager
 	//opts:=this.GetDefaultOptions("tls://127.0.0.1:3563")
-	opts := this.GetDefaultOptions("tcp://127.0.0.1:3563")
-	//opts := this.GetDefaultOptions("ws://127.0.0.1:3653")
+	//opts := this.GetDefaultOptions("tcp://127.0.0.1:3563")
+	opts := this.GetDefaultOptions("ws://127.0.0.1:3653")
 	opts.SetConnectionLostHandler(func(client MQTT.Client, err error) {
 		fmt.Println("ConnectionLost", err.Error())
 	})
