From 3f82b3f43c33f8442d4c5d3afee732529595dada Mon Sep 17 00:00:00 2001
From: mo khan <mo@mokhan.ca>
Date: Wed, 30 Nov 2022 13:42:14 -0700
Subject: initial commit

---
 cmd/consumer/main.go | 52 ++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 52 insertions(+)
 create mode 100644 cmd/consumer/main.go

(limited to 'cmd/consumer/main.go')

diff --git a/cmd/consumer/main.go b/cmd/consumer/main.go
new file mode 100644
index 0000000..a8a744d
--- /dev/null
+++ b/cmd/consumer/main.go
@@ -0,0 +1,52 @@
+package main
+
+import (
+	"c0/gatekeeper/pkg/x"
+	"encoding/json"
+	"fmt"
+	"time"
+
+	"github.com/gobuffalo/buffalo/worker"
+	"github.com/nats-io/nats.go"
+)
+
+func main() {
+	connection := x.Must(nats.Connect(nats.DefaultURL))
+	defer connection.Close()
+
+	stream := x.Must(connection.JetStream())
+
+	stream.QueueSubscribe("gtkpr.jobs.job_1", "default", func(msg *nats.Msg) {
+		var args worker.Args
+		json.Unmarshal(msg.Data, &args)
+
+		fmt.Printf("job: %v\n", args)
+	})
+
+	stream.QueueSubscribe("gtkpr.event.even", "even", func(msg *nats.Msg) {
+		var args worker.Args
+		json.Unmarshal(msg.Data, &args)
+
+		fmt.Printf("even: %v\n", args)
+		msg.Ack()
+	})
+
+	stream.QueueSubscribe("gtkpr.event.odd", "odd", func(msg *nats.Msg) {
+		var args worker.Args
+		json.Unmarshal(msg.Data, &args)
+
+		fmt.Printf("odd: %v\n", args)
+		msg.Ack()
+	})
+	stream.QueueSubscribe("gtkpr.event.*", "all", func(msg *nats.Msg) {
+		var args worker.Args
+		json.Unmarshal(msg.Data, &args)
+
+		fmt.Printf("all: %v\n", args)
+		msg.Ack()
+	})
+
+	for {
+		time.Sleep(10 * time.Second)
+	}
+}
-- 
cgit v1.2.3