apps/mochi-mqtt
1
0
Fork 0
mirror of https://github.com/mochi-mqtt/server.git synced 2025-10-04 15:52:55 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix examples

Browse Source
This commit is contained in:
Mochi
2020-02-12 20:39:30 +00:00
parent 31a026b14a
commit b605c94e5b
4 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
examples/dashboard/main.go
View File

@@ -27,7 +27,7 @@ func main() {
server := mqtt.New() server := mqtt.New()
stats := listeners.NewHTTPStats("stats", ":8080") stats := listeners.NewHTTPStats("stats", ":8080")
err = server.AddListener(stats, nil) err := server.AddListener(stats, nil)
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)
} }

4
examples/persistence/main.go
View File

@@ -6,12 +6,14 @@ import (
"os" "os"
"os/signal" "os/signal"
"syscall" "syscall"
"time"
"github.com/logrusorgru/aurora" "github.com/logrusorgru/aurora"
"go.etcd.io/bbolt" "go.etcd.io/bbolt"
mqtt "github.com/mochi-co/mqtt/server" mqtt "github.com/mochi-co/mqtt/server"
"github.com/mochi-co/mqtt/server/listeners" "github.com/mochi-co/mqtt/server/listeners"
"github.com/mochi-co/mqtt/server/listeners/auth"
"github.com/mochi-co/mqtt/server/persistence/bolt" "github.com/mochi-co/mqtt/server/persistence/bolt"
) )
@@ -29,7 +31,7 @@ func main() {
server := mqtt.New() server := mqtt.New()
tcp := listeners.NewTCP("t1", ":1883") tcp := listeners.NewTCP("t1", ":1883")
err := server.AddListener(tcp, &listeners.Config{ err := server.AddListener(tcp, &listeners.Config{
Auth: new(Auth), Auth: new(auth.Allow),
}) })
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)

3
examples/tcp/main.go
View File

@@ -11,6 +11,7 @@ import (
mqtt "github.com/mochi-co/mqtt/server" mqtt "github.com/mochi-co/mqtt/server"
"github.com/mochi-co/mqtt/server/listeners" "github.com/mochi-co/mqtt/server/listeners"
"github.com/mochi-co/mqtt/server/listeners/auth"
) )
func main() { func main() {
@@ -27,7 +28,7 @@ func main() {
server := mqtt.New() server := mqtt.New()
tcp := listeners.NewTCP("t1", ":1883") tcp := listeners.NewTCP("t1", ":1883")
err := server.AddListener(tcp, &listeners.Config{ err := server.AddListener(tcp, &listeners.Config{
Auth: new(Auth), Auth: new(auth.Allow),
}) })
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)

2
examples/websocket/main.go
View File

@@ -26,7 +26,7 @@ func main() {
server := mqtt.New() server := mqtt.New()
ws := listeners.NewWebsocket("ws1", ":1882") ws := listeners.NewWebsocket("ws1", ":1882")
err = server.AddListener(ws, nil) err := server.AddListener(ws, nil)
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)
} }