diff options
| -rw-r--r-- | weed/mq/client/cmd/weed_pub_record/publisher_record.go | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/weed/mq/client/cmd/weed_pub_record/publisher_record.go b/weed/mq/client/cmd/weed_pub_record/publisher_record.go index 6a8b01371..4d4e5fc4d 100644 --- a/weed/mq/client/cmd/weed_pub_record/publisher_record.go +++ b/weed/mq/client/cmd/weed_pub_record/publisher_record.go @@ -15,6 +15,7 @@ import ( var ( messageCount = flag.Int("n", 1000, "message count") + messageDelay = flag.Duration("d", time.Second, "delay between messages") concurrency = flag.Int("c", 4, "concurrent publishers") partitionCount = flag.Int("p", 6, "partition count") @@ -34,8 +35,10 @@ func doPublish(publisher *pub_client.TopicPublisher, id int) { fmt.Println(err) break } - time.Sleep(time.Second) - // println("Published", string(key), string(value)) + if *messageDelay > 0 { + time.Sleep(*messageDelay) + fmt.Printf("sent %+v\n", myRecord) + } } if err := publisher.FinishPublish(); err != nil { fmt.Println(err) |