This is an automated email from the ASF dual-hosted git repository. dongyuanpan pushed a commit to branch develop_mqtt5.0 in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git
commit b210bd56be3fea8428b965ed0b3445a1ecf844db Merge: 5397e58 67fe74f Author: Dongyuan Pan <[email protected]> AuthorDate: Wed Jun 19 17:51:56 2024 +0800 Merge pull request #279 from YxAc/flow_control [ISSUE #246] feat: implement flow control .../rocketmq/mqtt/cs/channel/ChannelManager.java | 2 - .../mqtt/cs/channel/DefaultChannelManager.java | 1 - .../rocketmq/mqtt/cs/config/ConnectConf.java | 9 ++ .../mqtt5/handler/Mqtt5ConnectHandler.java | 2 + .../protocol/mqtt5/handler/Mqtt5PubAckHandler.java | 5 +- .../mqtt5/handler/Mqtt5PubCompHandler.java | 7 +- .../protocol/mqtt5/handler/Mqtt5PubRelHandler.java | 8 + .../mqtt5/handler/Mqtt5PublishHandler.java | 29 ++++ .../apache/rocketmq/mqtt/cs/session/Session.java | 99 +++++++++++++ .../rocketmq/mqtt/cs/session/infly/PushAction.java | 8 +- .../mqtt/cs/session/loop/SessionLoopImpl.java | 1 + .../cs/test/channel/TestDefaultChannelManager.java | 162 +++++++++++---------- .../rocketmq/mqtt/cs/test/session/TestSession.java | 99 +++++++++++-- 13 files changed, 332 insertions(+), 100 deletions(-)
