This is an automated email from the ASF dual-hosted git repository.
dongyuanpan pushed a change to branch develop_mqtt5.0
in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git
from 5397e58 Support some simple feature (#254)
add 328f969 implement flow control for mqtt5.0
add 2ef341c Merge branch 'develop_mqtt5.0' into flow_control
add f3cadac update
add 67fe74f update by review comment
new b210bd5 Merge pull request #279 from YxAc/flow_control
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../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(-)
