OrgGo/hybridgroup.gobot
1
0
Fork 0
mirror of https://github.com/hybridgroup/gobot.git synced 2025-05-08 19:29:16 +08:00
Code Issues Projects Releases Wiki Activity

Keep it simple, validate later

Browse Source
This commit is contained in:
deadprogram 2014-11-03 23:27:21 -08:00
parent c5f8b8a869
commit 618becbf53
1 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
platforms/mqtt/mqtt_adaptor.go
View File

@ -1,10 +1,8 @@
package mqtt package mqtt
import ( import (
"fmt"
"git.eclipse.org/gitroot/paho/org.eclipse.paho.mqtt.golang.git" "git.eclipse.org/gitroot/paho/org.eclipse.paho.mqtt.golang.git"
"github.com/hybridgroup/gobot" "github.com/hybridgroup/gobot"
"net/url"
) )
type MqttAdaptor struct { type MqttAdaptor struct {
@ -51,10 +49,9 @@ func (a *MqttAdaptor) Finalize() bool {
return true return true
} }
func (a *MqttAdaptor) Publish(topic string, message []byte) int { func (a *MqttAdaptor) Publish(topic string, message []byte) {
m := mqtt.NewMessage(message) m := mqtt.NewMessage(message)
a.client.PublishMessage(topic, m) a.client.PublishMessage(topic, m)
return 0
} }
func (a *MqttAdaptor) On(event string, f func(s interface{})) { func (a *MqttAdaptor) On(event string, f func(s interface{})) {
@ -65,9 +62,8 @@ func (a *MqttAdaptor) On(event string, f func(s interface{})) {
} }
func createClientOptions(clientId, raw string) *mqtt.ClientOptions { func createClientOptions(clientId, raw string) *mqtt.ClientOptions {
uri, _ := url.Parse(raw)
opts := mqtt.NewClientOptions() opts := mqtt.NewClientOptions()
opts.AddBroker(fmt.Sprintf("tcp://%s", uri.Host)) opts.AddBroker(raw)
opts.SetClientId(clientId) opts.SetClientId(clientId)
return opts return opts