From ddcc13a9b9863d2868cd47d5d1e900c23c7cfb8f Mon Sep 17 00:00:00 2001
From: chintansakhiya <chintan.sakhiya@improwised.com>
Date: Fri, 19 Jan 2024 12:35:45 +0530
Subject: [PATCH] fix: rename file

---
 cli/worker/worker.go                       | 2 +-
 pkg/watermill/{sender.go => publisher.go}  | 0
 pkg/watermill/{worker.go => subscriber.go} | 0
 3 files changed, 1 insertion(+), 1 deletion(-)
 rename pkg/watermill/{sender.go => publisher.go} (100%)
 rename pkg/watermill/{worker.go => subscriber.go} (100%)

diff --git a/cli/worker/worker.go b/cli/worker/worker.go
index 41050b0..b7de382 100644
--- a/cli/worker/worker.go
+++ b/cli/worker/worker.go
@@ -34,7 +34,7 @@ func (w AddUser) Handle(data []byte) {
 }
 
 func Process(msg *message.Message) error {
-	// GobRegister()
+	GobRegister()
 	buf := bytes.NewBuffer(msg.Payload)
 	dec := gob.NewDecoder(buf)
 
diff --git a/pkg/watermill/sender.go b/pkg/watermill/publisher.go
similarity index 100%
rename from pkg/watermill/sender.go
rename to pkg/watermill/publisher.go
diff --git a/pkg/watermill/worker.go b/pkg/watermill/subscriber.go
similarity index 100%
rename from pkg/watermill/worker.go
rename to pkg/watermill/subscriber.go