From fc79e79df0fff2ee6cc6c5692310e38135495bec Mon Sep 17 00:00:00 2001
From: amirhnajafiz
-
-
+
+
@@ -51,7 +51,7 @@ import (
)
func main() {
- client, err := stallion.NewClient("localhost:9090")
+ client, err := stallion.NewClient("st://localhost:9090")
if err != nil {
panic(err)
}
diff --git a/example/client/multi-subscribe/main.go b/example/client/multi-subscribe/main.go
index 1c081e4..b3721de 100644
--- a/example/client/multi-subscribe/main.go
+++ b/example/client/multi-subscribe/main.go
@@ -8,14 +8,14 @@ import (
)
func main() {
- client, err := stallion.NewClient("localhost:9090")
+ client, err := stallion.NewClient("st://localhost:9090")
if err != nil {
panic(err)
}
for i := 0; i < 2; i++ {
go func(j int) {
- cli, er := stallion.NewClient("localhost:9090")
+ cli, er := stallion.NewClient("st://localhost:9090")
if er != nil {
log.Fatal(er)
}
diff --git a/example/client/simple-publish/main.go b/example/client/simple-publish/main.go
index 98295be..3960cfe 100644
--- a/example/client/simple-publish/main.go
+++ b/example/client/simple-publish/main.go
@@ -8,7 +8,7 @@ import (
)
func main() {
- client, err := stallion.NewClient("localhost:9090")
+ client, err := stallion.NewClient("st://localhost:9090")
if err != nil {
panic(err)
}