replace mosquitto with artemis

Author: borisalekseev

.github/workflows/pr_tests.yaml

@@ -492,12 +492,12 @@ jobs:
     # - test-basic
     # - test-mqtt-smoke
     services:
-      mosquitto:
-        image: eclipse-mosquitto:latest
+      artemis:
+        image: apache/activemq-artemis:latest-alpine
+        env:
+          ANONYMOUS_LOGIN: "true"
         ports:
           - 1883:1883
-        volumes:
-          - ./dev/mosquitto/mosquitto.conf:/mosquitto/config/mosquitto.conf
     steps:
       - uses: actions/checkout@1af3b93b6815bc44a9784bd300feb67ff0d1eeb3 # v6.0.0
         with:

dev/mosquitto/mosquitto.conf

@@ -41,14 +41,14 @@ services:
     security_opt:
       - no-new-privileges:true
 
-  mosquitto:
-    image: eclipse-mosquitto:latest
+  artemis:
+    image: apache/activemq-artemis:latest-alpine
+    environment:
+      ANONYMOUS_LOGIN: "true"
     ports:
       - 1883:1883
     security_opt:
       - no-new-privileges:true
-    volumes:
-      - ./dev/mosquitto/mosquitto.conf:/mosquitto/config/mosquitto.conf
 
   faststream:
     build: .

docker-compose.yaml

@@ -1,7 +1,7 @@
 from typing import TYPE_CHECKING, cast
 
 from faststream._internal.basic_types import DecodedMessage
-from faststream._internal.constants import ContentTypes
+from faststream._internal.constants import ContentType, ContentTypes
 from faststream.message import decode_message
 from faststream.mqtt.message import MQTTMessage
 
@@ -16,7 +16,7 @@ class MQTTParser:
     async def parse_message(self, message: "Message") -> MQTTMessage:
         payload = message.payload
         ct = (
-            message.properties.ContentType  # type: ignore[attr-defined]
+            getattr(message.properties, "ContentType", ContentTypes.TEXT.value)  # type: ignore[attr-defined]
             if message.properties
             else ContentTypes.TEXT.value
         )