This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-e2e.git
The following commit(s) were added to refs/heads/master by this push:
new 650d3a3 [ISSUE #17] Fix checkstyle error
650d3a3 is described below
commit 650d3a3e9c5b22bc23b56acb832dafeb66c6a208
Author: yueya <[email protected]>
AuthorDate: Thu Apr 13 14:09:41 2023 +0800
[ISSUE #17] Fix checkstyle error
---
.../org/apache/rocketmq/RocketMQApplication.java | 16 +++++++++++++++
.../apache/rocketmq/client/DelayListenerImpl.java | 21 ++++++++++++++-----
.../org/apache/rocketmq/client/MQAdminTools.java | 16 +++++++++++++++
.../apache/rocketmq/client/NormalListenerImpl.java | 16 +++++++++++++++
.../apache/rocketmq/client/OrderListenerImpl.java | 16 +++++++++++++++
.../rocketmq/client/TransactionListenerImpl.java | 19 ++++++++++++++---
.../java/org/apache/rocketmq/utils/MQAdmin.java | 17 ++++++++++++++-
.../org/apache/rocketmq/utils/RandomUtils.java | 17 ++++++++++++++-
.../org/apache/rocketmq/SpringBootBaseTest.java | 17 ++++++++++++++-
.../apache/rocketmq/message/DelayMessageTest.java | 16 +++++++++++++++
.../apache/rocketmq/message/NormalMessageTest.java | 16 +++++++++++++++
.../apache/rocketmq/message/OrderMessageTest.java | 24 ++++++++++++++--------
.../apache/rocketmq/message/TransMessageTest.java | 23 +++++++++++++++------
.../rocketmq/server/delay/DelayMessageTest.java | 6 +++---
.../rocketmq/server/normal/NormalMessageTest.java | 8 ++++----
.../rocketmq/server/order/OrderMessageTest.java | 4 ++--
.../server/transaction/TransactionMessageTest.java | 2 +-
17 files changed, 219 insertions(+), 35 deletions(-)
diff --git
a/java/e2e-spring/src/main/java/org/apache/rocketmq/RocketMQApplication.java
b/java/e2e-spring/src/main/java/org/apache/rocketmq/RocketMQApplication.java
index 5955f9e..466577b 100644
--- a/java/e2e-spring/src/main/java/org/apache/rocketmq/RocketMQApplication.java
+++ b/java/e2e-spring/src/main/java/org/apache/rocketmq/RocketMQApplication.java
@@ -1,3 +1,19 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
package org.apache.rocketmq;
import lombok.extern.slf4j.Slf4j;
diff --git
a/java/e2e-spring/src/main/java/org/apache/rocketmq/client/DelayListenerImpl.java
b/java/e2e-spring/src/main/java/org/apache/rocketmq/client/DelayListenerImpl.java
index 77535ff..5a7c2c0 100644
---
a/java/e2e-spring/src/main/java/org/apache/rocketmq/client/DelayListenerImpl.java
+++
b/java/e2e-spring/src/main/java/org/apache/rocketmq/client/DelayListenerImpl.java
@@ -1,18 +1,29 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
package org.apache.rocketmq.client;
import lombok.extern.slf4j.Slf4j;
-import org.apache.rocketmq.common.attribute.TopicMessageType;
import org.apache.rocketmq.common.message.MessageExt;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
-import org.apache.rocketmq.utils.MQAdmin;
-import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
-import javax.annotation.PostConstruct;
import java.util.HashMap;
import java.util.LinkedList;
-import org.springframework.core.env.Environment;
@Slf4j
@Component
@RocketMQMessageListener(topic = "${rocketmq.test.topic.delay}", consumerGroup
= "gid-delay-spring-test", selectorExpression = "*")
diff --git
a/java/e2e-spring/src/main/java/org/apache/rocketmq/client/MQAdminTools.java
b/java/e2e-spring/src/main/java/org/apache/rocketmq/client/MQAdminTools.java
index 8397377..9b3fd9c 100644
--- a/java/e2e-spring/src/main/java/org/apache/rocketmq/client/MQAdminTools.java
+++ b/java/e2e-spring/src/main/java/org/apache/rocketmq/client/MQAdminTools.java
@@ -1,3 +1,19 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
package org.apache.rocketmq.client;
import lombok.extern.slf4j.Slf4j;
diff --git
a/java/e2e-spring/src/main/java/org/apache/rocketmq/client/NormalListenerImpl.java
b/java/e2e-spring/src/main/java/org/apache/rocketmq/client/NormalListenerImpl.java
index fe6ec89..834f0ec 100644
---
a/java/e2e-spring/src/main/java/org/apache/rocketmq/client/NormalListenerImpl.java
+++
b/java/e2e-spring/src/main/java/org/apache/rocketmq/client/NormalListenerImpl.java
@@ -1,3 +1,19 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
package org.apache.rocketmq.client;
import lombok.extern.slf4j.Slf4j;
diff --git
a/java/e2e-spring/src/main/java/org/apache/rocketmq/client/OrderListenerImpl.java
b/java/e2e-spring/src/main/java/org/apache/rocketmq/client/OrderListenerImpl.java
index 1fd473c..abf15c5 100644
---
a/java/e2e-spring/src/main/java/org/apache/rocketmq/client/OrderListenerImpl.java
+++
b/java/e2e-spring/src/main/java/org/apache/rocketmq/client/OrderListenerImpl.java
@@ -1,3 +1,19 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
package org.apache.rocketmq.client;
import lombok.extern.slf4j.Slf4j;
diff --git
a/java/e2e-spring/src/main/java/org/apache/rocketmq/client/TransactionListenerImpl.java
b/java/e2e-spring/src/main/java/org/apache/rocketmq/client/TransactionListenerImpl.java
index 4b6716a..72dbfaf 100644
---
a/java/e2e-spring/src/main/java/org/apache/rocketmq/client/TransactionListenerImpl.java
+++
b/java/e2e-spring/src/main/java/org/apache/rocketmq/client/TransactionListenerImpl.java
@@ -1,10 +1,23 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
package org.apache.rocketmq.client;
import lombok.extern.slf4j.Slf4j;
-import org.apache.rocketmq.common.message.MessageExt;
-import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.annotation.RocketMQTransactionListener;
-import org.apache.rocketmq.spring.core.RocketMQListener;
import org.apache.rocketmq.spring.core.RocketMQLocalTransactionListener;
import org.apache.rocketmq.spring.core.RocketMQLocalTransactionState;
import org.springframework.messaging.Message;
diff --git
a/java/e2e-spring/src/main/java/org/apache/rocketmq/utils/MQAdmin.java
b/java/e2e-spring/src/main/java/org/apache/rocketmq/utils/MQAdmin.java
index 2c3e196..775bffb 100644
--- a/java/e2e-spring/src/main/java/org/apache/rocketmq/utils/MQAdmin.java
+++ b/java/e2e-spring/src/main/java/org/apache/rocketmq/utils/MQAdmin.java
@@ -14,7 +14,22 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
package org.apache.rocketmq.utils;
import org.apache.rocketmq.client.exception.MQClientException;
diff --git
a/java/e2e-spring/src/main/java/org/apache/rocketmq/utils/RandomUtils.java
b/java/e2e-spring/src/main/java/org/apache/rocketmq/utils/RandomUtils.java
index a5e2ef2..1035536 100644
--- a/java/e2e-spring/src/main/java/org/apache/rocketmq/utils/RandomUtils.java
+++ b/java/e2e-spring/src/main/java/org/apache/rocketmq/utils/RandomUtils.java
@@ -14,7 +14,22 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
package org.apache.rocketmq.utils;
import java.util.Random;
diff --git
a/java/e2e-spring/src/test/java/org/apache/rocketmq/SpringBootBaseTest.java
b/java/e2e-spring/src/test/java/org/apache/rocketmq/SpringBootBaseTest.java
index c27b77a..c09c742 100644
--- a/java/e2e-spring/src/test/java/org/apache/rocketmq/SpringBootBaseTest.java
+++ b/java/e2e-spring/src/test/java/org/apache/rocketmq/SpringBootBaseTest.java
@@ -1,3 +1,19 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
package org.apache.rocketmq;
import lombok.extern.slf4j.Slf4j;
@@ -11,7 +27,6 @@ import org.springframework.boot.test.context.SpringBootTest;
@Slf4j
@SpringBootTest(classes = RocketMQApplication.class)
public class SpringBootBaseTest {
- protected static String ALL_IP;
@Value("${rocketmq.cluster}")
private String cluster;
diff --git
a/java/e2e-spring/src/test/java/org/apache/rocketmq/message/DelayMessageTest.java
b/java/e2e-spring/src/test/java/org/apache/rocketmq/message/DelayMessageTest.java
index 3f67718..4dd16b3 100644
---
a/java/e2e-spring/src/test/java/org/apache/rocketmq/message/DelayMessageTest.java
+++
b/java/e2e-spring/src/test/java/org/apache/rocketmq/message/DelayMessageTest.java
@@ -1,3 +1,19 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
package org.apache.rocketmq.message;
import lombok.AllArgsConstructor;
diff --git
a/java/e2e-spring/src/test/java/org/apache/rocketmq/message/NormalMessageTest.java
b/java/e2e-spring/src/test/java/org/apache/rocketmq/message/NormalMessageTest.java
index de661d5..bf7c38f 100644
---
a/java/e2e-spring/src/test/java/org/apache/rocketmq/message/NormalMessageTest.java
+++
b/java/e2e-spring/src/test/java/org/apache/rocketmq/message/NormalMessageTest.java
@@ -1,3 +1,19 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
package org.apache.rocketmq.message;
import lombok.AllArgsConstructor;
diff --git
a/java/e2e-spring/src/test/java/org/apache/rocketmq/message/OrderMessageTest.java
b/java/e2e-spring/src/test/java/org/apache/rocketmq/message/OrderMessageTest.java
index 547eb45..b6ca52c 100644
---
a/java/e2e-spring/src/test/java/org/apache/rocketmq/message/OrderMessageTest.java
+++
b/java/e2e-spring/src/test/java/org/apache/rocketmq/message/OrderMessageTest.java
@@ -1,12 +1,24 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
package org.apache.rocketmq.message;
-import lombok.AllArgsConstructor;
-import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.SpringBootBaseTest;
-import org.apache.rocketmq.client.NormalListenerImpl;
import org.apache.rocketmq.client.OrderListenerImpl;
-import org.apache.rocketmq.client.producer.SendCallback;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.client.producer.SendStatus;
import org.apache.rocketmq.common.message.MessageExt;
@@ -15,11 +27,7 @@ import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
-import org.springframework.messaging.support.MessageBuilder;
-import java.io.Serializable;
-import java.math.BigDecimal;
-import java.nio.charset.StandardCharsets;
import java.util.LinkedList;
import java.util.Map;
import java.util.concurrent.Callable;
diff --git
a/java/e2e-spring/src/test/java/org/apache/rocketmq/message/TransMessageTest.java
b/java/e2e-spring/src/test/java/org/apache/rocketmq/message/TransMessageTest.java
index fd80d51..b86aac2 100644
---
a/java/e2e-spring/src/test/java/org/apache/rocketmq/message/TransMessageTest.java
+++
b/java/e2e-spring/src/test/java/org/apache/rocketmq/message/TransMessageTest.java
@@ -1,12 +1,26 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
package org.apache.rocketmq.message;
-import lombok.AllArgsConstructor;
-import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.SpringBootBaseTest;
import org.apache.rocketmq.client.NormalListenerImpl;
import org.apache.rocketmq.client.TransactionListenerImpl;
-import org.apache.rocketmq.client.producer.SendCallback;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.client.producer.SendStatus;
import org.apache.rocketmq.spring.core.RocketMQLocalTransactionState;
@@ -18,9 +32,6 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.messaging.support.MessageBuilder;
-import java.io.Serializable;
-import java.math.BigDecimal;
-import java.time.Duration;
import java.util.concurrent.Callable;
import static java.util.concurrent.TimeUnit.SECONDS;
diff --git
a/java/e2e-v4/src/test/java/org/apache/rocketmq/server/delay/DelayMessageTest.java
b/java/e2e-v4/src/test/java/org/apache/rocketmq/server/delay/DelayMessageTest.java
index 90b1b11..3e4a369 100644
---
a/java/e2e-v4/src/test/java/org/apache/rocketmq/server/delay/DelayMessageTest.java
+++
b/java/e2e-v4/src/test/java/org/apache/rocketmq/server/delay/DelayMessageTest.java
@@ -43,7 +43,7 @@ public class DelayMessageTest extends BaseOperate {
private String tag;
private String topic;
private String groupId;
- private final static int SEND_NUM = 100;
+ private final static int SEND_NUM = 10;
@BeforeEach
public void setUp() {
@@ -60,7 +60,7 @@ public class DelayMessageTest extends BaseOperate {
}
@Test
- @DisplayName("测试延迟level=1")
+ @DisplayName("Send 10 delay messages and set the delay test delay level=1
, expecting all to be consumed and latency is as expected")
public void testDelayLevel1() {
int delayLevel = 1;
RMQNormalConsumer consumer =
ConsumerFactory.getRMQNormalConsumer(namesrvAddr, groupId, rpcHook);
@@ -75,7 +75,7 @@ public class DelayMessageTest extends BaseOperate {
}
@Test
- @DisplayName("测试延迟level=4")
+ @DisplayName("Send 10 delay messages and set the delay test delay level=4
, expecting all to be consumed and latency is as expected")
public void testDelayLevel4() {
int delayLevel = 4;
RMQNormalConsumer consumer =
ConsumerFactory.getRMQNormalConsumer(namesrvAddr, groupId, rpcHook);
diff --git
a/java/e2e-v4/src/test/java/org/apache/rocketmq/server/normal/NormalMessageTest.java
b/java/e2e-v4/src/test/java/org/apache/rocketmq/server/normal/NormalMessageTest.java
index 7506da4..f65615f 100644
---
a/java/e2e-v4/src/test/java/org/apache/rocketmq/server/normal/NormalMessageTest.java
+++
b/java/e2e-v4/src/test/java/org/apache/rocketmq/server/normal/NormalMessageTest.java
@@ -55,7 +55,7 @@ public class NormalMessageTest extends BaseOperate {
}
@Test
- @DisplayName("同步发送10条普通消息，期望这10条消息被消费到")
+ @DisplayName("Send 10 normal messages synchronously, expecting all to be
consumed")
public void testConsumeNormalMessage() {
RMQNormalConsumer consumer =
ConsumerFactory.getRMQNormalConsumer(namesrvAddr, groupId, rpcHook);
consumer.subscribeAndStart(topic, tag, new RMQNormalListener());
@@ -68,7 +68,7 @@ public class NormalMessageTest extends BaseOperate {
}
@Test
- @DisplayName("异步发送10条普通消息，期望这10条消息被消费到")
+ @DisplayName("Send 10 normal messages asynchronously, expecting all to be
consumed")
public void testConsumeNormalMessageAndSendWithAsync() {
RMQNormalConsumer consumer =
ConsumerFactory.getRMQNormalConsumer(namesrvAddr, groupId, rpcHook);
consumer.subscribeAndStart(topic, tag, new RMQNormalListener());
@@ -81,7 +81,7 @@ public class NormalMessageTest extends BaseOperate {
}
@Test
- @DisplayName("OneWay发送10条普通消息，期望这10条消息被消费到")
+ @DisplayName("Send 10 normal messages in OneWay, expecting all to be
consumed")
public void testConsumeNormalMessageAndSendWithOneWay() {
RMQNormalConsumer consumer =
ConsumerFactory.getRMQNormalConsumer(namesrvAddr, groupId, rpcHook);
consumer.subscribeAndStart(topic, tag, new RMQNormalListener());
@@ -93,7 +93,7 @@ public class NormalMessageTest extends BaseOperate {
}
@Test
- @DisplayName("topic创建,然后发送消息,不消费,删除该topic再次创建同名topic,启动消费,预期无法再次消费到")
+ @DisplayName("Create a topic, then send a message, do not consume, delete
the topic to create another topic of the same name, start consumption, not
expected to be consumed again")
public void testConsumeNormalMessageWithDeleteAndCreateTopicAgain() {
RMQNormalProducer producer =
ProducerFactory.getRMQProducer(namesrvAddr,rpcHook);
diff --git
a/java/e2e-v4/src/test/java/org/apache/rocketmq/server/order/OrderMessageTest.java
b/java/e2e-v4/src/test/java/org/apache/rocketmq/server/order/OrderMessageTest.java
index 26092fa..738177d 100644
---
a/java/e2e-v4/src/test/java/org/apache/rocketmq/server/order/OrderMessageTest.java
+++
b/java/e2e-v4/src/test/java/org/apache/rocketmq/server/order/OrderMessageTest.java
@@ -62,7 +62,7 @@ public class OrderMessageTest extends BaseOperate {
}
@Test
- @DisplayName("使用分区顺序topic，设置8个shardingkey，发送100条分区顺序消息，期望能按顺序消费到全部消息")
+ @DisplayName("Thirty messages are sent to each of the eight queues in a
topic, with the expectation that the sequential consumption client will consume
the messages in each queue in order")
public void testConsumePartitionOrderMessage() {
RMQNormalConsumer consumer =
ConsumerFactory.getRMQNormalConsumer(namesrvAddr, groupId, rpcHook);
consumer.subscribeAndStart(topic, "*", new RMQOrderListener());
@@ -76,7 +76,7 @@ public class OrderMessageTest extends BaseOperate {
}
@Test
- @DisplayName("使用全局顺序topic，发送100条全局顺序消息，期望能按顺序消费到全部消息")
+ @DisplayName("100 messages are sent to a queue for a topic, with the
expectation that the sequential consuming client will consume the messages in
the queue in order")
public void testConsumeGlobalOrderMessage() {
RMQNormalConsumer consumer =
ConsumerFactory.getRMQNormalConsumer(namesrvAddr, groupId, rpcHook);
consumer.subscribeAndStart(topic, "*", new RMQOrderListener());
diff --git
a/java/e2e-v4/src/test/java/org/apache/rocketmq/server/transaction/TransactionMessageTest.java
b/java/e2e-v4/src/test/java/org/apache/rocketmq/server/transaction/TransactionMessageTest.java
index ced5929..fd1638e 100644
---
a/java/e2e-v4/src/test/java/org/apache/rocketmq/server/transaction/TransactionMessageTest.java
+++
b/java/e2e-v4/src/test/java/org/apache/rocketmq/server/transaction/TransactionMessageTest.java
@@ -62,7 +62,7 @@ public class TransactionMessageTest extends BaseOperate {
}
@Test
- @DisplayName("同步发送10条普通消息，期望这10条消息被消费到")
+ @DisplayName("Send 10 transaction messages synchronously, expecting all to
be consumed")
public void testConsumeNormalMessage() {
RMQNormalConsumer consumer =
ConsumerFactory.getRMQNormalConsumer(namesrvAddr, groupId, rpcHook);
consumer.subscribeAndStart(topic, tag, new RMQNormalListener());
