We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d7fb597 commit 62212f0Copy full SHA for 62212f0
internal/integration/mqtt/backend.go
@@ -8,7 +8,6 @@ import (
8
"text/template"
9
"time"
10
11
- mqtt "github.com/eclipse/paho.mqtt.golang"
12
paho "github.com/eclipse/paho.mqtt.golang"
13
"github.com/pkg/errors"
14
log "github.com/sirupsen/logrus"
@@ -675,7 +674,7 @@ func (b *Backend) isClosed() bool {
675
674
return b.connClosed
676
}
677
678
-func tokenWrapper(token mqtt.Token, timeout time.Duration) error {
+func tokenWrapper(token paho.Token, timeout time.Duration) error {
679
if !token.WaitTimeout(timeout) {
680
return errors.New("token wait timeout error")
681
0 commit comments