This is an automated email from the ASF dual-hosted git repository. pingww pushed a commit to branch develop_mqtt5.0 in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git
commit 82677ec302245de7fa88283471fd3fdec664efd0 Merge: 7dbaa4d 81da9d7 Author: pingww <[email protected]> AuthorDate: Wed Mar 13 11:14:03 2024 +0800 Merge pull request #249 from DongyuanPan/MQTT_5.0 [ISSUE #241] support topic alias .../mqtt/common/hook/AbstractUpstreamHook.java | 2 +- .../mqtt/common/model/MqttMessageUpContext.java | 11 ++++ .../rocketmq/mqtt/common/util/MessageUtil.java | 14 ++++ .../rocketmq/mqtt/cs/channel/ChannelInfo.java | 53 +++++++++++++++ .../rocketmq/mqtt/cs/channel/ChannelManager.java | 2 +- .../mqtt/cs/channel/DefaultChannelManager.java | 6 +- .../rocketmq/mqtt/cs/config/ConnectConf.java | 9 +++ .../cs/protocol/mqtt/MqttPacketDispatcher.java | 1 + .../protocol/mqtt/facotry/MqttMessageFactory.java | 37 +++++++---- .../cs/protocol/mqtt5/Mqtt5PacketDispatcher.java | 1 + .../mqtt5/handler/Mqtt5ConnectHandler.java | 76 ++++++++++++---------- .../mqtt5/handler/Mqtt5DisconnectHandler.java | 2 +- .../protocol/mqtt5/handler/Mqtt5PubRecHandler.java | 4 +- .../protocol/mqtt5/handler/Mqtt5PubRelHandler.java | 4 +- .../mqtt5/handler/Mqtt5PublishHandler.java | 45 ++++++++----- .../mqtt5/handler/Mqtt5SubscribeHandler.java | 47 +++++++------ .../mqtt5/handler/Mqtt5UnSubscribeHandler.java | 24 ++++--- .../rocketmq/mqtt/cs/session/infly/PushAction.java | 45 ++++++++++++- .../mqtt5/handler/TestMqtt5PublishHandler.java | 29 +++++++++ .../mqtt5/handler/TestMqtt5SubscribeHandler.java | 1 - .../mqtt5/processor/PublishProcessor5.java | 17 +++++ .../mqtt5/processor/TestPublishProcessor.java | 45 +++++++++++-- .../rocketmq/mqtt/example/mqtt5/Mqtt5Consumer.java | 1 + .../rocketmq/mqtt/example/mqtt5/Mqtt5Producer.java | 1 + 24 files changed, 365 insertions(+), 112 deletions(-)
