refactor(e2e-tests): Re-enable a few disabled e2e tests

Azure · Oct 17, 2018 · befdf92 · befdf92
1 parent 3f7d92b
commit befdf92
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/...n/src/main/java/com/microsoft/azure/sdk/iot/common/iothubservices/SendMessagesCommon.java b/...n/src/main/java/com/microsoft/azure/sdk/iot/common/iothubservices/SendMessagesCommon.java
@@ -707,7 +707,7 @@ public void sendMessagesOverAmqpWithTwinRespLinkDrop() throws IOException, Inter
 
         sendMessagesExpectingConnectionStatusChangeUpdate(testInstance.client, testInstance.protocol, AMQP_TWIN_RESP_LINK_DROP_MESSAGES_TO_SEND, RETRY_MILLISECONDS, SEND_TIMEOUT_MILLISECONDS, IotHubConnectionStatus.DISCONNECTED_RETRYING, 100, testInstance.authenticationType);
     }
-    @Ignore
+
     @Test
     public void sendMessagesWithThrottling() throws URISyntaxException, IOException, IotHubException, InterruptedException
     {
@@ -723,7 +723,7 @@ public void sendMessagesWithThrottling() throws URISyntaxException, IOException,
                 false);
 
     }
-    @Ignore
+
     @Test
     public void sendMessagesWithThrottlingNoRetry() throws URISyntaxException, IOException, IotHubException, InterruptedException
     {

diff --git a/.../java/tests/integration/com/microsoft/azure/sdk/iot/iothubservices/TransportClientIT.java b/.../java/tests/integration/com/microsoft/azure/sdk/iot/iothubservices/TransportClientIT.java
@@ -42,8 +42,6 @@
 import static tests.integration.com.microsoft.azure.sdk.iot.iothubservices.TransportClientIT.STATUS.FAILURE;
 import static tests.integration.com.microsoft.azure.sdk.iot.iothubservices.TransportClientIT.STATUS.SUCCESS;
 
-@Ignore
-//Ignoring these tests as they frequently fail. Needs investigations
 public class TransportClientIT extends MethodNameLoggingIntegrationTest
 {
     //how many devices to test multiplexing with
@@ -64,6 +62,7 @@ public class TransportClientIT extends MethodNameLoggingIntegrationTest
     private static final long MAX_MILLISECS_TIMEOUT_FLUSH_NOTIFICATION = 10 * 1000; // 10 secs
     private static final long MAXIMUM_TIME_TO_WAIT_FOR_IOTHUB_PER_CALL_MS = 1000; // 1 second
     private static final long MAXIMUM_TIME_FOR_IOTHUB_PROPAGATION_BETWEEN_DEVICE_SERVICE_CLIENTS = MAXIMUM_TIME_TO_WAIT_FOR_IOTHUB_TWIN_OPERATION * 10; // 2 sec
+    private static final long REGISTRY_MANAGER_DEVICE_CREATION_DELAY_MILLISECONDS = 3 * 1000;
 
     private static Device[] deviceListAmqps = new Device[MAX_DEVICE_MULTIPLEX];
     private static final AtomicBoolean succeed = new AtomicBoolean();
@@ -123,6 +122,8 @@ public static void setUp() throws Exception
             clientConnectionStringArrayList.add(registryManager.getDeviceConnectionString(deviceListAmqps[i]));
         }
 
+        Thread.sleep(MAX_DEVICE_MULTIPLEX * REGISTRY_MANAGER_DEVICE_CREATION_DELAY_MILLISECONDS);
+
         messageProperties = new HashMap<>(3);
         messageProperties.put("name1", "value1");
         messageProperties.put("name2", "value2");