From 1f6c61c11056b60fa253268aba5e75022db1c4cc Mon Sep 17 00:00:00 2001 From: sujit Date: Sun, 29 Sep 2024 17:06:41 +0545 Subject: [PATCH] init: publisher --- examples/dag.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/examples/dag.go b/examples/dag.go index 0d0edfb..0b7ebc4 100644 --- a/examples/dag.go +++ b/examples/dag.go @@ -47,7 +47,7 @@ func main() { go func() { time.Sleep(2 * time.Second) finalResult := d.Send([]byte(`[{"user_id": 1}, {"user_id": 2}]`)) - log.Printf("Final result received: %s", string(finalResult.Payload)) + log.Printf("Result received: %s %s", finalResult.MessageID, string(finalResult.Payload)) }() err := d.Start(context.TODO())