mirror of
https://github.com/wwhai/mqtt-benchmark.git
synced 2025-12-24 12:27:52 +08:00
Bugfix: only single message is sent (#23)
This commit is contained in:
10
client.go
10
client.go
@@ -84,10 +84,12 @@ func (c *Client) genMessages(ch chan *Message, done chan bool) {
|
||||
payload = make([]byte, c.MsgSize)
|
||||
}
|
||||
|
||||
ch <- &Message{
|
||||
Topic: c.MsgTopic,
|
||||
QoS: c.MsgQoS,
|
||||
Payload: payload,
|
||||
for i := 0; i < c.MsgCount; i++ {
|
||||
ch <- &Message{
|
||||
Topic: c.MsgTopic,
|
||||
QoS: c.MsgQoS,
|
||||
Payload: payload,
|
||||
}
|
||||
}
|
||||
|
||||
done <- true
|
||||
|
||||
Reference in New Issue
Block a user