Merge pull request #15 from tech-thinker/feature/refactoring

mrasif · web-flow · commit 20eeccf33e71 · 2021-11-25T23:08:23.000+05:30
chore: nats and worker queue added
diff --git a/queue/workers/PingWorker.go b/queue/workers/PingWorker.go
@@ -24,7 +24,7 @@ type pingWorker struct {
 
 func (w *pingWorker) Invoke(ctx context.Context, shutDownChannel chan *bool) error {
 	var (
-		groupError string = "ON_MESSAGE_SENT_WORKER"
+		groupError string = "INVOKE_PING_WORKER"
 	)
 
 	w.eventChannel = make(chan *queue.Message)

Original file line number	Diff line number	Diff line change
`@@ -24,7 +24,7 @@ type pingWorker struct {`
`24`	`24`
`25`	`25`	`func (w pingWorker) Invoke(ctx context.Context, shutDownChannel chan bool) error {`
`26`	`26`	`var (`
`27`		`- groupError string = "ON_MESSAGE_SENT_WORKER"`
	`27`	`+ groupError string = "INVOKE_PING_WORKER"`
`28`	`28`	`)`
`29`	`29`
`30`	`30`	`w.eventChannel = make(chan *queue.Message)`