Sign in
apache
/
rocketmq-e2e
/
9a6e34e05e2fe841bc57300f04ce15c88e216f7f
commit
9a6e34e05e2fe841bc57300f04ce15c88e216f7f
[
log
]
author
cryptoya <102146039+cryptoya@users.noreply.github.com>
Wed Nov 23 15:02:26 2022 +0800
committer
GitHub <noreply@github.com>
Wed Nov 23 15:02:26 2022 +0800
tree
1494e424fa897e508eca635b6f71a12462e81867
parent
bf486088cf85794c4d8ee6b74cfaaf03fc801f6b
[
diff
]
[ISSUE #1] Add rocketmq e2e test cases
.gitignore
[Added -
diff
]
README.md
[
diff
]
pom.xml
[Added -
diff
]
src/main/java/org/apache/rocketmq/account/Account.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/client/SimpleConsumerThread.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/client/rmq/RMQNormalConsumer.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/client/rmq/RMQNormalProducer.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/client/trans/LocalTransactionCheckerImpl.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/common/AbstractMQConsumer.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/common/AbstractMQProducer.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/common/MQCollector.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/common/MQConsumer.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/common/MQProducer.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/enums/TESTSET.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/factory/AclClient.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/factory/BaseFactory.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/factory/ClientConfigurationFactory.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/factory/ConsumerFactory.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/factory/MQMessageFactory.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/factory/MessageFactory.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/factory/ProducerFactory.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/frame/BaseOperate.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/frame/ResourceInit.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/listener/rmq/RMQNormalListener.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/util/AssertUtils.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/util/DateUtils.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/util/FileUtil.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/util/MQAdmin.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/util/MQWait.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/util/NameUtils.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/util/RandomUtils.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/util/TestUtils.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/util/VerifyUtils.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/util/data/collect/DataCollector.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/util/data/collect/DataCollectorManager.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/util/data/collect/DataFilter.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/util/data/collect/impl/ListDataCollectorImpl.java
[Added -
diff
]
src/main/java/org/apache/rocketmq/util/data/collect/impl/MapDataCollectorImpl.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/client/consumer/ConsumerGroupTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/client/consumer/PushConsumerInitTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/client/consumer/SimpleConsumerInitTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/client/message/MessageAbnormalTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/client/message/MessageBodyContentTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/client/message/MessageKeyTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/client/message/MessageTagTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/client/message/MessageUserPropertyTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/client/message/NormalMessageSizeTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/client/producer/ProducerInitTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/cluster/ClusterTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/example/ProducerExample.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/filter/push/SqlFilterTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/filter/push/SqlFilterWithOrderMsgTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/filter/push/TagFilterTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/server/DelayMessageTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/server/NormalMessageTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/server/OrderMessageTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/server/TransactionMessageTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/server/abnormal/DynamicChangeConsumeGroupTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/server/abnormal/PushConsumerRetryTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/simple/SimpleAckTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/simple/SimpleOrderParamTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/simple/SimpleOrderTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/simple/SimpleParamTest.java
[Added -
diff
]
src/test/java/org/apache/rocketmq/broker/simple/SimpleTopicTypeTest.java
[Added -
diff
]
src/test/resources/env/daily/daily.conf
[Added -
diff
]
src/test/resources/junit-platform.properties
[Added -
diff
]
src/test/resources/log4j.properties
[Added -
diff
]
src/test/resources/logback-test.xml
[Added -
diff
]
style/copyright/Apache.xml
[Added -
diff
]
style/copyright/profiles_settings.xml
[Added -
diff
]
style/rmq_checkstyle.xml
[Added -
diff
]
style/rmq_codeStyle.xml
[Added -
diff
]
72 files changed
tree: 1494e424fa897e508eca635b6f71a12462e81867
src/
style/
.asf.yaml
.gitignore
pom.xml
README.md
README.md
Apache RocketMQ E2E
RocketMQ E2E Test
