This closes #832
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/c684e9c8 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/c684e9c8 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/c684e9c8 Branch: refs/heads/master Commit: c684e9c8a644606f3b9dafad4f2a0e9d48f698c6 Parents: 646c8ce a093486 Author: Clebert Suconic <[email protected]> Authored: Mon Oct 10 23:24:15 2016 +0200 Committer: Clebert Suconic <[email protected]> Committed: Mon Oct 10 23:24:15 2016 +0200 ---------------------------------------------------------------------- .../core/protocol/mqtt/MQTTProtocolHandler.java | 12 ++- .../core/protocol/mqtt/MQTTPublishManager.java | 93 ++++++++-------- .../protocol/mqtt/MQTTRetainMessageManager.java | 3 +- .../core/protocol/mqtt/MQTTSessionState.java | 105 +++++++++---------- .../protocol/mqtt/MQTTSubscriptionManager.java | 19 ++-- .../artemis/core/protocol/mqtt/MQTTUtil.java | 41 +++++--- .../integration/mqtt/imported/MQTTTest.java | 26 +++++ 7 files changed, 169 insertions(+), 130 deletions(-) ----------------------------------------------------------------------
