Remove dupicate typedef for C APIs
diff --git a/src/client/consume.go b/src/client/consume.go
index d28aae2..66aa2a6 100644
--- a/src/client/consume.go
+++ b/src/client/consume.go
@@ -18,8 +18,6 @@
//#cgo CFLAGS: -I/usr/local/include/rocketmq
//#cgo LDFLAGS: -L/usr/local/lib -lrocketmq
-//typedef struct CMessageExt CMessageExt;
-//typedef struct CPushConsumer CPushConsumer;
//#include "CMessageExt.h"
//#include "CPushConsumer.h"
import "C"
diff --git a/src/client/messageExt.go b/src/client/messageExt.go
index c61ef11..bccea21 100644
--- a/src/client/messageExt.go
+++ b/src/client/messageExt.go
@@ -18,7 +18,6 @@
//#cgo CFLAGS: -I/usr/local/include/rocketmq
//#cgo LDFLAGS: -L/usr/local/lib -lrocketmq
-//typedef struct CMessageExt CMessageExt;
//#include "CMessageExt.h"
import "C"
@@ -47,4 +46,4 @@
func GetMessageId(msg MessageExt)(msgId string){
msgId = C.GoString(C.GetMessageId(msg.(*C.struct_CMessageExt)))
return
-}
\ No newline at end of file
+}
diff --git a/src/client/producer.go b/src/client/producer.go
index a0a1e91..95b2d66 100644
--- a/src/client/producer.go
+++ b/src/client/producer.go
@@ -18,8 +18,6 @@
//#cgo CFLAGS: -I/usr/local/include/rocketmq
//#cgo LDFLAGS: -L/usr/local/lib -lrocketmq
-//typedef struct CMessage CMessage;
-//typedef struct CProducer CProducer;
//#include "CMessage.h"
//#include "CProducer.h"
import "C"
@@ -73,4 +71,4 @@
sendResult.MsgId = C.GoString(&sr.msgId[0])
sendResult.Offset = int64(sr.offset)
return sendResult
-}
\ No newline at end of file
+}
diff --git a/src/client/pushconsumer.go b/src/client/pushconsumer.go
index f6cb3ea..9192862 100644
--- a/src/client/pushconsumer.go
+++ b/src/client/pushconsumer.go
@@ -18,8 +18,6 @@
//#cgo CFLAGS: -I/usr/local/include/rocketmq
//#cgo LDFLAGS: -L/usr/local/lib -lrocketmq
-//typedef struct CMessageExt CMessageExt;
-//typedef struct CPushConsumer CPushConsumer;
//#include "CMessageExt.h"
//#include "CPushConsumer.h"
//extern int ConsumeMessageCallback(CPushConsumer *consumer,CMessageExt *msg);
diff --git a/src/sample/sample_producer.go b/src/sample/sample_producer.go
index f3e922b..336812c 100644
--- a/src/sample/sample_producer.go
+++ b/src/sample/sample_producer.go
@@ -22,7 +22,7 @@
func SampleSendMessage() {
fmt.Println("Start Send Message..")
- namesvr := "172.17.0.5:9876"
+ namesvr := "172.17.0.2:9876"
topic := "T_TestTopic"
keys := "testKeys"
body := "testBody"
diff --git a/src/sample/sample_pushconsumer.go b/src/sample/sample_pushconsumer.go
index a867176..e70dd75 100644
--- a/src/sample/sample_pushconsumer.go
+++ b/src/sample/sample_pushconsumer.go
@@ -29,7 +29,7 @@
func SamplePushConsumeMessage() {
fmt.Println("Start Send Message..")
- namesvr := "172.17.0.5:9876"
+ namesvr := "172.17.0.2:9876"
topic := "T_TestTopic"
expression := "*"
//Create Producer
