This is an automated email from the ASF dual-hosted git repository.
dongyuanpan pushed a commit to branch develop_coap
in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git
commit 62cd8e366086098a9dcabf1b14f980ce844a8d3b
Merge: b210bd5 4d2e294
Author: Dongyuan Pan <dongyuanp...@gmail.com>
AuthorDate: Thu Jun 27 09:57:46 2024 +0800
Merge pull request #290 from apache/develop_mqtt5.0
merge develop_mqtt5.0 to develop_coap
distribution/conf/spring.xml | 2 +-
docs/quic.md | 16 ++
mqtt-common/pom.xml | 5 +
.../rocketmq/mqtt/common/facade/LmqQueueStore.java | 9 ++
.../mqtt/common/hook/AbstractUpstreamHook.java | 5 +-
.../rocketmq/mqtt/common/hook/EventHook.java | 45 ++++++
.../mqtt/common/hook/EventHookManager.java | 42 +++++
.../rocketmq/mqtt/common/model/ClientEvent.java | 123 ++++++++++++++
.../rocketmq/mqtt/common/model/Constants.java | 6 +
.../rocketmq/mqtt/common/model/EventType.java | 23 +++
.../rocketmq/mqtt/common/util/NetworkHelper.java | 35 ++++
.../mqtt/common/test/model/TestClientEvent.java | 57 +++++++
mqtt-cs/pom.xml | 11 +-
.../mqtt/cs/channel/AdaptiveTlsHandler.java | 93 +++++++++++
.../mqtt/cs/channel/DefaultChannelManager.java | 33 +++-
.../rocketmq/mqtt/cs/config/ConnectConf.java | 32 ++++
.../mqtt/cs/hook/EventHookManagerImpl.java | 171 ++++++++++++++++++++
.../protocol/mqtt/handler/MqttConnectHandler.java | 8 +
.../rocketmq/mqtt/cs/protocol/ssl/SslFactory.java | 30 +++-
.../rocketmq/mqtt/cs/session/loop/QueueCache.java | 35 ++--
.../mqtt/cs/session/loop/SessionLoopImpl.java | 3 +-
.../rocketmq/mqtt/cs/starter/MqttServer.java | 177 +++++++++++++++++----
.../cs/test/hook/TestEventHookManagerImpl.java | 135 ++++++++++++++++
.../cs/test/hook/TestUpstreamHookManagerImpl.java | 28 ++--
.../mqtt/handler/TestMqttConnectHandler.java | 9 ++
.../cs/test/session/infly/TestRetryDriver.java | 30 ++--
.../rocketmq/mqtt/ds/auth/AuthManagerSample.java | 9 ++
.../ds/event/processor/ClientEventProcessor.java | 107 +++++++++++++
.../rocketmq/mqtt/ds/notify/NotifyManager.java | 15 +-
.../mqtt/ds/store/LmqQueueStoreManager.java | 65 ++++++++
.../ds/upstream/mqtt/UpstreamProcessorManager.java | 10 +-
.../upstream/mqtt/processor/PublishProcessor.java | 12 +-
.../event/processor/TestClientEventProcessor.java | 97 +++++++++++
.../ds/test/meta/TestMetaPersistManagerSample.java | 10 +-
.../mqtt/ds/test/notify/TestNotifyManager.java | 2 +-
.../ds/test/store/TestLmqQueueStoreManager.java | 17 ++
.../mqtt/processor/TestPublishProcessor.java | 29 ++--
.../mqtt5/processor/TestPublishProcessor.java | 3 +-
.../mqtt/example/MqttClientEventConsumer.java | 144 +++++++++++++++++
.../exporter/collector/MqttMetricsCollector.java | 24 +++
.../mqtt/exporter/collector/MqttMetricsInfo.java | 15 +-
pom.xml | 22 ++-
42 files changed, 1624 insertions(+), 120 deletions(-)
