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())