From 702b0689f8ef23b388096e5a5e6431baaddd5f90 Mon Sep 17 00:00:00 2001 From: Quentin JOLY Date: Mon, 26 Aug 2024 15:55:45 +0200 Subject: [PATCH] Delete controller/main.go~ --- controller/main.go~ | 40 ---------------------------------------- 1 file changed, 40 deletions(-) delete mode 100644 controller/main.go~ diff --git a/controller/main.go~ b/controller/main.go~ deleted file mode 100644 index ba53a30..0000000 --- a/controller/main.go~ +++ /dev/null @@ -1,40 +0,0 @@ -package main - -import ( - "fmt" - "os" - "time" - - "github.com/nats-io/nats.go" -) - -func main() { - - url := os.Getenv("NATS_URL") - if url == "" { - url = nats.DefaultURL - } - - nc, _ := nats.Connect(url) - defer nc.Drain() - - sub, _ := nc.Subscribe("greet.*", func(msg *nats.Msg) { - - name := msg.Subject[6:] - msg.Respond([]byte("hello, " + name)) - }) - - rep, _ := nc.Request("greet.joe", nil, time.Second) - fmt.Println(string(rep.Data)) - - rep, _ = nc.Request("greet.sue", nil, time.Second) - fmt.Println(string(rep.Data)) - - rep, _ = nc.Request("greet.bob", nil, time.Second) - fmt.Println(string(rep.Data)) - - sub.Unsubscribe() - - _, err := nc.Request("greet.joe", nil, time.Second) - fmt.Println(err) -}