This closes #1002 gitkMqtt ack clean session
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/8a88a566 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/8a88a566 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/8a88a566 Branch: refs/heads/master Commit: 8a88a56693e8f75b6f51152c0c3be5f4c5dc95eb Parents: 20737cb cd28d76 Author: Andy Taylor <[email protected]> Authored: Thu Feb 9 11:36:13 2017 +0000 Committer: Andy Taylor <[email protected]> Committed: Thu Feb 9 11:36:13 2017 +0000 ---------------------------------------------------------------------- .../protocol/mqtt/MQTTConnectionManager.java | 52 +++++++++++--------- .../core/protocol/mqtt/MQTTPublishManager.java | 14 ++++-- .../artemis/core/protocol/mqtt/MQTTSession.java | 28 +++++++++-- .../core/protocol/mqtt/MQTTSessionState.java | 46 ++++++++--------- .../protocol/mqtt/MQTTSubscriptionManager.java | 28 ++++++----- .../artemis/core/protocol/mqtt/MQTTUtil.java | 2 +- .../integration/mqtt/imported/MQTTTest.java | 1 + .../mqtt/imported/MQTTTestSupport.java | 5 ++ 8 files changed, 109 insertions(+), 67 deletions(-) ----------------------------------------------------------------------
