This is an automated email from the ASF dual-hosted git repository. dongyuanpan pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git
commit 0df9d9d06cd9c17aff35697ffd648d0f4b835088 Merge: 495d573 a911e70 Author: Dongyuan Pan <[email protected]> AuthorDate: Wed Jun 19 17:53:05 2024 +0800 Merge pull request #283 from YxAc/online_offline_event_develop [ISSUE #116] feat: support client event notification .../rocketmq/mqtt/common/facade/LmqQueueStore.java | 9 ++ .../mqtt/common/hook/AbstractUpstreamHook.java | 7 +- .../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 +++ .../mqtt/common/test/model/TestClientEvent.java | 57 +++++++ .../mqtt/cs/channel/DefaultChannelManager.java | 12 +- .../mqtt/cs/hook/EventHookManagerImpl.java | 171 +++++++++++++++++++++ .../protocol/mqtt/handler/MqttConnectHandler.java | 8 + .../cs/test/hook/TestEventHookManagerImpl.java | 135 ++++++++++++++++ .../cs/test/hook/TestUpstreamHookManagerImpl.java | 28 ++-- .../mqtt/handler/TestMqttConnectHandler.java | 9 ++ .../cs/test/session/infly/TestRetryDriver.java | 30 ++-- .../ds/event/processor/ClientEventProcessor.java | 107 +++++++++++++ .../mqtt/ds/store/LmqQueueStoreManager.java | 51 ++++++ .../event/processor/TestClientEventProcessor.java | 97 ++++++++++++ .../ds/test/store/TestLmqQueueStoreManager.java | 17 ++ .../upstream/processor/TestPublishProcessor.java | 29 ++-- .../mqtt/example/MqttClientEventConsumer.java | 144 +++++++++++++++++ .../exporter/collector/MqttMetricsCollector.java | 8 + .../mqtt/exporter/collector/MqttMetricsInfo.java | 5 +- 23 files changed, 1112 insertions(+), 51 deletions(-)
