package/mq
1
0
Fork 0
mirror of https://github.com/oarkflow/mq.git synced 2025-10-07 00:43:35 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat: update

Browse Source
This commit is contained in:
sujit
2024-10-13 18:34:06 +05:45
parent f9f06b608c
commit cf669b0a38
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
examples/tasks/tasks.go
View File

@@ -35,7 +35,7 @@ func Node3(_ context.Context, task *mq.Task) mq.Result {
func Node4(_ context.Context, task *mq.Task) mq.Result { func Node4(_ context.Context, task *mq.Task) mq.Result {
var user map[string]any var user map[string]any
_ = json.Unmarshal(task.Payload, &user) _ = json.Unmarshal(task.Payload, &user)
user["final"] = "D" user["node"] = "D"
resultPayload, _ := json.Marshal(user) resultPayload, _ := json.Marshal(user)
return mq.Result{Payload: resultPayload} return mq.Result{Payload: resultPayload}
} }
@@ -43,7 +43,7 @@ func Node4(_ context.Context, task *mq.Task) mq.Result {
func Node5(_ context.Context, task *mq.Task) mq.Result { func Node5(_ context.Context, task *mq.Task) mq.Result {
var user map[string]any var user map[string]any
_ = json.Unmarshal(task.Payload, &user) _ = json.Unmarshal(task.Payload, &user)
user["salary"] = "E" user["node"] = "E"
resultPayload, _ := json.Marshal(user) resultPayload, _ := json.Marshal(user)
return mq.Result{Payload: resultPayload} return mq.Result{Payload: resultPayload}
} }
@@ -58,7 +58,7 @@ func Node6(_ context.Context, task *mq.Task) mq.Result {
func Node7(_ context.Context, task *mq.Task) mq.Result { func Node7(_ context.Context, task *mq.Task) mq.Result {
var user map[string]any var user map[string]any
_ = json.Unmarshal(task.Payload, &user) _ = json.Unmarshal(task.Payload, &user)
user["node"] = "7" user["node"] = "G"
resultPayload, _ := json.Marshal(user) resultPayload, _ := json.Marshal(user)
return mq.Result{Payload: resultPayload} return mq.Result{Payload: resultPayload}
} }
@@ -66,7 +66,7 @@ func Node7(_ context.Context, task *mq.Task) mq.Result {
func Node8(_ context.Context, task *mq.Task) mq.Result { func Node8(_ context.Context, task *mq.Task) mq.Result {
var user map[string]any var user map[string]any
_ = json.Unmarshal(task.Payload, &user) _ = json.Unmarshal(task.Payload, &user)
user["node"] = "8" user["node"] = "H"
resultPayload, _ := json.Marshal(user) resultPayload, _ := json.Marshal(user)
return mq.Result{Payload: resultPayload} return mq.Result{Payload: resultPayload}
} }