From commits-return-3513-apmail-rocketmq-commits-archive=rocketmq.apache.org@rocketmq.apache.org Wed Jun 5 02:18:11 2019 Return-Path: X-Original-To: apmail-rocketmq-commits-archive@minotaur.apache.org Delivered-To: apmail-rocketmq-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [207.244.88.153]) by minotaur.apache.org (Postfix) with SMTP id 3D3F819E13 for ; Wed, 5 Jun 2019 02:18:11 +0000 (UTC) Received: (qmail 26858 invoked by uid 500); 5 Jun 2019 02:18:10 -0000 Delivered-To: apmail-rocketmq-commits-archive@rocketmq.apache.org Received: (qmail 26822 invoked by uid 500); 5 Jun 2019 02:18:10 -0000 Mailing-List: contact commits-help@rocketmq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@rocketmq.apache.org Delivered-To: mailing list commits@rocketmq.apache.org Received: (qmail 26813 invoked by uid 99); 5 Jun 2019 02:18:10 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 05 Jun 2019 02:18:10 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id E5A3F8AAB6; Wed, 5 Jun 2019 02:18:09 +0000 (UTC) Date: Wed, 05 Jun 2019 02:18:09 +0000 To: "commits@rocketmq.apache.org" Subject: [rocketmq] branch mqtt updated (b807cc3 -> 53a15b6) MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit Message-ID: <155970108954.18894.1092547743903633406@gitbox.apache.org> From: duhengforever@apache.org X-Git-Host: gitbox.apache.org X-Git-Repo: rocketmq X-Git-Refname: refs/heads/mqtt X-Git-Reftype: branch X-Git-Oldrev: b807cc3f9262d1ed8c36ecc1e15ca15a4b7d7a35 X-Git-Newrev: 53a15b63238b3fcdbbb9495f2ae57f460558f83f X-Git-NotificationType: ref_changed X-Git-Multimail-Version: 1.5.dev Auto-Submitted: auto-generated This is an automated email from the ASF dual-hosted git repository. duhengforever pushed a change to branch mqtt in repository https://gitbox.apache.org/repos/asf/rocketmq.git. from b807cc3 Merge pull request #1234 from xiangwangcheng/mqtt new caf1439 add test case(unfinished) new f0ad359 add logic of resending msg when acktimeout new 53a15b6 Merge pull request #1245 from xiangwangcheng/mqtt The 941 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: .../org/apache/rocketmq/common/MqttConfig.java | 10 ++ .../rocketmq/common/service/NnodeService.java | 2 +- .../rocketmq/mqtt/client/IOTClientManagerImpl.java | 10 +- .../rocketmq/mqtt/client/InFlightMessage.java | 9 +- .../rocketmq/mqtt/client/InFlightPacket.java | 89 ++++++++++++++++ .../apache/rocketmq/mqtt/client/MQTTSession.java | 49 ++------- .../rocketmq/mqtt/constant/MqttConstant.java | 1 + .../impl/MqttSubscribeMessageHandler.java | 12 +-- .../service/impl/MqttScheduledServiceImpl.java | 38 +++++++ .../apache/rocketmq/mqtt/task/MqttPushTask.java | 4 +- .../mqtt/MqttPubackMessageHandlerTest.java | 2 +- .../mqtt/MqttSubscribeMessageHandlerTest.java | 114 +++++++++++++++++++++ ...beMessageHandlerTest.java => MqttUtilTest.java} | 16 ++- 13 files changed, 292 insertions(+), 64 deletions(-) create mode 100644 mqtt/src/main/java/org/apache/rocketmq/mqtt/client/InFlightPacket.java copy mqtt/src/test/java/org/apache/rocketmq/mqtt/{MqttSubscribeMessageHandlerTest.java => MqttUtilTest.java} (70%)