pa/eqemu-server
2
0
Fork 0
mirror of https://github.com/EQEmu/Server.git synced 2026-03-05 09:22:24 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Changed helloworld.go to use proper import

Browse Source
This commit is contained in:
Xackery 2018-03-10 18:44:01 -08:00
parent bf84fcd908
commit 22aef8ad79
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
utils/nats/helloworld/helloworld.go
View File

@ -5,9 +5,9 @@ import (
"log" "log"
"time" "time"
"github.com/eqemu/server/protobuf/go/eqproto"
"github.com/golang/protobuf/proto" "github.com/golang/protobuf/proto"
"github.com/nats-io/go-nats" "github.com/nats-io/go-nats"
"github.com/xackery/rebuildeq/go/eqproto"
) )
func main() { func main() {
@ -41,8 +41,6 @@ func asyncChannelMessageSubscriber(nc *nats.Conn) {
log.Println(message) log.Println(message)
}) })
log.Println("Waiting on async messages...") log.Println("Waiting on async messages...")
time.Sleep(10 * time.Second)
log.Println("Timed out after 10 seconds")
} }
// syncChannelMessageSubscriber is an example of how to subscribe // syncChannelMessageSubscriber is an example of how to subscribe
@ -55,7 +53,7 @@ func syncChannelMessageSubscriber(nc *nats.Conn) {
} }
var m *nats.Msg var m *nats.Msg
if m, err = sub.NextMsg(10 * time.Second); err != nil { if m, err = sub.NextMsg(10 * time.Second); err != nil {
log.Println("Timed out after 10 seconds", err.Error()) log.Println("Timed out after 10 seconds waiting for message", err.Error())
return return
} }