You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@rocketmq.apache.org by di...@apache.org on 2022/04/18 03:10:44 UTC

[rocketmq-mqtt] branch main updated (1393642 -> eba371f)

This is an automated email from the ASF dual-hosted git repository.

dinglei pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git


    from 1393642  code optimization and codeCov enhancing of mqtt.cs.protocol.mqtt.handler for #22 (#63)
     add eba371f  [ISSUE #22] codeCov of protocol.mqtt and protocol.rpc (#67)

No new revisions were added by this update.

Summary of changes:
 .../cs/protocol/mqtt/MqttPacketDispatcher.java     |   4 -
 .../mqtt/handler/MqttSubscribeHandler.java         |   7 --
 .../mqtt/handler/MqttUnSubscribeHandler.java       |   4 -
 .../rocketmq/mqtt/cs/test/TestConnectHandler.java  |  66 -----------
 .../protocol/mqtt/TestMqttPacketDispatcher.java    | 121 +++++++++++++++++++++
 ...tHandler.java => TestMqttSubscribeHandler.java} |  89 ++++++++-------
 ...andler.java => TestMqttUnSubscribeHandler.java} |  99 ++++++++---------
 .../test/protocol/rpc/TestRpcPacketDispatcher.java |  95 ++++++++++++++++
 8 files changed, 311 insertions(+), 174 deletions(-)
 delete mode 100644 mqtt-cs/src/test/java/org/apache/rocketmq/mqtt/cs/test/TestConnectHandler.java
 create mode 100644 mqtt-cs/src/test/java/org/apache/rocketmq/mqtt/cs/test/protocol/mqtt/TestMqttPacketDispatcher.java
 copy mqtt-cs/src/test/java/org/apache/rocketmq/mqtt/cs/test/protocol/mqtt/handler/{TestMqttConnectHandler.java => TestMqttSubscribeHandler.java} (52%)
 copy mqtt-cs/src/test/java/org/apache/rocketmq/mqtt/cs/test/protocol/mqtt/handler/{TestMqttConnectHandler.java => TestMqttUnSubscribeHandler.java} (50%)
 create mode 100644 mqtt-cs/src/test/java/org/apache/rocketmq/mqtt/cs/test/protocol/rpc/TestRpcPacketDispatcher.java