Path	Lines of Code
bdd/src/main/resources/client/consumer/ConsumerGroup.feature	35
bdd/src/main/resources/client/consumer/PushConsumerInit.feature	61
bdd/src/main/resources/client/consumer/SimpleConsumerInit.feature	80
bdd/src/main/resources/client/message/MessageBodyContent.feature	29
bdd/src/main/resources/client/message/MessageKey.feature	53
bdd/src/main/resources/client/message/MessageProperties.feature	50
bdd/src/main/resources/client/message/MessageSize.feature	84
bdd/src/main/resources/client/message/MessageTag.feature	52
bdd/src/main/resources/client/message/MessageUserProperty.feature	94
bdd/src/main/resources/client/producer/ProducerInit.feature	83
bdd/src/main/resources/filter.push/SqlFilter.feature	51
bdd/src/main/resources/filter.push/SqlFilterWithOrderMsg.feature	43
bdd/src/main/resources/filter.push/TagFilter.feature	138
bdd/src/main/resources/message/MessageBodyContent.feature	29
bdd/src/main/resources/message/MessageKey.feature	53
bdd/src/main/resources/message/MessageProperties.feature	50
bdd/src/main/resources/message/MessageSize.feature	84
bdd/src/main/resources/message/MessageTag.feature	52
bdd/src/main/resources/message/MessageUserProperty.feature	94
bdd/src/main/resources/server/abnormal/PushConsumerRetry.feature	47
bdd/src/main/resources/server/delay.feature	44
bdd/src/main/resources/server/normal.feature	27
bdd/src/main/resources/server/order.feature	24
bdd/src/main/resources/server/transaction.feature	31
bdd/src/main/resources/simple/SimpleAck.feature	32
bdd/src/main/resources/simple/SimpleMsgType.feature	48
bdd/src/main/resources/simple/SimpleOrderParam.feature	62
bdd/src/main/resources/simple/SimpleParameter.feature	94
csharp/rocketmq-client-csharp-tests/rocketmq-client-csharp-tests.csproj	22
csharp/rocketmq-client-csharp-tests/test/BaseTest.cs	14
csharp/rocketmq-client-csharp-tests/test/DelayMsgTest.cs	249
csharp/rocketmq-client-csharp-tests/test/FifoMsgTest.cs	151
csharp/rocketmq-client-csharp-tests/test/NormalMsgTest.cs	139
csharp/rocketmq-client-csharp-tests/test/TransMsgTest.cs	256
csharp/rocketmq-client-csharp-tests/utils/ClientUtils.cs	22
csharp/rocketmq-client-csharp-tests/utils/MQAdminUtils.cs	143
csharp/rocketmq-client-csharp-tests/utils/NameUtils.cs	27
golang/mqgotest/delay/delaymsg_test.go	85
golang/mqgotest/fifo/ordermsg_test.go	46
golang/mqgotest/normal/normalmsg_test.go	77
golang/mqgotest/transaction/transmsg_test.go	58
java/e2e-spring/src/test/java/org/apache/rocketmq/SpringBootBaseTest.java	25
java/e2e-spring/src/test/java/org/apache/rocketmq/message/DelayMessageTest.java	81
java/e2e-spring/src/test/java/org/apache/rocketmq/message/NormalMessageTest.java	87
java/e2e-spring/src/test/java/org/apache/rocketmq/message/OrderMessageTest.java	60
java/e2e-spring/src/test/java/org/apache/rocketmq/message/TransMessageTest.java	96
java/e2e-spring/src/test/resources/logback-test.xml	13
java/e2e-v4/src/test/java/org/apache/rocketmq/server/delay/DelayMessageTest.java	62
java/e2e-v4/src/test/java/org/apache/rocketmq/server/normal/NormalMessageTest.java	67
java/e2e-v4/src/test/java/org/apache/rocketmq/server/order/OrderMessageTest.java	65
java/e2e-v4/src/test/java/org/apache/rocketmq/server/transaction/TransactionMessageTest.java	60
java/e2e-v4/src/test/resources/logback-test.xml	13
java/e2e/pom.xml	188
java/e2e/src/main/java/org/apache/rocketmq/account/Account.java	40
java/e2e/src/main/java/org/apache/rocketmq/client/SimpleConsumerThread.java	74
java/e2e/src/main/java/org/apache/rocketmq/client/rmq/RMQNormalConsumer.java	277
java/e2e/src/main/java/org/apache/rocketmq/client/rmq/RMQNormalProducer.java	146
java/e2e/src/main/java/org/apache/rocketmq/client/trans/LocalTransactionCheckerImpl.java	20
java/e2e/src/main/java/org/apache/rocketmq/common/AbstractMQConsumer.java	5
java/e2e/src/main/java/org/apache/rocketmq/common/AbstractMQProducer.java	10
java/e2e/src/main/java/org/apache/rocketmq/common/MQCollector.java	74
java/e2e/src/main/java/org/apache/rocketmq/common/MQConsumer.java	4
java/e2e/src/main/java/org/apache/rocketmq/common/MQProducer.java	3
java/e2e/src/main/java/org/apache/rocketmq/enums/TESTSET.java	22
java/e2e/src/main/java/org/apache/rocketmq/factory/AclClient.java	9
java/e2e/src/main/java/org/apache/rocketmq/factory/BaseFactory.java	5
java/e2e/src/main/java/org/apache/rocketmq/factory/ClientConfigurationFactory.java	24
java/e2e/src/main/java/org/apache/rocketmq/factory/ConsumerFactory.java	92
java/e2e/src/main/java/org/apache/rocketmq/factory/MQMessageFactory.java	94
java/e2e/src/main/java/org/apache/rocketmq/factory/MessageFactory.java	171
java/e2e/src/main/java/org/apache/rocketmq/factory/ProducerFactory.java	47
java/e2e/src/main/java/org/apache/rocketmq/frame/BaseOperate.java	51
java/e2e/src/main/java/org/apache/rocketmq/frame/ResourceInit.java	164
java/e2e/src/main/java/org/apache/rocketmq/listener/rmq/RMQNormalListener.java	63
java/e2e/src/main/java/org/apache/rocketmq/util/AssertUtils.java	80
java/e2e/src/main/java/org/apache/rocketmq/util/DateUtils.java	59
java/e2e/src/main/java/org/apache/rocketmq/util/FileUtil.java	80
java/e2e/src/main/java/org/apache/rocketmq/util/MQAdmin.java	199
java/e2e/src/main/java/org/apache/rocketmq/util/MQWait.java	1
java/e2e/src/main/java/org/apache/rocketmq/util/NameUtils.java	102
java/e2e/src/main/java/org/apache/rocketmq/util/RandomUtils.java	59
java/e2e/src/main/java/org/apache/rocketmq/util/TestUtils.java	96
java/e2e/src/main/java/org/apache/rocketmq/util/VerifyUtils.java	843
java/e2e/src/main/java/org/apache/rocketmq/util/data/collect/DataCollector.java	16
java/e2e/src/main/java/org/apache/rocketmq/util/data/collect/DataCollectorManager.java	83
java/e2e/src/main/java/org/apache/rocketmq/util/data/collect/DataFilter.java	3
java/e2e/src/main/java/org/apache/rocketmq/util/data/collect/impl/ListDataCollectorImpl.java	65
java/e2e/src/main/java/org/apache/rocketmq/util/data/collect/impl/MapDataCollectorImpl.java	81
java/e2e/src/test/java/org/apache/rocketmq/broker/client/consumer/ConsumerGroupTest.java	53
java/e2e/src/test/java/org/apache/rocketmq/broker/client/consumer/PushConsumerInitTest.java	212
java/e2e/src/test/java/org/apache/rocketmq/broker/client/consumer/SimpleConsumerInitTest.java	222
java/e2e/src/test/java/org/apache/rocketmq/broker/client/message/MessageAbnormalTest.java	101
java/e2e/src/test/java/org/apache/rocketmq/broker/client/message/MessageBodyContentTest.java	102
java/e2e/src/test/java/org/apache/rocketmq/broker/client/message/MessageKeyTest.java	143
java/e2e/src/test/java/org/apache/rocketmq/broker/client/message/MessageTagTest.java	108
java/e2e/src/test/java/org/apache/rocketmq/broker/client/message/MessageUserPropertyTest.java	156
java/e2e/src/test/java/org/apache/rocketmq/broker/client/message/NormalMessageSizeTest.java	185
java/e2e/src/test/java/org/apache/rocketmq/broker/client/producer/ProducerInitTest.java	213
java/e2e/src/test/java/org/apache/rocketmq/broker/cluster/ClusterTest.java	108
java/e2e/src/test/java/org/apache/rocketmq/broker/example/ProducerExample.java	36
java/e2e/src/test/java/org/apache/rocketmq/broker/filter/push/SqlFilterTest.java	138
java/e2e/src/test/java/org/apache/rocketmq/broker/filter/push/SqlFilterWithOrderMsgTest.java	121
java/e2e/src/test/java/org/apache/rocketmq/broker/filter/push/TagFilterTest.java	277
java/e2e/src/test/java/org/apache/rocketmq/broker/offset/ResetOffsetTest.java	1
java/e2e/src/test/java/org/apache/rocketmq/broker/server/DelayMessageTest.java	127
java/e2e/src/test/java/org/apache/rocketmq/broker/server/NormalMessageTest.java	95
java/e2e/src/test/java/org/apache/rocketmq/broker/server/OrderMessageTest.java	69
java/e2e/src/test/java/org/apache/rocketmq/broker/server/TransactionMessageTest.java	173
java/e2e/src/test/java/org/apache/rocketmq/broker/server/abnormal/DynamicChangeConsumeGroupTest.java	1
java/e2e/src/test/java/org/apache/rocketmq/broker/server/abnormal/PushConsumerRetryTest.java	219
java/e2e/src/test/java/org/apache/rocketmq/broker/simple/SimpleAckTest.java	122
java/e2e/src/test/java/org/apache/rocketmq/broker/simple/SimpleOrderParamTest.java	297
java/e2e/src/test/java/org/apache/rocketmq/broker/simple/SimpleOrderTest.java	53
java/e2e/src/test/java/org/apache/rocketmq/broker/simple/SimpleParamTest.java	305
java/e2e/src/test/java/org/apache/rocketmq/broker/simple/SimpleTopicTypeTest.java	78
java/e2e/src/test/resources/logback-test.xml	13