search

apache / rocketmq-mqtt

Apache rocketmq
https://rocketmq.apache.org/
Apache License 2.0
181 stars 63 forks source link

Feature Support：Will Message #174

Closed DongyuanPan closed 1 year ago

DongyuanPan commented 1 year ago

This PR implements the will message to to close #69 . This PR was developed based on #120, and the state machine of will message is implemented.

codecov-commenter commented 1 year ago

Codecov Report

Merging #174 (a16db9a) into develop (0a4c230) will decrease coverage by 3.23%. The diff coverage is 14.57%.

@@             Coverage Diff             @@
##           develop     #174      +/-   ##
===========================================
- Coverage    40.08%   36.84%   -3.24%     
===========================================
  Files          122      129       +7     
  Lines         5319     5995     +676     
  Branches       767      830      +63     
===========================================
+ Hits          2132     2209      +77     
- Misses        2824     3413     +589     
- Partials       363      373      +10
Impacted Files Coverage Δ
...g/apache/rocketmq/mqtt/common/model/Constants.java 0.00% <ø> (ø)
...apache/rocketmq/mqtt/common/model/WillMessage.java 0.00% <0.00%> (ø)
...a/org/apache/rocketmq/mqtt/cs/session/Session.java 52.29% <0.00%> (-0.61%) :arrow_down:
...rg/apache/rocketmq/mqtt/cs/starter/MqttServer.java 0.00% <ø> (ø)
...rg/apache/rocketmq/mqtt/ds/meta/MetaRpcClient.java 0.00% <0.00%> (ø)
...pache/rocketmq/mqtt/ds/meta/RetainedMsgClient.java 0.00% <ø> (ø)
...ketmq/mqtt/ds/meta/RetainedPersistManagerImpl.java 0.00% <ø> (ø)
...rg/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java 0.00% <0.00%> (ø)
...cketmq/mqtt/ds/meta/WillMsgPersistManagerImpl.java 0.00% <0.00%> (ø)
...org/apache/rocketmq/mqtt/example/MqttConsumer.java 0.00% <0.00%> (ø)
... and 19 more

:mega: We’re building smart automated test selection to slash your CI/CD build times. Learn more