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 2c8289e Merge pull request #199 from DongyuanPan/fixNullPointInWill
new 501ade3 Merge pull request #179 from apache/develop
new 1d0b869 [ISSUE #44] Support shared subscription
new e69841d Merge pull request #194 from
ferrirW/support-shared-subscription-model-dev
The 319 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 | 15 ++
.../rocketmq/mqtt/common/model/Constants.java | 3 +
.../rocketmq/mqtt/common/model/PullResult.java | 1 +
.../apache/rocketmq/mqtt/common/model/Queue.java | 4 +
.../rocketmq/mqtt/common/model/Subscription.java | 11 ++
.../rocketmq/mqtt/common/util/TopicUtils.java | 25 +++
.../apache/rocketmq/mqtt/cs/session/Session.java | 3 +
.../rocketmq/mqtt/cs/session/infly/PushAction.java | 7 +
.../rocketmq/mqtt/cs/session/loop/QueueCache.java | 9 +-
.../mqtt/cs/session/loop/SessionLoopImpl.java | 3 +-
.../rocketmq/mqtt/ds/notify/NotifyManager.java | 2 +
.../mqtt/ds/store/LmqQueueStoreManager.java | 182 +++++++++++++++++++++
pom.xml | 2 +-
13 files changed, 264 insertions(+), 3 deletions(-)
