Minor update on pub-sub example

Author: shijuvar

.gitignore

@@ -10,4 +10,6 @@
 
 # Output of the go coverage tool, specifically when used with LiteIDE
 *.out
-.idea
+
+# IDE metadata
+**.idea/**

nats-basic-example/auth.conf

@@ -0,0 +1,6 @@
+listen = 0.0.0.0:4222
+
+authorization {
+  username = shijuvar
+  password = gopher
+}

nats-basic-example/pub.go

@@ -10,7 +10,10 @@ import (
 )
 
 func main() {
-	nc, err := nats.Connect("nats://127.0.0.1:4222")
+	nc, err := nats.Connect("nats://127.0.0.1:4222",
+		nats.Name("nats-demo"), // optional NATS name
+		nats.UserInfo("shijuvar", "gopher"),
+	)
 	if err != nil {
 		log.Fatalf("Error: %s", err)
 	}

nats-basic-example/qsub1.go

@@ -0,0 +1,21 @@
+package main
+
+import (
+"log"
+"runtime"
+
+"github.com/nats-io/go-nats"
+)
+
+func main() {
+	nc, err := nats.Connect("nats://127.0.0.1:4222",
+		nats.UserInfo("shijuvar", "gopher"),
+	)
+	if err != nil {
+		log.Fatalf("Error: %s", err)
+	}
+	nc.QueueSubscribe("order.created", "worker-group", func(m *nats.Msg) {
+		log.Printf("[Orer] %s", string(m.Data))
+	})
+	runtime.Goexit()
+}

nats-basic-example/qsub2.go

@@ -0,0 +1,21 @@
+package main
+
+import (
+	"log"
+	"runtime"
+
+	"github.com/nats-io/go-nats"
+)
+
+func main() {
+	nc, err := nats.Connect("nats://127.0.0.1:4222",
+		nats.UserInfo("shijuvar", "gopher"),
+	)
+	if err != nil {
+		log.Fatalf("Error: %s", err)
+	}
+	nc.QueueSubscribe("order.created", "worker-group", func(m *nats.Msg) {
+		log.Printf("[Orer] %s", string(m.Data))
+	})
+	runtime.Goexit()
+}

nats-basic-example/sub.go

@@ -9,7 +9,9 @@ import (
 )
 
 func main() {
-	nc, err := nats.Connect("nats://127.0.0.1:4222")
+	nc, err := nats.Connect("nats://127.0.0.1:4222",
+		nats.UserInfo("shijuvar", "gopher"),
+	)
 	if err != nil {
 		log.Fatalf("Error: %s", err)
 	}

nats-config/client-auth.conf

@@ -1,6 +1,6 @@
 listen = 0.0.0.0:4222
 
 authorization {
-  username = hoge
-  password = fuga
+  username = shijuvar
+  password = gopher
 }