VirtualControlLoopEvent onsetEvent = getOnsetEvent();
ControlLoopEventManager manager = makeManager(onsetEvent);
- assertTrue(0 == manager.getControlLoopTimeout(null));
- assertTrue(120 == manager.getControlLoopTimeout(120));
+ assertEquals(0, manager.getControlLoopTimeout(null));
+ assertEquals(120, manager.getControlLoopTimeout(120));
InputStream is = new FileInputStream(new File(TEST_YAML));
final String yamlString = IOUtils.toString(is, StandardCharsets.UTF_8);
assertNotNull(notification);
assertEquals(ControlLoopNotificationType.ACTIVE, notification.getNotification());
- assertTrue(0 == manager.getControlLoopTimeout(null));
- assertTrue(120 == manager.getControlLoopTimeout(120));
+ assertEquals(0, manager.getControlLoopTimeout(null));
+ assertEquals(120, manager.getControlLoopTimeout(120));
}
@Test
assertNotNull(notification);
assertEquals(ControlLoopNotificationType.ACTIVE, notification.getNotification());
- assertTrue(0 == manager.getControlLoopTimeout(null));
- assertTrue(120 == manager.getControlLoopTimeout(120));
+ assertEquals(0, manager.getControlLoopTimeout(null));
+ assertEquals(120, manager.getControlLoopTimeout(120));
}
@Test
//
PolicyResult result = manager.onResponse(dmaapResponse);
logger.debug("{}", manager);
- assertTrue(result == null);
+ assertNull(result);
assertFalse(manager.isOperationComplete());
assertTrue(manager.isOperationRunning());
//
dmaapResponse.setBody(outputBody);
result = manager.onResponse(dmaapResponse);
logger.debug("{}", manager);
- assertTrue(result.equals(PolicyResult.FAILURE));
+ assertEquals(PolicyResult.FAILURE, result);
assertFalse(manager.isOperationComplete());
assertFalse(manager.isOperationRunning());
//
//
result = manager.onResponse(dmaapResponse);
logger.debug("{}", manager);
- assertTrue(result == null);
+ assertNull(result);
assertFalse(manager.isOperationComplete());
assertTrue(manager.isOperationRunning());
//
dmaapResponse.setBody(outputBody);
result = manager.onResponse(dmaapResponse);
logger.debug("{}", manager);
- assertTrue(result.equals(PolicyResult.FAILURE));
+ assertEquals(PolicyResult.FAILURE, result);
//
// Should be complete now
//
assertTrue(manager.isOperationComplete());
assertFalse(manager.isOperationRunning());
assertNotNull(manager.getOperationResult());
- assertTrue(manager.getOperationResult().equals(PolicyResult.FAILURE_RETRIES));
- assertTrue(manager.getHistory().size() == 2);
+ assertEquals(PolicyResult.FAILURE_RETRIES, manager.getOperationResult());
+ assertEquals(2, manager.getHistory().size());
}
@Test
//
PolicyResult result = manager.onResponse(dmaapResponse);
logger.debug("{}", manager);
- assertTrue(result == null);
+ assertNull(result);
assertFalse(manager.isOperationComplete());
assertTrue(manager.isOperationRunning());
//
logger.debug("{}", manager);
assertTrue(manager.isOperationComplete());
assertFalse(manager.isOperationRunning());
- assertTrue(manager.getHistory().size() == 1);
- assertTrue(manager.getOperationResult().equals(PolicyResult.FAILURE_TIMEOUT));
+ assertEquals(1, manager.getHistory().size());
+ assertEquals(PolicyResult.FAILURE_TIMEOUT, manager.getOperationResult());
//
// Now we are going to Fail the previous request
//
//
assertTrue(manager.isOperationComplete());
assertFalse(manager.isOperationRunning());
- assertTrue(manager.getHistory().size() == 1);
- assertTrue(manager.getOperationResult().equals(PolicyResult.FAILURE_TIMEOUT));
+ assertEquals(1, manager.getHistory().size());
+ assertEquals(PolicyResult.FAILURE_TIMEOUT, manager.getOperationResult());
}
@Test