diff --git a/examples/dag.go b/examples/dag.go index ba60ad6..16004f4 100644 --- a/examples/dag.go +++ b/examples/dag.go @@ -4,6 +4,8 @@ import ( "context" "encoding/json" "fmt" + "log" + "github.com/oarkflow/mq/examples/tasks" "github.com/oarkflow/mq/services" @@ -54,6 +56,7 @@ func aSync() { if f.Notifier != nil { f.Notifier.ToRoom("global", "message", result) } + log.Printf("DAG - FINAL_RESPONSE ~> TaskID: %s, Payload: %s, Topic: %s, Error: %v, Latency: %s", result.TaskID, result.Payload, result.Topic, result.Error, result.Latency) }) setup(f) err := f.Validate() diff --git a/examples/tasks/operations.go b/examples/tasks/operations.go index df44834..e26e1ad 100644 --- a/examples/tasks/operations.go +++ b/examples/tasks/operations.go @@ -71,7 +71,9 @@ func (e *EmailDelivery) ProcessTask(ctx context.Context, task *mq.Task) mq.Resul if err != nil { panic(err) } - return mq.Result{Payload: task.Payload, Ctx: ctx} + data["email_sent"] = true + d, _ := json.Marshal(data) + return mq.Result{Payload: d, Ctx: ctx} } type SendSms struct { diff --git a/examples/webroot/index.html b/examples/webroot/index.html index 90b7b58..0c94fa3 100644 --- a/examples/webroot/index.html +++ b/examples/webroot/index.html @@ -57,6 +57,12 @@