@@ -1381,6 +1381,12 @@ TEST( coreMQTT_Integration, test_MQTT_Restore_Session_Incoming_Duplicate_PubRel
13811381 */
13821382void test_MQTT_Resend_Unacked_Publish_QoS1 ( void )
13831383{
1384+ if ( testingAgainstAWS )
1385+ {
1386+ /* Add 30 seconds of delay */
1387+ Clock_SleepMs ( 30000 );
1388+ }
1389+
13841390 /* Start a persistent session with the broker. */
13851391 startPersistentSession ();
13861392
@@ -1410,6 +1416,12 @@ void test_MQTT_Resend_Unacked_Publish_QoS1( void )
14101416 /* Reset the transport receive function in the context. */
14111417 context .transportInterface .recv = Openssl_Recv ;
14121418
1419+ if ( testingAgainstAWS )
1420+ {
1421+ /* Add 30 seconds of delay */
1422+ Clock_SleepMs ( 30000 );
1423+ }
1424+
14131425 /* We will re-establish an MQTT over TLS connection with the broker to restore
14141426 * the persistent session. */
14151427 resumePersistentSession ();
@@ -1534,6 +1546,12 @@ TEST( coreMQTT_Integration, test_MQTT_Resend_Unacked_Publish_QoS2 )
15341546 */
15351547void test_MQTT_Restore_Session_Duplicate_Incoming_Publish_Qos1 ( void )
15361548{
1549+ if ( testingAgainstAWS )
1550+ {
1551+ /* Add 30 seconds of delay */
1552+ Clock_SleepMs ( 30000 );
1553+ }
1554+
15371555 /* Start a persistent session with the broker. */
15381556 startPersistentSession ();
15391557
0 commit comments