commit 4fcf64af68852fdf2af32cadbda3c8ca197a1ccc
author shannonDing <libya_003@163.com> Wed Oct 31 14:02:19 2018 +0000
committer shannonDing <libya_003@163.com> Wed Oct 31 14:02:19 2018 +0000
tree 077f67b4c6641d81b684c61e690c9718d086394c
parent 7bb3f1dff7c1646127c61a72986ea55f08c9a586

Modify Samples

src/sample/main.go

diff --git a/src/sample/main.go b/src/sample/main.go
index 4a040e3..eb868b8 100644
--- a/src/sample/main.go
+++ b/src/sample/main.go
@@ -21,8 +21,8 @@
 
 func main() {
     fmt.Println("Start Sample Main Function......")
-    ExampleVersion()
-    ExampleSendMessage()
-    ExamplePushConsumeMessage()
+    SampleVersion()
+    SampleSendMessage()
+    SamplePushConsumeMessage()
     fmt.Scan()
 }

src/sample/sample_common.go

diff --git a/src/sample/example_common.go b/src/sample/sample_common.go
similarity index 97%
rename from src/sample/example_common.go
rename to src/sample/sample_common.go
index 10c2a40..461199b 100644
--- a/src/sample/example_common.go
+++ b/src/sample/sample_common.go
@@ -20,6 +20,6 @@
 import "fmt"
 import "../client"
 
-func ExampleVersion() {
+func SampleVersion() {
 	fmt.Println("Version :", client.GetVersion())
 }
\ No newline at end of file

src/sample/sample_producer.go

diff --git a/src/sample/example_producer.go b/src/sample/sample_producer.go
similarity index 98%
rename from src/sample/example_producer.go
rename to src/sample/sample_producer.go
index 4985ad8..f3e922b 100644
--- a/src/sample/example_producer.go
+++ b/src/sample/sample_producer.go
@@ -20,7 +20,7 @@
 import "fmt"
 import "../client"
 
-func ExampleSendMessage() {
+func SampleSendMessage() {
 	fmt.Println("Start Send Message..")
 	namesvr := "172.17.0.5:9876"
 	topic := "T_TestTopic"

src/sample/sample_pushconsumer.go

diff --git a/src/sample/example_pushconsumer.go b/src/sample/sample_pushconsumer.go
similarity index 88%
rename from src/sample/example_pushconsumer.go
rename to src/sample/sample_pushconsumer.go
index 392dfe7..a867176 100644
--- a/src/sample/example_pushconsumer.go
+++ b/src/sample/sample_pushconsumer.go
@@ -20,14 +20,14 @@
 import "fmt"
 import "../client"
 
-func ConsumeMessage(msg client.MessageExt) (client.ConsumeStatus) {
-	fmt.Println("ConsumeMessage")
+func SampleConsumeMessage(msg client.MessageExt) (client.ConsumeStatus) {
+	fmt.Println("ConsumeMessageInSample")
 	fmt.Println("Message topic",client.GetMessageTopic(msg))
 	fmt.Println("MessageId",client.GetMessageId(msg))
 	return client.ConsumeSuccess
 }
 
-func ExamplePushConsumeMessage() {
+func SamplePushConsumeMessage() {
 	fmt.Println("Start Send Message..")
 	namesvr := "172.17.0.5:9876"
 	topic := "T_TestTopic"
@@ -41,7 +41,7 @@
 	client.Subscribe(consumer, topic, expression)
 	fmt.Println("Set Push Consumer Subscribe,Topic:", topic," Exp:", expression)
 
-	client.RegisterMessageCallback(consumer,ConsumeMessage)
+	client.RegisterMessageCallback(consumer,SampleConsumeMessage)
 	client.StartPushConsumer(consumer)
 	fmt.Println("Start Push Consumer")
 	fmt.Scan()