|
|
@ -896,10 +896,6 @@ public class EdgeControllerTest extends AbstractControllerTest { |
|
|
Assert.assertTrue(popDeviceMsg(edgeImitator.getDownlinkMsgs(), UpdateMsgType.ENTITY_CREATED_RPC_MESSAGE, "Test Sync Edge Device 1")); |
|
|
Assert.assertTrue(popDeviceMsg(edgeImitator.getDownlinkMsgs(), UpdateMsgType.ENTITY_CREATED_RPC_MESSAGE, "Test Sync Edge Device 1")); |
|
|
Assert.assertTrue(popAssetProfileMsg(edgeImitator.getDownlinkMsgs(), UpdateMsgType.ENTITY_CREATED_RPC_MESSAGE, "test")); |
|
|
Assert.assertTrue(popAssetProfileMsg(edgeImitator.getDownlinkMsgs(), UpdateMsgType.ENTITY_CREATED_RPC_MESSAGE, "test")); |
|
|
Assert.assertTrue(popAssetMsg(edgeImitator.getDownlinkMsgs(), UpdateMsgType.ENTITY_CREATED_RPC_MESSAGE, "Test Sync Edge Asset 1")); |
|
|
Assert.assertTrue(popAssetMsg(edgeImitator.getDownlinkMsgs(), UpdateMsgType.ENTITY_CREATED_RPC_MESSAGE, "Test Sync Edge Asset 1")); |
|
|
Thread.sleep(1000); |
|
|
|
|
|
for (AbstractMessage downlinkMsg : edgeImitator.getDownlinkMsgs()) { |
|
|
|
|
|
System.out.println(" A " + downlinkMsg); |
|
|
|
|
|
} |
|
|
|
|
|
Assert.assertTrue(edgeImitator.getDownlinkMsgs().isEmpty()); |
|
|
Assert.assertTrue(edgeImitator.getDownlinkMsgs().isEmpty()); |
|
|
|
|
|
|
|
|
edgeImitator.expectMessageAmount(20); |
|
|
edgeImitator.expectMessageAmount(20); |
|
|
|