Skip to content

Commit 295a97c

Browse files
committed
Update github.com/eclipse/paho.mqtt.golang vendor.
1 parent 469515e commit 295a97c

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

42 files changed

+100
-120
lines changed

backend/mqttpubsub/backend.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -5,15 +5,15 @@ import (
55
"encoding/gob"
66
"fmt"
77

8-
"git.eclipse.org/gitroot/paho/org.eclipse.paho.mqtt.golang.git"
98
log "github.com/Sirupsen/logrus"
109
"github.com/brocaar/loraserver"
1110
"github.com/brocaar/lorawan"
11+
"github.com/eclipse/paho.mqtt.golang"
1212
)
1313

1414
// Backend implements a MQTT pub-sub backend.
1515
type Backend struct {
16-
conn *mqtt.Client
16+
conn mqtt.Client
1717
txPacketChan chan loraserver.TXPacket
1818
}
1919

@@ -97,7 +97,7 @@ func (b *Backend) publish(topic string, v interface{}) error {
9797
return nil
9898
}
9999

100-
func (b *Backend) txPacketHandler(c *mqtt.Client, msg mqtt.Message) {
100+
func (b *Backend) txPacketHandler(c mqtt.Client, msg mqtt.Message) {
101101
var txPacket loraserver.TXPacket
102102
dec := gob.NewDecoder(bytes.NewReader(msg.Payload()))
103103
if err := dec.Decode(&txPacket); err != nil {

backend/mqttpubsub/backend_test.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -5,9 +5,8 @@ import (
55
"encoding/gob"
66
"testing"
77

8-
"git.eclipse.org/gitroot/paho/org.eclipse.paho.mqtt.golang.git"
9-
108
"github.com/brocaar/loraserver"
9+
"github.com/eclipse/paho.mqtt.golang"
1110
. "github.com/smartystreets/goconvey/convey"
1211
)
1312

@@ -29,7 +28,7 @@ func TestBackend(t *testing.T) {
2928

3029
Convey("Given the MQTT client is subscribed to RX packets", func() {
3130
rxPacketChan := make(chan loraserver.RXPacket)
32-
token := c.Subscribe("gateway/+/rx", 0, func(c *mqtt.Client, msg mqtt.Message) {
31+
token := c.Subscribe("gateway/+/rx", 0, func(c mqtt.Client, msg mqtt.Message) {
3332
var rxPacket loraserver.RXPacket
3433
dec := gob.NewDecoder(bytes.NewReader(msg.Payload()))
3534
if err := dec.Decode(&rxPacket); err != nil {
Lines changed: 4 additions & 17 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.
Lines changed: 6 additions & 6 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.
Lines changed: 48 additions & 37 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.
Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.
Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.
Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)