This is an automated email from the ASF dual-hosted git repository.
aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
The following commit(s) were added to refs/heads/master by this push:
new 2ff904e9 Fix typo (#353)
2ff904e9 is described below
commit 2ff904e9f3b0317c691fc881345a50f11df9a007
Author: xpume <[email protected]>
AuthorDate: Mon Feb 6 16:42:01 2023 +0800
Fix typo (#353)
---
golang/example/consumer/simple_consumer/main.go | 4 ++--
golang/example/producer/async/main.go | 2 +-
golang/example/producer/delay/main.go | 2 +-
golang/example/producer/fifo/main.go | 2 +-
golang/example/producer/normal/main.go | 2 +-
golang/example/producer/transaction/main.go | 2 +-
6 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/golang/example/consumer/simple_consumer/main.go
b/golang/example/consumer/simple_consumer/main.go
index 7be67c10..f53dedc5 100644
--- a/golang/example/consumer/simple_consumer/main.go
+++ b/golang/example/consumer/simple_consumer/main.go
@@ -72,12 +72,12 @@ func main() {
if err != nil {
log.Fatal(err)
}
- // gracefule stop simpleConsumer
+ // graceful stop simpleConsumer
defer simpleConsumer.GracefulStop()
go func() {
for {
- fmt.Println("start recevie message")
+ fmt.Println("start receive message")
mvs, err := simpleConsumer.Receive(context.TODO(),
maxMessageNum, invisibleDuration)
if err != nil {
fmt.Println(err)
diff --git a/golang/example/producer/async/main.go
b/golang/example/producer/async/main.go
index 5a160477..dfebe18b 100644
--- a/golang/example/producer/async/main.go
+++ b/golang/example/producer/async/main.go
@@ -58,7 +58,7 @@ func main() {
if err != nil {
log.Fatal(err)
}
- // gracefule stop producer
+ // graceful stop producer
defer producer.GracefulStop()
for i := 0; i < 10; i++ {
// new a message
diff --git a/golang/example/producer/delay/main.go
b/golang/example/producer/delay/main.go
index 8792c8e6..947dc2f3 100644
--- a/golang/example/producer/delay/main.go
+++ b/golang/example/producer/delay/main.go
@@ -58,7 +58,7 @@ func main() {
if err != nil {
log.Fatal(err)
}
- // gracefule stop producer
+ // graceful stop producer
defer producer.GracefulStop()
for i := 0; i < 10; i++ {
// new a message
diff --git a/golang/example/producer/fifo/main.go
b/golang/example/producer/fifo/main.go
index 4ecbed9f..2aa8443e 100644
--- a/golang/example/producer/fifo/main.go
+++ b/golang/example/producer/fifo/main.go
@@ -58,7 +58,7 @@ func main() {
if err != nil {
log.Fatal(err)
}
- // gracefule stop producer
+ // graceful stop producer
defer producer.GracefulStop()
for i := 0; i < 10; i++ {
// new a message
diff --git a/golang/example/producer/normal/main.go
b/golang/example/producer/normal/main.go
index 7b0aa0e3..2f5bcb66 100644
--- a/golang/example/producer/normal/main.go
+++ b/golang/example/producer/normal/main.go
@@ -57,7 +57,7 @@ func main() {
if err != nil {
log.Fatal(err)
}
- // gracefule stop producer
+ // graceful stop producer
defer producer.GracefulStop()
for i := 0; i < 10; i++ {
diff --git a/golang/example/producer/transaction/main.go
b/golang/example/producer/transaction/main.go
index 2424008b..584a7700 100644
--- a/golang/example/producer/transaction/main.go
+++ b/golang/example/producer/transaction/main.go
@@ -64,7 +64,7 @@ func main() {
if err != nil {
log.Fatal(err)
}
- // gracefule stop producer
+ // graceful stop producer
defer producer.GracefulStop()
for i := 0; i < 10; i++ {
// new a message
