From da1d7139468708104a2b6121ad275ae058b72930 Mon Sep 17 00:00:00 2001 From: windyboy Date: Wed, 14 Aug 2024 11:48:39 +0800 Subject: [PATCH] =?UTF-8?q?=F0=9F=9A=80=20Integrate=20Hasura=20service=20i?= =?UTF-8?q?nto=20NATS=20message=20processing.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- cmd/main/main.go | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/cmd/main/main.go b/cmd/main/main.go index 480b8e0..0428acf 100644 --- a/cmd/main/main.go +++ b/cmd/main/main.go @@ -3,6 +3,7 @@ package main import ( "caatsm/internal/config" "caatsm/internal/nats" + "caatsm/internal/repository" "caatsm/pkg/utils" "os" @@ -82,7 +83,10 @@ func executeListen(c *cli.Context) error { fmt.Println("Loaded configuration successfully") log := utils.GetLogger() log.Info("Starting nats subscriber") - // handler := handlers.New(cfg) - nats.Subscribe(cfg) + publisher := nats.NewPub(cfg) + repository := repository.NewHasura(cfg) + handler := nats.NewHandler(cfg, publisher, repository) + subscriber := nats.NewSub(cfg) + subscriber.Subscribe(cfg, handler) return nil }