diff --git a/examples/dashboard/main.go b/examples/dashboard/main.go index 53b770d..47e6578 100644 --- a/examples/dashboard/main.go +++ b/examples/dashboard/main.go @@ -27,7 +27,7 @@ func main() { server := mqtt.New() stats := listeners.NewHTTPStats("stats", ":8080") - err = server.AddListener(stats, nil) + err := server.AddListener(stats, nil) if err != nil { log.Fatal(err) } diff --git a/examples/persistence/main.go b/examples/persistence/main.go index 517c5f6..cd4b0f1 100644 --- a/examples/persistence/main.go +++ b/examples/persistence/main.go @@ -6,12 +6,14 @@ import ( "os" "os/signal" "syscall" + "time" "github.com/logrusorgru/aurora" "go.etcd.io/bbolt" mqtt "github.com/mochi-co/mqtt/server" "github.com/mochi-co/mqtt/server/listeners" + "github.com/mochi-co/mqtt/server/listeners/auth" "github.com/mochi-co/mqtt/server/persistence/bolt" ) @@ -29,7 +31,7 @@ func main() { server := mqtt.New() tcp := listeners.NewTCP("t1", ":1883") err := server.AddListener(tcp, &listeners.Config{ - Auth: new(Auth), + Auth: new(auth.Allow), }) if err != nil { log.Fatal(err) diff --git a/examples/tcp/main.go b/examples/tcp/main.go index 6f9ec90..3737f6c 100644 --- a/examples/tcp/main.go +++ b/examples/tcp/main.go @@ -11,6 +11,7 @@ import ( mqtt "github.com/mochi-co/mqtt/server" "github.com/mochi-co/mqtt/server/listeners" + "github.com/mochi-co/mqtt/server/listeners/auth" ) func main() { @@ -27,7 +28,7 @@ func main() { server := mqtt.New() tcp := listeners.NewTCP("t1", ":1883") err := server.AddListener(tcp, &listeners.Config{ - Auth: new(Auth), + Auth: new(auth.Allow), }) if err != nil { log.Fatal(err) diff --git a/examples/websocket/main.go b/examples/websocket/main.go index 1440948..1505a0f 100644 --- a/examples/websocket/main.go +++ b/examples/websocket/main.go @@ -26,7 +26,7 @@ func main() { server := mqtt.New() ws := listeners.NewWebsocket("ws1", ":1882") - err = server.AddListener(ws, nil) + err := server.AddListener(ws, nil) if err != nil { log.Fatal(err) }