fmt

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