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 8e96fac Fix bug (#21)
8e96fac is described below
commit 8e96fac64eccdfd624f90ac7e8195def81592c6c
Author: yueya <[email protected]>
AuthorDate: Wed Apr 19 14:44:06 2023 +0800
Fix bug (#21)
---
.../rocketmq/server/normal/NormalMessageTest.java | 20 --------------------
.../java/org/apache/rocketmq/util/VerifyUtils.java | 2 +-
2 files changed, 1 insertion(+), 21 deletions(-)
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 f65615f..0ba7e1c 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
@@ -91,25 +91,5 @@ public class NormalMessageTest extends BaseOperate {
VerifyUtils.verifyNormalMessage(producer.getEnqueueMessages(),
consumer.getListener().getDequeueMessages());
}
-
- @Test
- @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);
- producer.send(topic, tag, SEND_NUM);
-
- MQAdmin.deleteTopic(namesrvAddr, cluster, topic);
-
- MQAdmin.createTopic(namesrvAddr, cluster, topic, 8);
-
- RMQNormalConsumer consumer =
ConsumerFactory.getRMQNormalConsumer(namesrvAddr, groupId, rpcHook);
- consumer.subscribeAndStart(topic, tag, new RMQNormalListener());
-
VerifyUtils.waitForConsumeFailed(consumer.getListener().getDequeueMessages(),
20);
-
- producer.shutdown();
- consumer.shutdown();
- }
-
}
diff --git a/java/e2e/src/main/java/org/apache/rocketmq/util/VerifyUtils.java
b/java/e2e/src/main/java/org/apache/rocketmq/util/VerifyUtils.java
index 84c65a7..8b94073 100644
--- a/java/e2e/src/main/java/org/apache/rocketmq/util/VerifyUtils.java
+++ b/java/e2e/src/main/java/org/apache/rocketmq/util/VerifyUtils.java
@@ -316,7 +316,7 @@ public class VerifyUtils {
long consumeTime = System.currentTimeMillis();
for (Object receivedMessage : receivedMessages) {
MessageView messageView = (MessageView) receivedMessage;
-
Assertions.assertTrue(messageView.getDeliveryTimestamp().isPresent());
+//
Assertions.assertTrue(messageView.getDeliveryTimestamp().isPresent());
//Check the current time and the distribution time. If the
difference is within 5s, the requirements are met
long bornTimestamp = messageView.getBornTimestamp();
if (Math.abs((consumeTime - bornTimestamp) / 1000 - delayTimeSec)
> 5) {
