DemoPublic/Midware/NATS/Client/Golang/natspub.go

23 lines
283 B
Go

package main
import (
"fmt"
"time"
"github.com/nats-io/nats.go"
)
func main() {
nc, err := nats.Connect(nats.DefaultURL)
defer nc.Close()
if nil != err {
fmt.Println(err)
return
}
for {
nc.Publish("foo", []byte("Hello Publish!"))
time.Sleep(1 * time.Second)
}
}