51a01c18fd9eb2652dbf3ec97a9877d48e00cd89 - rocketmq-e2e

commit: 51a01c18fd9eb2652dbf3ec97a9877d48e00cd89
[log] [tgz]
author: XiaoWei Zhang <1403767615@qq.com>
Fri Oct 20 11:47:25 2023 +0800
committer: GitHub <noreply@github.com>
Fri Oct 20 11:47:25 2023 +0800
tree: 3fc9860db38a46fa0d396d7ae5bb96154c337539
parent: b035dd07bb7dceb536a4a2015c03076d6fe2073b [diff]

Added the java4.x client cluster filter pull test content (#51)

* Added the java4.x client cluster filter pull test content

* Improved the test content, adding the test content of batchproducer, transactions, loadbacing, offset, retry and other scenarios

* Refine old tests and add retry test scenarios

* Refine old tests and normalize non-standard code

48 files changed

tree: 3fc9860db38a46fa0d396d7ae5bb96154c337539

README.md

Apache RocketMQ E2E

RocketMQ E2E Test

Test Case Coverage

Message Type
- Normal message
- Transaction message
- Order message
- Delay message
Producer
- Sync Send
- Async Send
PushConsumer
SimpleConsumer
- Order/Delay/Transaction/Normal
- Sync receive/Async receive
- Sync ack/Async ack
Client init (Producer/PushConsumer/SimpleConsumer)
- Parameter settings
Mode
- Cluster
- Broadcast
Message
- Tag
- Body
- Key
- User property
Filter
- Tag
- Sql
Retry
- Normal message
- Order message

How to start

mvn clean test -B -Dgroups=smoke -Dcluster=DefaultCluster

Options

ALL_IP : not required, default is null
cluster: not required, default DefaultCluster
groups: param of junit5, src/main/java/org/apache/rocketmq/enums/TESTSET.java