This is an automated email from the ASF dual-hosted git repository.
dongyuanpan pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git
from 495d573 [ISSUE #274] Fix startup exception (#276)
add a3c83b3 define client event hook/msg
add 666d352 support client online/offline event notification
add 4b7000e format code style
add e0f376b update
add 5fe1fa0 format code
add 58cb449 refact event hook
add 0ad5f0d add example for client event consuming with RMQ SDK or MQTT
Client
add a911e70 fix error
new 0df9d9d Merge pull request #283 from YxAc/online_offline_event_develop
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/common/facade/LmqQueueStore.java | 9 ++
.../mqtt/common/hook/AbstractUpstreamHook.java | 7 +-
.../WillMsgSender.java => hook/EventHook.java} | 26 +++-
.../hook/{Hook.java => EventHookManager.java} | 22 ++-
.../rocketmq/mqtt/common/model/ClientEvent.java | 123 +++++++++++++++
.../rocketmq/mqtt/common/model/Constants.java | 6 +
.../model/{RpcHeader.java => EventType.java} | 6 +-
.../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 ++--
...tConsumer.java => MqttClientEventConsumer.java} | 68 ++++++--
.../exporter/collector/MqttMetricsCollector.java | 8 +
.../mqtt/exporter/collector/MqttMetricsInfo.java | 5 +-
23 files changed, 954 insertions(+), 77 deletions(-)
copy
mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/{facade/WillMsgSender.java
=> hook/EventHook.java} (53%)
copy mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/hook/{Hook.java
=> EventHookManager.java} (70%)
create mode 100644
mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/ClientEvent.java
copy
mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/{RpcHeader.java
=> EventType.java} (90%)
create mode 100644
mqtt-common/src/test/java/org/apache/rocketmq/mqtt/common/test/model/TestClientEvent.java
create mode 100644
mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/hook/EventHookManagerImpl.java
create mode 100644
mqtt-cs/src/test/java/org/apache/rocketmq/mqtt/cs/test/hook/TestEventHookManagerImpl.java
create mode 100644
mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/event/processor/ClientEventProcessor.java
create mode 100644
mqtt-ds/src/test/java/org/apache/rocketmq/mqtt/ds/test/event/processor/TestClientEventProcessor.java
copy
mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/{MqttConsumer.java
=> MqttClientEventConsumer.java} (57%)
