~/Projects/mqtt-go
git clone https://code.lsong.org/mqtt-go
Commit
- Commit
- 99c96c844ece47e5de6fe9866af8a0ddd09bdf37
- Author
- mochi <[email protected]>
- Date
- 2022-03-31 16:49:02 +0100 +0100
- Diffstat
examples/dashboard/main.go | 2 +-
examples/events/main.go | 2 +-
examples/persistence/main.go | 2 +-
examples/tcp/main.go | 2 +-
examples/tls/main.go | 2 +-
examples/websocket/main.go | 2 +-
Update example code to use new NewServer function instead of deprecated New
diff --git a/examples/dashboard/main.go b/examples/dashboard/main.go
index 47e6578e868836ad89e60333d14d1b2fafc2eda0..ecd39aef205a2b5163a6fcaa72174a6ca757e430 100644
--- a/examples/dashboard/main.go
+++ b/examples/dashboard/main.go
@@ -24,7 +24,7 @@ }()
fmt.Println(aurora.Magenta("Mochi MQTT Server initializing..."), aurora.Cyan("TCP"))
- server := mqtt.New()
+ server := mqtt.NewServer(nil)
stats := listeners.NewHTTPStats("stats", ":8080")
err := server.AddListener(stats, nil)
diff --git a/examples/events/main.go b/examples/events/main.go
index a80e54838d3e2d1333a083d200843c294475e370..93723d55a8bcb42790fabd3e8bcf5277ca4ead38 100644
--- a/examples/events/main.go
+++ b/examples/events/main.go
@@ -27,7 +27,7 @@ }()
fmt.Println(aurora.Magenta("Mochi MQTT Server initializing..."), aurora.Cyan("TCP"))
- server := mqtt.New()
+ server := mqtt.NewServer(nil)
tcp := listeners.NewTCP("t1", ":1883")
err := server.AddListener(tcp, &listeners.Config{
Auth: new(auth.Allow),
diff --git a/examples/persistence/main.go b/examples/persistence/main.go
index cd4b0f16d3c818bcc4456f9cada315cd61af9604..d22e1d1c3a5cc4c6bd6444442ab0e61c8e3dce5b 100644
--- a/examples/persistence/main.go
+++ b/examples/persistence/main.go
@@ -28,7 +28,7 @@ }()
fmt.Println(aurora.Magenta("Mochi MQTT Server initializing..."), aurora.Cyan("Persistence"))
- server := mqtt.New()
+ server := mqtt.NewServer(nil)
tcp := listeners.NewTCP("t1", ":1883")
err := server.AddListener(tcp, &listeners.Config{
Auth: new(auth.Allow),
diff --git a/examples/tcp/main.go b/examples/tcp/main.go
index 3737f6c80d77914a3cecbb11b0e07f10ce8a3557..79113aae5d33d7ec1867af81f2f5c6f81140da52 100644
--- a/examples/tcp/main.go
+++ b/examples/tcp/main.go
@@ -25,7 +25,7 @@ }()
fmt.Println(aurora.Magenta("Mochi MQTT Server initializing..."), aurora.Cyan("TCP"))
- server := mqtt.New()
+ server := mqtt.NewServer(nil)
tcp := listeners.NewTCP("t1", ":1883")
err := server.AddListener(tcp, &listeners.Config{
Auth: new(auth.Allow),
diff --git a/examples/tls/main.go b/examples/tls/main.go
index c68adf48f4e1479bfe94381f74bd1c171feb5a99..7bed0091fc93687398e0e68422db634729c0b45c 100644
--- a/examples/tls/main.go
+++ b/examples/tls/main.go
@@ -57,8 +57,8 @@ }()
fmt.Println(aurora.Magenta("Mochi MQTT Server initializing..."), aurora.Cyan("TLS/SSL"))
+ "os/signal"
"log"
-
tcp := listeners.NewTCP("t1", ":1883")
err := server.AddListener(tcp, &listeners.Config{
Auth: new(auth.Allow),
diff --git a/examples/websocket/main.go b/examples/websocket/main.go
index 1505a0fbacf72efd9fb79e983211e6b7ea7801ad..ac5ba30132daad9d5ea7ccce33edf2a1b6eb2f38 100644
--- a/examples/websocket/main.go
+++ b/examples/websocket/main.go
@@ -24,7 +24,7 @@ }()
fmt.Println(aurora.Magenta("Mochi MQTT Server initializing..."), aurora.Cyan("TCP"))
- server := mqtt.New()
+ server := mqtt.NewServer(nil)
ws := listeners.NewWebsocket("ws1", ":1882")
err := server.AddListener(ws, nil)
if err != nil {
