Repository: activemq-artemis Updated Branches: refs/heads/master f660783df -> e088c2fa2
This closes #1021 Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/e088c2fa Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/e088c2fa Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/e088c2fa Branch: refs/heads/master Commit: e088c2fa27bcdc21e0ba47c373e43c7eae24e501 Parents: f660783 21b64b3 Author: Martyn Taylor <[email protected]> Authored: Thu Feb 16 17:37:50 2017 +0000 Committer: Martyn Taylor <[email protected]> Committed: Thu Feb 16 17:37:50 2017 +0000 ---------------------------------------------------------------------- .../activemq/artemis/api/core/SimpleString.java | 12 ++ .../core/protocol/mqtt/MQTTProtocolHandler.java | 2 +- .../core/protocol/mqtt/MQTTPublishManager.java | 2 +- .../protocol/mqtt/MQTTRetainMessageManager.java | 4 +- .../artemis/core/protocol/mqtt/MQTTSession.java | 16 ++- .../core/protocol/mqtt/MQTTSessionState.java | 5 +- .../protocol/mqtt/MQTTSubscriptionManager.java | 9 +- .../artemis/core/protocol/mqtt/MQTTUtil.java | 48 +++---- .../core/protocol/openwire/amq/AMQConsumer.java | 5 +- .../core/protocol/openwire/amq/AMQSession.java | 9 +- .../protocol/openwire/util/OpenWireUtil.java | 21 +-- .../core/config/WildcardConfiguration.java | 17 ++- .../core/postoffice/impl/AddressImpl.java | 6 +- .../postoffice/impl/WildcardAddressManager.java | 11 -- .../mqtt/imported/MQTTOpenwireTest.java | 141 +++++++++++++++++++ .../integration/mqtt/imported/MQTTTest.java | 2 - .../mqtt/imported/MQTTTestSupport.java | 19 ++- .../integration/openwire/OpenWireUtilTest.java | 9 +- 18 files changed, 257 insertions(+), 81 deletions(-) ----------------------------------------------------------------------
