rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From wenf...@apache.org
Subject [rocketmq-client-go] branch native updated: feat(example): rename shutdown instead of shundown (#336)
Date Fri, 20 Dec 2019 06:40:58 GMT
This is an automated email from the ASF dual-hosted git repository.

wenfeng pushed a commit to branch native
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git


The following commit(s) were added to refs/heads/native by this push:
     new df01296  feat(example): rename shutdown instead of shundown (#336)
df01296 is described below

commit df0129648b196117aa67972b7f89d87f6fd83855
Author: xujianhai666 <52450794+xujianhai666@users.noreply.github.com>
AuthorDate: Fri Dec 20 14:40:51 2019 +0800

    feat(example): rename shutdown instead of shundown (#336)
    
    Closes #335
---
 examples/consumer/retry/order/main.go | 4 ++++
 examples/consumer/simple/main.go      | 2 +-
 examples/consumer/strategy/main.go    | 2 +-
 examples/consumer/tag/main.go         | 4 ++++
 examples/consumer/trace/main.go       | 2 +-
 examples/producer/acl/main.go         | 2 +-
 examples/producer/async/main.go       | 2 +-
 examples/producer/delay/main.go       | 2 +-
 examples/producer/interceptor/main.go | 2 +-
 examples/producer/namespace/main.go   | 2 +-
 examples/producer/simple/main.go      | 2 +-
 examples/producer/tag/main.go         | 2 +-
 examples/producer/trace/main.go       | 2 +-
 examples/producer/transaction/main.go | 2 +-
 14 files changed, 20 insertions(+), 12 deletions(-)

diff --git a/examples/consumer/retry/order/main.go b/examples/consumer/retry/order/main.go
index f74ef68..2b34a68 100644
--- a/examples/consumer/retry/order/main.go
+++ b/examples/consumer/retry/order/main.go
@@ -69,4 +69,8 @@ func main() {
 		os.Exit(-1)
 	}
 	time.Sleep(time.Hour)
+	err = c.Shutdown()
+	if err != nil {
+		fmt.Printf("shundown Consumer error: %s", err.Error())
+	}
 }
diff --git a/examples/consumer/simple/main.go b/examples/consumer/simple/main.go
index c3ec35c..99c56fa 100644
--- a/examples/consumer/simple/main.go
+++ b/examples/consumer/simple/main.go
@@ -53,6 +53,6 @@ func main() {
 	time.Sleep(time.Hour)
 	err = c.Shutdown()
 	if err != nil {
-		fmt.Printf("shundown Consumer error: %s", err.Error())
+		fmt.Printf("shutdown Consumer error: %s", err.Error())
 	}
 }
diff --git a/examples/consumer/strategy/main.go b/examples/consumer/strategy/main.go
index 43c5ae5..a1ef54a 100644
--- a/examples/consumer/strategy/main.go
+++ b/examples/consumer/strategy/main.go
@@ -51,6 +51,6 @@ func main() {
 	time.Sleep(time.Hour)
 	err = c.Shutdown()
 	if err != nil {
-		fmt.Printf("shundown Consumer error: %s", err.Error())
+		fmt.Printf("shutdown Consumer error: %s", err.Error())
 	}
 }
diff --git a/examples/consumer/tag/main.go b/examples/consumer/tag/main.go
index 4a7cc9c..9c5d2fa 100644
--- a/examples/consumer/tag/main.go
+++ b/examples/consumer/tag/main.go
@@ -51,4 +51,8 @@ func main() {
 		os.Exit(-1)
 	}
 	time.Sleep(time.Hour)
+	err = c.Shutdown()
+	if err != nil {
+		fmt.Printf("shutdown Consumer error: %s", err.Error())
+	}
 }
diff --git a/examples/consumer/trace/main.go b/examples/consumer/trace/main.go
index acc700a..83a564e 100644
--- a/examples/consumer/trace/main.go
+++ b/examples/consumer/trace/main.go
@@ -58,6 +58,6 @@ func main() {
 	time.Sleep(time.Hour)
 	err = c.Shutdown()
 	if err != nil {
-		fmt.Printf("shundown Consumer error: %s", err.Error())
+		fmt.Printf("shutdown Consumer error: %s", err.Error())
 	}
 }
diff --git a/examples/producer/acl/main.go b/examples/producer/acl/main.go
index 2bd97fb..dec64e1 100644
--- a/examples/producer/acl/main.go
+++ b/examples/producer/acl/main.go
@@ -60,6 +60,6 @@ func main() {
 	}
 	err = p.Shutdown()
 	if err != nil {
-		fmt.Printf("shundown producer error: %s", err.Error())
+		fmt.Printf("shutdown producer error: %s", err.Error())
 	}
 }
