opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-30 18:10:44 +08:00
Code Issues Packages Projects Releases Wiki Activity
943 Commits 72 Branches 40 Tags
mqtt
Commit Graph

943 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
xhpscdx a4270cff44 add mqttProcessor unit test (#1374) 2019-08-13 15:11:46 +08:00
Aaron-He 5813a8ba0e [RIP-11] Add persistence interface for mqtt session (#1297) 
* implements mqtt subscription persistence

* Refactor code follow RocketMQ coding style

* Add quering mqtt client interface & reformat code
 2019-07-08 10:36:34 +08:00
Heng Du 53a15b6323 Merge pull request #1245 from xiangwangcheng/mqtt 
[RIP-11] add logic of resending messages when ack-timeout
 2019-06-05 10:18:02 +08:00
chengxiangwang f0ad359ca1 add logic of resending msg when acktimeout 2019-06-04 17:49:07 +08:00
chengxiangwang caf1439718 add test case(unfinished) 2019-06-04 17:49:07 +08:00
Heng Du b807cc3f92 Merge pull request #1234 from xiangwangcheng/mqtt 
[RIP-11]fulfill logic of pull message/push offline messages when reconnected/add test case
 2019-05-29 15:33:15 +08:00
chengxiangwang c4297921fd add test case(unfinished) 2019-05-28 16:06:23 +08:00
chengxiangwang 5481c2bc02 add logic of push messages when reconnected;add logic of transfer qos1 messages 2019-05-28 16:06:22 +08:00
chengxiangwang 947d558ae9 fulfill logic of pull messages from enode 2019-05-28 16:06:22 +08:00
Heng Du b1a0b485cc Merge pull request #1209 from xiangwangcheng/mqtt 
[RIP-11]polish data structure of IOTClientManager; add logic of triggering push message to consumers
 2019-05-27 09:24:25 +08:00
chengxiangwang 45d8d04ce1 add logic of persist consumeOffset;polish logic of PUBLISH messages to clients(consumers) 2019-05-22 16:58:37 +08:00
chengxiangwang 25ba6fabd0 optimize logic of push message to consumers;add MQTTSession(extends Client) 2019-05-14 20:13:02 +08:00
chengxiangwang f8da6ffa63 optimize Client of IOT; add in-flight window 2019-05-14 20:12:56 +08:00
chengxiangwang e010ca74d6 polish data structure of IOTClientManager;add message forward logic 2019-05-14 20:10:46 +08:00
Heng Du 4f8cd91cf4 Merge pull request #1197 from xiangwangcheng/mqtt 
interface adjustment(interface sinking) of snode/client module
 2019-05-07 16:03:11 +08:00
chengxiangwang 4547be6fd2 Merge branch 'mqtt' of https://github.com/xiangwangcheng/rocketmq into mqtt 2019-05-05 22:22:31 +08:00
chengxiangwang b0e78bf1cc add MqttRuntimeException.java;change dledger version to 0.2-SNAPSHOT 2019-05-05 22:20:21 +08:00
chengxiangwang 6a12998836 add MqttRuntimeException.java;change dledger version to 0.2-SNAPSHOT 2019-05-05 22:08:41 +08:00
chengxiangwang 5624f1c01d Merge branch 'qos1' into mqtt 2019-04-09 17:58:58 +08:00
chengxiangwang 49769d0c86 move interface from snode to common 2019-04-09 17:41:07 +08:00
Heng Du b2169653c9 Merge pull request #1116 from Aaron-He/mqtt 
Implementation of handling MQTT client PINGREQ
 2019-03-26 09:18:59 +08:00
HeChengyang 36c21740ff Implementation of handling MQTT client PINGREQ 2019-03-25 17:58:49 +08:00
Heng Du a3c17c665d Merge pull request #1067 from xiangwangcheng/snode 
[RIP-11]Move mqtt-related code to a new module rocketmq-mqtt
 2019-03-15 22:05:34 +08:00
chengxiangwang 3629a0a717 add new module rocketmq-mqtt 2019-03-08 15:02:33 +08:00
Heng Du a1f4358ebf Merge pull request #842 from xiangwangcheng/snode 
[RIP-11]MQTT:completing  pub and sub logic of qos=0 messages(single node only )
 2019-03-07 19:57:32 +08:00
ShannonDing 66e15cfa11 Send subscription to snode when using real push 2019-02-28 17:50:52 +08:00
ShannonDing 4dbf4160d9 Polish Push consumer 2019-02-28 17:41:07 +08:00
chengxiangwang c36f09aa56 1.add mqttServerConfig/mqttClientConfig 2.delete payload from RemotingCommand 2019-02-27 15:47:24 +08:00
chengxiangwang bd21a92d69 add MqttConfig.java 2019-02-26 23:17:30 +08:00
chengxiangwang 5a3102d9f4 completing qos=0 message pub and sub 2019-02-26 23:15:23 +08:00
duhenglucky e2c697bf59 Modify checkstyle remove chinese characters 2019-02-25 10:46:34 +08:00
ShannonDing 0235a706e2 Refactor imports 2019-02-25 10:38:41 +08:00
duhenglucky 27296f1d22 Fix the incompatibility issue of 4.x client in broker 2019-02-25 09:55:54 +08:00
ShannonDing 923a7666af Merge branch 'snode' of github.com:apache/rocketmq into snode 2019-02-23 21:40:01 +08:00
ShannonDing 2669a5c4d8 Support origin 4.x 2019-02-23 21:39:23 +08:00
duhenglucky 3706778b21 Add lockMQ function for support order message 2019-02-23 21:32:41 +08:00
ShannonDing 510bb34fe9 Merge branch 'snode' of github.com:apache/rocketmq into snode 2019-02-23 19:22:51 +08:00
duhenglucky 41d5adc08e Merge branch 'snode' of github.com:apache/rocketmq into snode 2019-02-23 16:26:58 +08:00
duhenglucky ff6b687151 Fix the issue of storesize and bornhost inaccurate in push message 2019-02-23 16:26:37 +08:00
ShannonDing a23ef1b020 Merge branch 'snode' of github.com:apache/rocketmq into snode 2019-02-22 19:43:20 +08:00
Heng Du 509bce4d5d Merge pull request #864 from ShannonDing/snode 
Polish the push consumer to support 4.x
 2019-02-22 19:37:29 +08:00
ShannonDing f7e2b1f82e Merge branch 'snode' of github.com:apache/rocketmq into snode 2019-02-22 19:30:01 +08:00
ShannonDing fbe64ffbe5 Polish the push consumer to support 4.x 2019-02-22 19:28:23 +08:00
duhenglucky 14a75e5ccc Add embedded start mode(single service) for snode and enode 2019-02-22 01:57:39 +08:00
dinglei d7a2603c17 [RIP-11] Recover pull request for old message queue that is allocated on rebalance.(#827) 
[RIP-11] Recover pull request for old message queue that is allocated on rebalance.
 2019-02-20 16:41:54 +08:00
Heng Du 1c26991d6b Merge pull request #755 from xiangwangcheng/snode 
[RIP-11]Add SessionManager and WillMessageService; finish CONNECT/DISCONNECT logic
 2019-02-20 10:14:12 +08:00
duhenglucky 1dde4fe7f2 Polish rebalance process in real push mode 2019-02-19 21:40:23 +08:00
ShannonDing 3c264c8f2c Polish push message process in client(add broker name) 2019-02-19 17:30:24 +08:00
duhenglucky 8e124956b8 Merge branch 'snode' of github.com:apache/rocketmq into snode 2019-02-19 16:26:23 +08:00
duhenglucky 28a8d649fa Fix the push subscription not update issue 2019-02-19 16:26:02 +08:00