[rocketmq-mqtt] branch main updated (3a8b982 -> aba2165)

[pi...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

pingww pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git


    from 3a8b982  Merge pull request #107 from tianliuliu/fix_fastjson
     new 4f70824  Fix the bug of Get Start in Readme
     new 3d42181  Tips for optimizing broker configuration
     new 4b953ec  Merge branch 'apache:main' into main
     new a072645  add kv
     new 8c7462a  rm data
     new 7751b65  bug fix
     new de1a2f6  init version kv
     new 13a2017  init version kv
     new 46c6e3b  init version kv
     new 8712e58  change store path
     new 8351deb  add sofa kv
     new c26d977  add doc
     new fe47b08  fix doc
     new 2fab079  fix code style
     new d52e441  add license in config file
     new a41c7d1  add license in test file
     new a9e0c91  roll back addSubscriptionAndInit
     new aba2165  Merge pull request #110 from DongyuanPan/dev

The 129 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:
 README.md                                          |  17 +-
 assembly.xml                                       |   1 +
 bin/{mqtt.sh => meta.sh}                           |   3 +-
 conf/{connect.conf => meta.conf}                   |   4 +-
 conf/{spring.xml => meta_spring.xml}               |   8 +-
 meta/pom.xml                                       | 140 +++
 .../apache/rocketmq/mqtt/meta/config/MetaConf.java |  93 ++
 .../mqtt/meta/config/MetaConfListener.java         |  27 +-
 .../apache/rocketmq/mqtt/meta/core/MetaClient.java | 948 +++++++++++++++++++++
 .../apache/rocketmq/mqtt/meta/core/MetaServer.java |  97 +++
 .../org/apache/rocketmq/mqtt/meta/core/Node.java   |  47 +-
 .../rocketmq/mqtt/meta}/starter/Startup.java       |  13 +-
 .../org/apache/rocketmq/mqtt/meta/util/IpUtil.java |  98 +++
 .../apache/rocketmq/mqtt/meta/util/SpringUtil.java |  30 +-
 .../apache/rocketmq/mqtt/meta/util/IpUtilTest.java |  58 ++
 .../rocketmq/mqtt/ds/config/ServiceConf.java       |  45 +
 pom.xml                                            |   1 +
 17 files changed, 1552 insertions(+), 78 deletions(-)
 copy bin/{mqtt.sh => meta.sh} (97%)
 copy conf/{connect.conf => meta.conf} (96%)
 copy conf/{spring.xml => meta_spring.xml} (84%)
 create mode 100644 meta/pom.xml
 create mode 100644 meta/src/main/java/org/apache/rocketmq/mqtt/meta/config/MetaConf.java
 copy mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config/ConnectConfListener.java => meta/src/main/java/org/apache/rocketmq/mqtt/meta/config/MetaConfListener.java (88%)
 create mode 100644 meta/src/main/java/org/apache/rocketmq/mqtt/meta/core/MetaClient.java
 create mode 100644 meta/src/main/java/org/apache/rocketmq/mqtt/meta/core/MetaServer.java
 copy mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/MqttMessageUpContext.java => meta/src/main/java/org/apache/rocketmq/mqtt/meta/core/Node.java (51%)
 copy {mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs => meta/src/main/java/org/apache/rocketmq/mqtt/meta}/starter/Startup.java (79%)
 create mode 100644 meta/src/main/java/org/apache/rocketmq/mqtt/meta/util/IpUtil.java
 copy mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/MqttTopic.java => meta/src/main/java/org/apache/rocketmq/mqtt/meta/util/SpringUtil.java (55%)
 create mode 100644 meta/src/test/java/org/apache/rocketmq/mqtt/meta/util/IpUtilTest.java