You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ro...@apache.org on 2023/09/13 10:28:59 UTC
[activemq-artemis] branch main updated (e7a27f0342 -> af2672e79a)
This is an automated email from the ASF dual-hosted git repository.
robbie pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
from e7a27f0342 NO-JIRA a few small address-settings doc fixes
add af2672e79a ARTEMIS-966 MQTT subscription state isn't durable
No new revisions were added by this update.
Summary of changes:
.../apache/activemq/artemis/utils/RandomUtil.java | 5 +
.../artemis/core/message/impl/CoreMessage.java | 14 +-
.../artemis/core/protocol/mqtt/MQTTBundle.java | 19 +-
.../core/protocol/mqtt/MQTTConnectionManager.java | 11 +-
.../artemis/core/protocol/mqtt/MQTTLogger.java | 3 +
.../core/protocol/mqtt/MQTTProtocolHandler.java | 18 +-
.../core/protocol/mqtt/MQTTProtocolManager.java | 109 ++-------
.../protocol/mqtt/MQTTProtocolManagerFactory.java | 2 +-
.../artemis/core/protocol/mqtt/MQTTSession.java | 28 ++-
.../core/protocol/mqtt/MQTTSessionState.java | 101 +++++++--
.../core/protocol/mqtt/MQTTStateManager.java | 246 +++++++++++++++++++++
.../protocol/mqtt/MQTTSubscriptionManager.java | 100 ++++-----
.../artemis/core/protocol/mqtt/MQTTUtil.java | 2 +
.../artemis/core/protocol/mqtt/StateSerDeTest.java | 108 +++++++++
.../remoting/impl/invm/InVMAcceptorFactory.java | 5 +
.../artemis/core/server/impl/QueueImpl.java | 2 +
.../artemis/spi/core/remoting/AcceptorFactory.java | 4 +
.../artemis/tests/util/ActiveMQTestBase.java | 3 +
docs/user-manual/mqtt.adoc | 6 +
.../src/main/resources/activemq/server0/broker.xml | 2 +-
.../amqp/AmqpFailoverEndpointDiscoveryTest.java | 17 ++
.../AmqpReplicatedLargeMessageTest.java | 4 +-
.../integration/client/MessageExpirationTest.java | 1 +
.../tests/integration/client/UpdateQueueTest.java | 12 +-
.../integration/journal/MessageJournalTest.java | 2 +-
.../tests/integration/mqtt/MQTTFQQNTest.java | 11 +-
.../integration/mqtt/MQTTSecurityManagerTest.java | 4 +-
.../artemis/tests/integration/mqtt/MQTTTest.java | 4 +-
.../tests/integration/mqtt/MQTTTestSupport.java | 2 +-
.../mqtt/MqttClusterRemoteSubscribeTest.java | 22 +-
.../mqtt/MqttWildCardSubAutoCreateTest.java | 10 +-
.../artemis/tests/integration/mqtt5/MQTT5Test.java | 118 ++++++++++
.../tests/integration/mqtt5/MQTT5TestSupport.java | 8 +-
.../mqtt5/spec/MessageReceiptTests.java | 8 +-
.../security/SecurityPerAcceptorJmsTest.java | 6 +-
.../tests/integration/security/SecurityTest.java | 4 +-
36 files changed, 786 insertions(+), 235 deletions(-)
copy artemis-service-extensions/src/main/java/org/apache/activemq/artemis/service/extensions/ActiveMQServiceExtensionLogger.java => artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTBundle.java (61%)
create mode 100644 artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTStateManager.java
create mode 100644 artemis-protocols/artemis-mqtt-protocol/src/test/java/org/apache/activemq/artemis/core/protocol/mqtt/StateSerDeTest.java