You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jb...@apache.org on 2017/02/16 18:42:19 UTC
[2/2] activemq-artemis git commit: This closes #1022
This closes #1022
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/f900d8a9
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/f900d8a9
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/f900d8a9
Branch: refs/heads/master
Commit: f900d8a9751cbe63d6c703310b04f85a93cfcd0f
Parents: e088c2f 5a235d9
Author: Justin Bertram <jb...@apache.org>
Authored: Thu Feb 16 12:42:04 2017 -0600
Committer: Justin Bertram <jb...@apache.org>
Committed: Thu Feb 16 12:42:04 2017 -0600
----------------------------------------------------------------------
.../protocol/mqtt/MQTTConnectionManager.java | 39 +++++++------
.../core/protocol/mqtt/MQTTFailureListener.java | 4 +-
.../core/protocol/mqtt/MQTTProtocolHandler.java | 26 ++++-----
.../core/protocol/mqtt/MQTTPublishManager.java | 49 +++++++++++-----
.../protocol/mqtt/MQTTRetainMessageManager.java | 61 ++++++++++++--------
.../core/protocol/mqtt/MQTTSessionState.java | 20 -------
.../integration/mqtt/imported/MQTTTest.java | 39 ++++++++++++-
7 files changed, 148 insertions(+), 90 deletions(-)
----------------------------------------------------------------------