aboutsummaryrefslogtreecommitdiff
path: root/weed/mq
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2024-04-15 20:09:14 -0700
committerchrislu <chris.lu@gmail.com>2024-04-15 20:09:14 -0700
commitce2b2fa9b268288abc4e83f208ce1487838eb414 (patch)
treea3b0304c2836dc9fb743dfaf73a97c3d8092823d /weed/mq
parent68ade92d4f2a205dee1f7e9ee84cabeb81c68147 (diff)
parent37019477bc68f0f3ed83e39034b455622b35b383 (diff)
downloadseaweedfs-ce2b2fa9b268288abc4e83f208ce1487838eb414.tar.xz
seaweedfs-ce2b2fa9b268288abc4e83f208ce1487838eb414.zip
Merge branch 'master' into mq-subscribe
Diffstat (limited to 'weed/mq')
-rw-r--r--weed/mq/client/cmd/weed_sub/subscriber.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/mq/client/cmd/weed_sub/subscriber.go b/weed/mq/client/cmd/weed_sub/subscriber.go
index 6d0e49be1..adcdda04c 100644
--- a/weed/mq/client/cmd/weed_sub/subscriber.go
+++ b/weed/mq/client/cmd/weed_sub/subscriber.go
@@ -52,7 +52,7 @@ func main() {
})
subscriber.SetCompletionFunc(func() {
- glog.V(0).Infof("done recived %d messages", counter)
+ glog.V(0).Infof("done received %d messages", counter)
})
if err := subscriber.Subscribe(); err != nil {