Path	Lines of Code
logappender/src/test/java/org/apache/rocketmq/logappender/AbstractTestCase.java	43
logappender/src/test/java/org/apache/rocketmq/logappender/Log4jPropertiesTest.java	12
logappender/src/test/java/org/apache/rocketmq/logappender/Log4jTest.java	20
logappender/src/test/java/org/apache/rocketmq/logappender/Log4jXmlTest.java	12
logappender/src/test/java/org/apache/rocketmq/logappender/LogbackTest.java	32
logappender/src/test/java/org/apache/rocketmq/logappender/log4j2Test.java	24
logappender/src/test/resources/log4j-example.xml	33
logappender/src/test/resources/log4j2-example.xml	21
logappender/src/test/resources/logback-example.xml	57
rocketmq-cloudevents-binding/src/test/java/org/apache/rocketmq/cloudevent/RocketMQMessageWriterTest.java	216
rocketmq-cloudevents-binding/src/test/java/org/apache/rocketmq/cloudevent/RocketmqMessageFactoryTest.java	205
rocketmq-flume/rocketmq-flume-sink/src/test/java/org/apache/rocketmq/flume/ng/sink/RocketMQSinkTest.java	236
rocketmq-flume/rocketmq-flume-source/src/test/java/org/apache/rocketmq/flume/ng/source/RocketMQSourceTest.java	143
rocketmq-hbase/rocketmq-hbase-sink/src/test/java/org/apache/rocketmq/sink/ReplicatorTest.java	223
rocketmq-hbase/rocketmq-hbase-source/src/test/java/org/apache/rocketmq/hbase/source/RocketMQSourceTest.java	172
rocketmq-iot-bridge/src/test/java/org/apache/rocketmq/iot/connection/client/ClientManagerTest.java	54
rocketmq-iot-bridge/src/test/java/org/apache/rocketmq/iot/integration/ConsumeMessageIntegrationTest.java	192
rocketmq-iot-bridge/src/test/java/org/apache/rocketmq/iot/integration/ProduceMessageIntegrationTest.java	164
rocketmq-iot-bridge/src/test/java/org/apache/rocketmq/iot/integration/PubSubIntegrationTest.java	191
rocketmq-iot-bridge/src/test/java/org/apache/rocketmq/iot/protocol/mqtt/handler/MqttConnectionHandlerTest.java	53
rocketmq-iot-bridge/src/test/java/org/apache/rocketmq/iot/protocol/mqtt/handler/MqttDispatcherTest.java	46
rocketmq-iot-bridge/src/test/java/org/apache/rocketmq/iot/protocol/mqtt/handler/MqttIdleHandlerTest.java	56
rocketmq-iot-bridge/src/test/java/org/apache/rocketmq/iot/protocol/mqtt/handler/downstream/AbstractMqttMessageHandlerTest.java	62
rocketmq-iot-bridge/src/test/java/org/apache/rocketmq/iot/protocol/mqtt/handler/downstream/MqttConnectMessageHandlerTest.java	85
rocketmq-iot-bridge/src/test/java/org/apache/rocketmq/iot/protocol/mqtt/handler/downstream/MqttDisconnectMessageHandlerTest.java	42
rocketmq-iot-bridge/src/test/java/org/apache/rocketmq/iot/protocol/mqtt/handler/downstream/MqttMessageForwarderTest.java	104
rocketmq-iot-bridge/src/test/java/org/apache/rocketmq/iot/protocol/mqtt/handler/downstream/MqttPingreqMessageHandlerTest.java	59
rocketmq-iot-bridge/src/test/java/org/apache/rocketmq/iot/protocol/mqtt/handler/downstream/MqttSubscribeMessageHandlerTest.java	60
rocketmq-iot-bridge/src/test/java/org/apache/rocketmq/iot/protocol/mqtt/handler/downstream/MqttUnsubscribeMessageHandlerTest.java	64
rocketmq-iot-bridge/src/test/java/org/apache/rocketmq/iot/storage/subscription/InMemorySubscriptionTest.java	152
rocketmq-jms/core/src/test/java/org/apache/rocketmq/jms/JmsTestListener.java	43
rocketmq-jms/core/src/test/java/org/apache/rocketmq/jms/JmsTestUtil.java	33
rocketmq-jms/core/src/test/java/org/apache/rocketmq/jms/domain/message/JmsBytesMessageTest.java	57
rocketmq-jms/core/src/test/java/org/apache/rocketmq/jms/domain/message/JmsMessageConvertTest.java	39
rocketmq-jms/core/src/test/java/org/apache/rocketmq/jms/domain/message/JmsObjectMessageTest.java	62
rocketmq-jms/core/src/test/java/org/apache/rocketmq/jms/domain/message/JmsTextMessageTest.java	28
rocketmq-jms/core/src/test/java/org/apache/rocketmq/jms/integration/IntegrationTestBase.java	153
rocketmq-jms/core/src/test/java/org/apache/rocketmq/jms/integration/JmsClientIT.java	146
rocketmq-jms/core/src/test/java/org/apache/rocketmq/jms/integration/JmsConsumerIT.java	87
rocketmq-jms/core/src/test/java/org/apache/rocketmq/jms/util/URISpecParserTest.java	19
rocketmq-jms/spring/src/test/java/org/apache/rocketmq/jms/spring/JmsConsumeIT.java	39
rocketmq-jms/spring/src/test/java/org/apache/rocketmq/jms/spring/JmsProduceIT.java	63
rocketmq-jms/spring/src/test/java/org/apache/rocketmq/jms/spring/SpringTestBase.java	20
rocketmq-jms/spring/src/test/resources/consumer.xml	26
rocketmq-jms/spring/src/test/resources/producer.xml	21
rocketmq-knative/source/pkg/controller/sinks/sinks_test.go	228
rocketmq-logstash-integration/rocketmq-logstash-output/src/test/java/org/apache/rocketmq/logstashplugin/output/RocketMQTest.java	36
rocketmq-mysql/src/test/java/org/apache/rocketmq/mysql/BigIntColumnParserTest.java	14
rocketmq-mysql/src/test/java/org/apache/rocketmq/mysql/EnumColumnParserTest.java	13
rocketmq-mysql/src/test/java/org/apache/rocketmq/mysql/IntColumnParserTest.java	27
rocketmq-mysql/src/test/java/org/apache/rocketmq/mysql/SetColumnParserTest.java	13
rocketmq-redis/src/test/java/org/apache/rocketmq/redis/replicator/BaseConf.java	111
rocketmq-redis/src/test/java/org/apache/rocketmq/redis/replicator/IntegrationTestBase.java	150
rocketmq-redis/src/test/java/org/apache/rocketmq/redis/replicator/RocketMQRedisReplicatorTest.java	74
rocketmq-redis/src/test/java/org/apache/rocketmq/redis/replicator/mq/KryoEventSerializerTest.java	44
rocketmq-redis/src/test/resources/log4j2.xml	19
rocketmq-serializer/rocketmq-serializer-avro/src/test/avro/user.avsc	22
rocketmq-serializer/rocketmq-serializer-avro/src/test/java/org/apache/rocketmq/serializer/avro/RocketMQAvroSerializerTest.java	21
rocketmq-serializer/rocketmq-serializer-avro/src/test/java/org/apache/rocketmq/serializer/avro/RocketMQAvroSpecifiedSerializerTest.java	18
rocketmq-serializer/rocketmq-serializer-avro/src/test/java/org/apache/rocketmq/serializer/avro/User.java	163
rocketmq-serializer/rocketmq-serializer-core/src/test/java/org/apache/rocketmq/serializer/impl/RocketMQStringSerializerTest.java	13
rocketmq-serializer/rocketmq-serializer-json/src/test/java/org/apache/rocketmq/serializer/json/RocketMQJsonSerializerTest.java	15
rocketmq-serializer/rocketmq-serializer-json/src/test/java/org/apache/rocketmq/serializer/json/User.java	31
rocketmq-spark/src/test/java/org/apache/rocketmq/spark/RocketMQServerMock.java	86
rocketmq-spark/src/test/java/org/apache/rocketmq/spark/sql/RocketMQDataSourceTest.java	125
rocketmq-spark/src/test/java/org/apache/rocketmq/spark/streaming/MessageRetryManagerTest.java	74
rocketmq-spark/src/test/java/org/apache/rocketmq/spark/streaming/ReliableRocketMQReceiverTest.java	47
rocketmq-spark/src/test/java/org/apache/rocketmq/spark/streaming/RocketMQReceiverTest.java	68
rocketmq-spark/src/test/java/org/apache/rocketmq/spark/streaming/RocketMqUtilsTest.java	110