From e600bf016dd040cba7249dde6d8f185c60af4932 Mon Sep 17 00:00:00 2001 From: chrislu Date: Mon, 24 Feb 2025 23:51:13 -0800 Subject: [PATCH] fmt --- weed/mq/client/cmd/agent_sub_record/agent_sub_record.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/weed/mq/client/cmd/agent_sub_record/agent_sub_record.go b/weed/mq/client/cmd/agent_sub_record/agent_sub_record.go index 80313e4d1..c17938515 100644 --- a/weed/mq/client/cmd/agent_sub_record/agent_sub_record.go +++ b/weed/mq/client/cmd/agent_sub_record/agent_sub_record.go @@ -46,7 +46,7 @@ func main() { session.SubscribeMessageRecord(func(key []byte, recordValue *schema_pb.RecordValue) { counter++ record := example.FromRecordValue(recordValue) - fmt.Printf("%s %v\n", string(key), record) + fmt.Printf("%d %s %v\n", counter, string(key), record) }, func() { log.Printf("done received %d messages", counter) })