diff options
| author | chrislu <chris.lu@gmail.com> | 2024-05-05 14:17:41 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-05-05 14:17:41 -0700 |
| commit | 664b704e307b7eda52714bfb9936d6895e6e1471 (patch) | |
| tree | 77f163a70ba3e0a3561ebadd6890851f3d38cd47 | |
| parent | 4e3701df77aa405daab1146944b0691db1c9e1bf (diff) | |
| download | seaweedfs-664b704e307b7eda52714bfb9936d6895e6e1471.tar.xz seaweedfs-664b704e307b7eda52714bfb9936d6895e6e1471.zip | |
add delay
| -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) |