This is an automated email from the ASF dual-hosted git repository.
pingww pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git
from 748c841 Merge pull request #131 from YYYYWD/develop
new 070554f use openssl provider instead of jdk provider to improve
performance (#123)
new f330b32 removed meta kv which will be possible to implement directly
using a raft state machine
new b0d2190 Merge pull request #139 from pingww/main
new 93a9855 fix #88
new 0fb52d1 Merge pull request #140 from pingww/main
new 5e149d9 pkg
new 53db903 pkg
new 6661232 pkg
new c2ff842 pkg
new b4e3ba8 pkg
new 88bf710 pkg
new 05e9309 [maven-release-plugin] prepare release rocketmq-mqtt-1.0.0
new 88e2362 [maven-release-plugin] prepare for next development iteration
new 73f1d11 pkg
new 6de81c5 pkh
new 2239839 [maven-release-plugin] prepare release rocketmq-mqtt-1.0.0
new 3b4dd1e pkg
new 679eccd [maven-release-plugin] prepare release rocketmq-mqtt-1.0.0
new 4242f6b [maven-release-plugin] prepare for next development iteration
new 9dcc191 distributioin
new 69544fe Merge pull request #145 from pingww/main
new cda0ac8 readme
new af8fde4 Merge pull request #146 from pingww/main
new 32f0dc2 Update .asf.yaml
new 3f8db8b merge main
new 01fb72b merge main: fix conflict
new eccebec Merge pull request #158 from DongyuanPan/develop_merge_main
The 218 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:
.asf.yaml | 6 ++
README.md | 13 +----
conf/meta_spring.xml | 4 +-
{bin => distribution/bin}/meta.sh | 2 +-
{bin => distribution/bin}/mqtt.sh | 0
{bin => distribution/bin}/runserver.sh | 0
{conf => distribution/conf}/connect.conf | 0
{conf => distribution/conf}/logback.xml | 0
{conf => distribution/conf}/service.conf | 0
{conf => distribution/conf}/spring.xml | 0
distribution/pom.xml | 62 ++++++++++++++++++++
assembly.xml => distribution/release.xml | 26 ++++++---
.../apache/rocketmq/mqtt/meta/starter/Startup.java | 32 -----------
mqtt-common/pom.xml | 6 +-
mqtt-cs/pom.xml | 6 +-
.../rocketmq/mqtt/cs/protocol/ssl/SslFactory.java | 3 +-
.../mqtt/cs/session/loop/SessionLoopImpl.java | 8 ++-
mqtt-ds/pom.xml | 10 +---
mqtt-example/pom.xml | 6 +-
mqtt-exporter/pom.xml | 6 +-
{meta => mqtt-meta}/pom.xml | 6 +-
.../apache/rocketmq/mqtt/meta/config/MetaConf.java | 0
.../mqtt/meta/config/MetaConfListener.java | 2 +-
.../rocketmq/mqtt/meta/raft/FailoverClosure.java | 0
.../rocketmq/mqtt/meta/raft/MqttClosure.java | 0
.../rocketmq/mqtt/meta/raft/MqttRaftServer.java | 0
.../rocketmq/mqtt/meta/raft/MqttStateMachine.java | 0
.../rocketmq/mqtt/meta/raft/RaftGroupHolder.java | 0
.../meta/raft/processor/AbstractRpcProcessor.java | 0
.../mqtt/meta/raft/processor/Constants.java | 0
.../meta/raft/processor/CounterStateProcessor.java | 0
.../meta/raft/processor/MqttReadRpcProcessor.java | 0
.../meta/raft/processor/MqttWriteRpcProcessor.java | 2 +-
.../raft/processor/RetainedMsgStateProcessor.java | 0
.../mqtt/meta/raft/processor/StateProcessor.java | 0
.../raft/snapshot/AbstractSnapshotOperation.java | 0
.../mqtt/meta/raft/snapshot/SnapshotOperation.java | 0
.../snapshot/impl/CounterSnapshotOperation.java | 0
.../apache/rocketmq/mqtt/meta/starter/Startup.java | 31 ++++++++++
.../apache/rocketmq/mqtt/meta/util/DiskUtils.java | 0
.../org/apache/rocketmq/mqtt/meta/util/IpUtil.java | 4 +-
.../rocketmq/mqtt/meta/util/RaftExecutor.java | 0
.../apache/rocketmq/mqtt/meta/util/SpringUtil.java | 2 +-
.../rocketmq/mqtt/meta/raft/CounterClient.java | 0
.../mqtt/meta/raft/RetainedMsgClientTest.java | 0
.../apache/rocketmq/mqtt/meta/util/IpUtilTest.java | 0
pom.xml | 67 +++++++++++++++++-----
47 files changed, 204 insertions(+), 100 deletions(-)
rename {bin => distribution/bin}/meta.sh (99%)
rename {bin => distribution/bin}/mqtt.sh (100%)
rename {bin => distribution/bin}/runserver.sh (100%)
rename {conf => distribution/conf}/connect.conf (100%)
rename {conf => distribution/conf}/logback.xml (100%)
rename {conf => distribution/conf}/service.conf (100%)
rename {conf => distribution/conf}/spring.xml (100%)
create mode 100644 distribution/pom.xml
rename assembly.xml => distribution/release.xml (77%)
delete mode 100644
meta/src/main/java/org/apache/rocketmq/mqtt/meta/starter/Startup.java
rename {meta => mqtt-meta}/pom.xml (93%)
rename {meta =>
mqtt-meta}/src/main/java/org/apache/rocketmq/mqtt/meta/config/MetaConf.java
(100%)
rename {meta =>
mqtt-meta}/src/main/java/org/apache/rocketmq/mqtt/meta/config/MetaConfListener.java
(99%)
rename {meta =>
mqtt-meta}/src/main/java/org/apache/rocketmq/mqtt/meta/raft/FailoverClosure.java
(100%)
rename {meta =>
mqtt-meta}/src/main/java/org/apache/rocketmq/mqtt/meta/raft/MqttClosure.java
(100%)
rename {meta =>
mqtt-meta}/src/main/java/org/apache/rocketmq/mqtt/meta/raft/MqttRaftServer.java
(100%)
rename {meta =>
mqtt-meta}/src/main/java/org/apache/rocketmq/mqtt/meta/raft/MqttStateMachine.java
(100%)
rename {meta =>
mqtt-meta}/src/main/java/org/apache/rocketmq/mqtt/meta/raft/RaftGroupHolder.java
(100%)
rename {meta =>
mqtt-meta}/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/AbstractRpcProcessor.java
(100%)
rename {meta =>
mqtt-meta}/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/Constants.java
(100%)
rename {meta =>
mqtt-meta}/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/CounterStateProcessor.java
(100%)
rename {meta =>
mqtt-meta}/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/MqttReadRpcProcessor.java
(100%)
rename {meta =>
mqtt-meta}/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/MqttWriteRpcProcessor.java
(99%)
rename {meta =>
mqtt-meta}/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/RetainedMsgStateProcessor.java
(100%)
rename {meta =>
mqtt-meta}/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/StateProcessor.java
(100%)
rename {meta =>
mqtt-meta}/src/main/java/org/apache/rocketmq/mqtt/meta/raft/snapshot/AbstractSnapshotOperation.java
(100%)
rename {meta =>
mqtt-meta}/src/main/java/org/apache/rocketmq/mqtt/meta/raft/snapshot/SnapshotOperation.java
(100%)
rename {meta =>
mqtt-meta}/src/main/java/org/apache/rocketmq/mqtt/meta/raft/snapshot/impl/CounterSnapshotOperation.java
(100%)
create mode 100644
mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/starter/Startup.java
rename {meta =>
mqtt-meta}/src/main/java/org/apache/rocketmq/mqtt/meta/util/DiskUtils.java
(100%)
rename {meta =>
mqtt-meta}/src/main/java/org/apache/rocketmq/mqtt/meta/util/IpUtil.java (99%)
rename {meta =>
mqtt-meta}/src/main/java/org/apache/rocketmq/mqtt/meta/util/RaftExecutor.java
(100%)
rename {meta =>
mqtt-meta}/src/main/java/org/apache/rocketmq/mqtt/meta/util/SpringUtil.java
(99%)
rename {meta =>
mqtt-meta}/src/test/java/org/apache/rocketmq/mqtt/meta/raft/CounterClient.java
(100%)
rename {meta =>
mqtt-meta}/src/test/java/org/apache/rocketmq/mqtt/meta/raft/RetainedMsgClientTest.java
(100%)
rename {meta =>
mqtt-meta}/src/test/java/org/apache/rocketmq/mqtt/meta/util/IpUtilTest.java
(100%)
