Channel as part of group name

fluffy-bunny · Jan 3, 2024 · 7d48933 · 7d48933
1 parent 9cfa379
commit 7d48933
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/cmd/cli/cmd/tasks/publisher/publisher.go b/cmd/cli/cmd/tasks/publisher/publisher.go
@@ -45,8 +45,9 @@ to quickly create a Cobra application.`,
 		options = append(options, asynq.MaxRetry(maxRetry))
 		if len(group) > 0 {
 			gg := &models.Group{
-				OrgId: group,
-				Event: "some:event",
+				AppID:   group,
+				Event:   "some:event",
+				Channel: "$default",
 			}
 			groupS, err := json.Marshal(gg)
 			if err != nil {

diff --git a/internal/models/groups.go b/internal/models/groups.go
@@ -1,6 +1,7 @@
 package models
 
 type Group struct {
-	OrgId string
-	Event string
+	AppID   string
+	Event   string
+	Channel string
 }