fakerpawnno1 commented on code in PR #32:
URL: https://github.com/apache/rocketmq-e2e/pull/32#discussion_r1211561896
##########
golang/message/message_body_content_test.go:
##########
@@ -0,0 +1,116 @@
+package rocketmqtest
+
+import (
+ . "rocketmq-go-e2e/utils"
+ "sync"
+ "testing"
+ "time"
+
+ rmq_client "github.com/apache/rocketmq-clients/golang"
+)
+
+func TestMessageContent(t *testing.T) {
+ type args struct {
+ name, testTopic, nameServer, grpcEndpoint, clusterName, ak, sk,
cm, msgtag, keys, body string
+ }
+ tests := []struct {
+ name string
+ args args
+ }{
+ {
+ name: "Send normal message, setting message body with
space character, expect consume success",
+ args: args{
+ testTopic: GetTopicName(),
+ nameServer: NAMESERVER,
+ grpcEndpoint: GRPC_ENDPOINT,
+ clusterName: CLUSTER_NAME,
+ ak: "",
+ sk: "",
+ cm: GetGroupName(),
+ msgtag: RandomString(8),
+ keys: RandomString(8),
+ body: " ",
+ },
+ },
+ {
+ name: "Send normal message, setting message body with
chinese character, expect consume success",
+ args: args{
+ testTopic: GetTopicName(),
+ nameServer: NAMESERVER,
+ grpcEndpoint: GRPC_ENDPOINT,
+ clusterName: CLUSTER_NAME,
+ ak: "",
+ sk: "",
+ cm: GetGroupName(),
+ msgtag: RandomString(8),
+ keys: RandomString(8),
+ body: "中文字符",
+ },
+ },
+ {
+ name: "Send normal message, setting message body with
emoji(😱) character, expect consume success",
+ args: args{
+ testTopic: GetTopicName(),
+ nameServer: NAMESERVER,
+ grpcEndpoint: GRPC_ENDPOINT,
+ clusterName: CLUSTER_NAME,
+ ak: "",
+ sk: "",
+ cm: GetGroupName(),
+ msgtag: RandomString(8),
+ keys: RandomString(8),
+ body: "😱",
+ },
+ },
+ }
+ for _, tt := range tests {
+ t.Run(tt.name, func(t *testing.T) {
+ var wg sync.WaitGroup
+ // maximum number of messages received at one time
+ var maxMessageNum int32 = 32
+ // invisibleDuration should > 20s
+ var invisibleDuration = time.Second * 20
+ var msgCount = 10
+
+ CreateTopic(tt.args.testTopic, "", tt.args.clusterName,
tt.args.nameServer)
+ simpleConsumer :=
BuildSimpleConsumer(tt.args.grpcEndpoint, tt.args.cm, tt.args.msgtag,
tt.args.ak, tt.args.sk, tt.args.testTopic)
+
+ // new producer instance
+ producer := BuildProducer(tt.args.grpcEndpoint,
tt.args.ak, tt.args.sk, tt.args.testTopic)
+ // graceful stop producer
+ defer producer.GracefulStop()
+
+ msg := &rmq_client.Message{
+ // 为当前消息设置 Topic。
+ Topic: tt.args.testTopic,
+ // 消息体。
+ Body: []byte(tt.args.body),
+ }
+
+ if tt.args.keys != "" {
+ // 设置消息索引键，可根据关键字精确查找某条消息。
Review Comment:
这个判断是否有必要？
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
