You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2015/07/09 16:18:11 UTC
[5/5] activemq-artemis git commit: This closes #62 MQTT support
This closes #62 MQTT support
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/17cc62bc
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/17cc62bc
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/17cc62bc
Branch: refs/heads/master
Commit: 17cc62bca2a0659c39bec026bb0b5ea45292dd68
Parents: 077e9e2 0f82ca7
Author: Clebert Suconic <cl...@apache.org>
Authored: Thu Jul 9 10:17:48 2015 -0400
Committer: Clebert Suconic <cl...@apache.org>
Committed: Thu Jul 9 10:17:48 2015 -0400
----------------------------------------------------------------------
artemis-distribution/pom.xml | 9 +
artemis-distribution/src/main/assembly/dep.xml | 2 +
artemis-protocols/artemis-mqtt-protocol/pom.xml | 56 +
.../core/protocol/mqtt/MQTTConnection.java | 241 +++
.../protocol/mqtt/MQTTConnectionManager.java | 205 ++
.../core/protocol/mqtt/MQTTFailureListener.java | 47 +
.../artemis/core/protocol/mqtt/MQTTLogger.java | 43 +
.../core/protocol/mqtt/MQTTMessageInfo.java | 57 +
.../core/protocol/mqtt/MQTTProtocolHandler.java | 362 ++++
.../core/protocol/mqtt/MQTTProtocolManager.java | 140 ++
.../mqtt/MQTTProtocolManagerFactory.java | 58 +
.../core/protocol/mqtt/MQTTPublishManager.java | 270 +++
.../protocol/mqtt/MQTTRetainMessageManager.java | 98 +
.../artemis/core/protocol/mqtt/MQTTSession.java | 173 ++
.../core/protocol/mqtt/MQTTSessionCallback.java | 111 ++
.../core/protocol/mqtt/MQTTSessionState.java | 250 +++
.../protocol/mqtt/MQTTSubscriptionManager.java | 183 ++
.../artemis/core/protocol/mqtt/MQTTUtil.java | 178 ++
...mis.spi.core.protocol.ProtocolManagerFactory | 1 +
artemis-protocols/pom.xml | 1 +
pom.xml | 23 +
tests/integration-tests/pom.xml | 37 +
.../mqtt/imported/FuseMQTTClientProvider.java | 131 ++
.../mqtt/imported/MQTTClientProvider.java | 48 +
.../integration/mqtt/imported/MQTTTest.java | 1747 ++++++++++++++++++
.../mqtt/imported/MQTTTestSupport.java | 376 ++++
.../integration/mqtt/imported/PahoMQTTTest.java | 175 ++
.../util/ResourceLoadingSslContext.java | 284 +++
.../integration/mqtt/imported/util/Wait.java | 56 +
29 files changed, 5362 insertions(+)
----------------------------------------------------------------------