mqtt: update examples that use mqtt for updated notification signature

Signed-off-by: deadprogram <[email protected]>
neo4reo · Apr 19, 2017 · 311bfcf · 311bfcf
1 parent b97869e
commit 311bfcf
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 10 deletions.
diff --git a/examples/mqtt_firmata_blink.go b/examples/mqtt_firmata_blink.go
@@ -19,10 +19,10 @@ func main() {
 	led := gpio.NewLedDriver(firmataAdaptor, "13")
 
 	work := func() {
-		mqttAdaptor.On("lights/on", func(data []byte) {
+		mqttAdaptor.On("lights/on", func(msg mqtt.Message) {
 			led.On()
 		})
-		mqttAdaptor.On("lights/off", func(data []byte) {
+		mqttAdaptor.On("lights/off", func(msg mqtt.Message) {
 			led.Off()
 		})
 		data := []byte("")

diff --git a/examples/mqtt_ping.go b/examples/mqtt_ping.go
@@ -16,10 +16,10 @@ func main() {
 	mqttAdaptor := mqtt.NewAdaptor("tcp://test.mosquitto.org:1883", "pinger")
 
 	work := func() {
-		mqttAdaptor.On("hello", func(data []byte) {
+		mqttAdaptor.On("hello", func(msg mqtt.Message) {
 			fmt.Println("hello")
 		})
-		mqttAdaptor.On("hola", func(data []byte) {
+		mqttAdaptor.On("hola", func(msg mqtt.Message) {
 			fmt.Println("hola")
 		})
 		data := []byte("o")

diff --git a/examples/ollie_mqtt.go b/examples/ollie_mqtt.go
@@ -31,8 +31,8 @@ func main() {
 	work := func() {
 		ollie.SetRGB(255, 0, 255)
 
-		mqttAdaptor.On("sensores/dial", func(data []byte) {
-			val, _ := strconv.Atoi(string(data))
+		mqttAdaptor.On("sensores/dial", func(msg mqtt.Message) {
+			val, _ := strconv.Atoi(string(msg.Payload()))
 
 			if val > 2000 {
 				ollie.SetRGB(0, 255, 0)
@@ -45,28 +45,28 @@ func main() {
 			ollie.SetRGB(255, 0, 0)
 		})
 
-		mqttAdaptor.On("rover/frente", func(data []byte) {
+		mqttAdaptor.On("rover/frente", func(msg mqtt.Message) {
 			ollie.Roll(40, FRENTE)
 			gobot.After(1*time.Second, func() {
 				ollie.Stop()
 			})
 		})
 
-		mqttAdaptor.On("rover/derecha", func(data []byte) {
+		mqttAdaptor.On("rover/derecha", func(msg mqtt.Message) {
 			ollie.Roll(40, DERECHA)
 			gobot.After(1*time.Second, func() {
 				ollie.Stop()
 			})
 		})
 
-		mqttAdaptor.On("rover/atras", func(data []byte) {
+		mqttAdaptor.On("rover/atras", func(msg mqtt.Message) {
 			ollie.Roll(40, ATRAS)
 			gobot.After(1*time.Second, func() {
 				ollie.Stop()
 			})
 		})
 
-		mqttAdaptor.On("rover/izquierda", func(data []byte) {
+		mqttAdaptor.On("rover/izquierda", func(msg mqtt.Message) {
 			ollie.Roll(40, IZQUIERDA)
 			gobot.After(1*time.Second, func() {
 				ollie.Stop()