Add regression test for messageExpiryInterval bug

SmartsquareGmbH · Aug 19, 2024 · ade03a0 · ade03a0
1 parent 1274b38
commit ade03a0
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/src/test/kotlin/de/smartsquare/starter/mqtt/Mqtt5AutoConfigurationTest.kt b/src/test/kotlin/de/smartsquare/starter/mqtt/Mqtt5AutoConfigurationTest.kt
@@ -16,6 +16,7 @@ import org.springframework.beans.factory.annotation.Autowired
 import org.springframework.boot.test.context.SpringBootTest
 import org.springframework.stereotype.Component
 import org.springframework.test.context.TestPropertySource
+import kotlin.jvm.optionals.getOrNull
 
 @ExtendWith(EmqxExtension::class)
 @SpringBootTest(
@@ -132,6 +133,15 @@ class Mqtt5AutoConfigurationTest {
         }
     }
 
+    @Test
+    fun `publishes message with contentType`() {
+        publisher.publish("string", MqttQos.EXACTLY_ONCE, "1", PublishingOptions(contentType = "text/plain"))
+
+        await untilAssertedKluent {
+            publishSubscriber.receivedPayload?.contentType?.getOrNull()?.toString() shouldBeEqualTo "text/plain"
+        }
+    }
+
     @Component
     class IntSubscriber {