diff --git a/examples/producer/async/main.go b/examples/producer/async/main.go
index 01f7f05..4a9bfa2 100644
--- a/examples/producer/async/main.go
+++ b/examples/producer/async/main.go
@@ -60,6 +60,6 @@ func main() {
 	wg.Wait()
 	err = p.Shutdown()
 	if err != nil {
-		fmt.Printf("shundown producer error: %s", err.Error())
+		fmt.Printf("shutdown producer error: %s", err.Error())
 	}
 }
diff --git a/examples/producer/delay/main.go b/examples/producer/delay/main.go
index 61ff29a..8116ed8 100644
--- a/examples/producer/delay/main.go
+++ b/examples/producer/delay/main.go
@@ -50,6 +50,6 @@ func main() {
 	}
 	err = p.Shutdown()
 	if err != nil {
-		fmt.Printf("shundown producer error: %s", err.Error())
+		fmt.Printf("shutdown producer error: %s", err.Error())
 	}
 }
diff --git a/examples/producer/interceptor/main.go b/examples/producer/interceptor/main.go
index 22fc552..ebd2df6 100644
--- a/examples/producer/interceptor/main.go
+++ b/examples/producer/interceptor/main.go
@@ -51,7 +51,7 @@ func main() {
 	}
 	err = p.Shutdown()
 	if err != nil {
-		fmt.Printf("shundown producer error: %s", err.Error())
+		fmt.Printf("shutdown producer error: %s", err.Error())
 	}
 }
 
diff --git a/examples/producer/namespace/main.go b/examples/producer/namespace/main.go
index 881c688..e4ae477 100644
--- a/examples/producer/namespace/main.go
+++ b/examples/producer/namespace/main.go
@@ -61,6 +61,6 @@ func main() {
 	}
 	err = p.Shutdown()
 	if err != nil {
-		fmt.Printf("shundown producer error: %s", err.Error())
+		fmt.Printf("shutdown producer error: %s", err.Error())
 	}
 }
diff --git a/examples/producer/simple/main.go b/examples/producer/simple/main.go
index 0a99835..5d2ce68 100644
--- a/examples/producer/simple/main.go
+++ b/examples/producer/simple/main.go
@@ -50,6 +50,6 @@ func main() {
 	}
 	err = p.Shutdown()
 	if err != nil {
-		fmt.Printf("shundown producer error: %s", err.Error())
+		fmt.Printf("shutdown producer error: %s", err.Error())
 	}
 }
diff --git a/examples/producer/tag/main.go b/examples/producer/tag/main.go
index ca408ab..8fb914f 100644
--- a/examples/producer/tag/main.go
+++ b/examples/producer/tag/main.go
@@ -53,6 +53,6 @@ func main() {
 	}
 	err = p.Shutdown()
 	if err != nil {
-		fmt.Printf("shundown producer error: %s", err.Error())
+		fmt.Printf("shutdown producer error: %s", err.Error())
 	}
 }
diff --git a/examples/producer/trace/main.go b/examples/producer/trace/main.go
index 01986b5..3d17c0b 100644
--- a/examples/producer/trace/main.go
+++ b/examples/producer/trace/main.go
@@ -59,6 +59,6 @@ func main() {
 
 	err = p.Shutdown()
 	if err != nil {
-		fmt.Printf("shundown producer error: %s", err.Error())
+		fmt.Printf("shutdown producer error: %s", err.Error())
 	}
 }
diff --git a/examples/producer/transaction/main.go b/examples/producer/transaction/main.go
index 660db96..8b017db 100644
--- a/examples/producer/transaction/main.go
+++ b/examples/producer/transaction/main.go
@@ -103,6 +103,6 @@ func main() {
 	time.Sleep(5 * time.Minute)
 	err = p.Shutdown()
 	if err != nil {
-		fmt.Printf("shundown producer error: %s", err.Error())
+		fmt.Printf("shutdown producer error: %s", err.Error())
 	}
 }


Mime
View raw message