mc_mqtt_SUITE test for #12707 #12710

Author: michaelklishin

deps/rabbitmq_mqtt/test/mc_mqtt_SUITE.erl

@@ -33,7 +33,8 @@ groups() ->
        mqtt_amqp,
        mqtt_amqp_alt,
        amqp_mqtt,
-       is_persistent
+       is_persistent,
+       amqpl_to_mqtt_gh_12707
       ]}
     ].
 
@@ -160,6 +161,34 @@ roundtrip_amqpl(_Config) ->
     ExpectedUserProperty = lists:keysort(1, UserProperty),
     ?assertMatch(#{'User-Property' := ExpectedUserProperty}, Props).
 
+amqpl_to_mqtt_gh_12707(_Config) ->
+    Props = #'P_basic'{content_type = <<"text/plain">>,
+                       content_encoding = <<"gzip">>,
+                       headers = [],
+                       delivery_mode = 1,
+                       priority = 7,
+                       correlation_id = <<"gh_12707-corr">> ,
+                       reply_to = <<"reply-to">>,
+                       expiration = <<"12707">>,
+                       message_id = <<"msg-id">>,
+                       timestamp = 99,
+                       type = <<"45">>,
+                       user_id = <<"gh_12707">>,
+                       app_id = <<"rmq">>
+                      },
+    Payload = [<<"gh_12707">>],
+    Content = #content{properties = Props,
+                       payload_fragments_rev = Payload},
+    Content = #content{properties = Props,
+                        payload_fragments_rev = Payload},
+    Anns = #{
+        ?ANN_EXCHANGE => <<"amq.topic">>,
+        ?ANN_ROUTING_KEYS => [<<"dummy">>]
+    },
+    OriginalMsg = mc:init(mc_amqpl, Content, Anns),
+    Converted = mc:convert(mc_mqtt, OriginalMsg),
+    ?assertEqual(12707, mc:get_annotation(ttl, Converted)).
+
 %% Non-UTF-8 Correlation Data should also be converted (via AMQP 0.9.1 header x-correlation-id).
 roundtrip_amqpl_correlation(_Config) ->
     Msg0 = mqtt_msg(),