cryptoya commented on code in PR #22:
URL: https://github.com/apache/rocketmq-e2e/pull/22#discussion_r1173258691
##########
bdd/src/main/resources/delay.feature:
##########
@@ -0,0 +1,31 @@
+Feature: Test the message transfer mode and topic type
+
+ Scenario: Send 10 messages set delivery timestamp after 30s after the
current system time. Expect to consume all 10 messages after 30s
+ Given Create a "DELAY" topic:"random-topic" if not exist, a "Concurrently"
group:"random-group"
+ When Create a PushConsumer, set the Endpoint("127.0.0.1:9876"),
ConsumerGroup("random-group"), SubscriptionExpression("TagA"),
Topic("random-topic"), MessageListener("default")
+ And Create a Producer, set the Endpoint("127.0.0.1:9876"),
RequestTimeout:("10s"), Topic("random-topic")
+ Then Create a message, including the Topic("random-topic"),
SubscriptionExpression("TagA"), Key("Key"), and Body("Body")
+ And Set message "DeliveryTimestamp" to 20 seconds before the current
system time
+ And Send "10" messages "synchronous"
+ Then Check all messages that can be consumed within 60s
Review Comment:
done
--
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]
