inteligr8/alfresco-community-repo
1
0
Fork 0
mirror of https://github.com/Alfresco/alfresco-community-repo.git synced 2025-07-31 17:39:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

REPO-2852 Heartbeat: Add junit tests for the new service and collectors

Browse Source 
* Code review changes - added throws Exception to method signatures
This commit is contained in:
Erik Knizat
2017-09-15 13:45:30 +01:00
parent d268b29c97
commit eda2ac2b6f
1 changed files with 11 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
src/test/java/org/alfresco/heartbeat/HeartBeatTest.java
View File

@@ -70,8 +70,6 @@ public class HeartBeatTest
mockDataCollectorService = mock(HBDataCollectorService.class); mockDataCollectorService = mock(HBDataCollectorService.class);
((ConfigurableApplicationContext) context).getBeanFactory().registerSingleton("licenseService",mockLicenseService); ((ConfigurableApplicationContext) context).getBeanFactory().registerSingleton("licenseService",mockLicenseService);
((ConfigurableApplicationContext) context).getBeanFactory().registerSingleton("hbDataCollectorService",mockDataCollectorService); ((ConfigurableApplicationContext) context).getBeanFactory().registerSingleton("hbDataCollectorService",mockDataCollectorService);
mockDataSenderService = mock(HBDataSenderService.class);
} }
@Test @Test
@@ -84,7 +82,7 @@ public class HeartBeatTest
} }
@Test @Test
public void testJobSchedulingWhenEnabled() public void testJobSchedulingWhenEnabled() throws Exception
{ {
// Enable heartbeat in data collector service ( as if set in prop file) // Enable heartbeat in data collector service ( as if set in prop file)
when(mockDataCollectorService.isEnabledByDefault()).thenReturn(true); when(mockDataCollectorService.isEnabledByDefault()).thenReturn(true);
@@ -96,7 +94,7 @@ public class HeartBeatTest
} }
@Test @Test
public void testJobSchedulingWhenDisabled() public void testJobSchedulingWhenDisabled() throws Exception
{ {
// Disable heartbeat in data collector service ( as if set in prop file) // Disable heartbeat in data collector service ( as if set in prop file)
when(mockDataCollectorService.isEnabledByDefault()).thenReturn(false); when(mockDataCollectorService.isEnabledByDefault()).thenReturn(false);
@@ -111,7 +109,7 @@ public class HeartBeatTest
* Heartbeat enabled by default but disabled in licence on onLicenseChange * Heartbeat enabled by default but disabled in licence on onLicenseChange
*/ */
@Test @Test
public void testOnLicenseChangeOverridesDefaultEnabled() public void testOnLicenseChangeOverridesDefaultEnabled() throws Exception
{ {
// Enable heartbeat in data collector service ( as if set in prop file) // Enable heartbeat in data collector service ( as if set in prop file)
when(mockDataCollectorService.isEnabledByDefault()).thenReturn(true); when(mockDataCollectorService.isEnabledByDefault()).thenReturn(true);
@@ -136,7 +134,7 @@ public class HeartBeatTest
* heartbeat disabled by default but enabled in licence * heartbeat disabled by default but enabled in licence
*/ */
@Test @Test
public void testOnLicenseChangeOverridesDefaultDisabled() public void testOnLicenseChangeOverridesDefaultDisabled() throws Exception
{ {
// Disable heartbeat in data collector service ( as if set in prop file) // Disable heartbeat in data collector service ( as if set in prop file)
when(mockDataCollectorService.isEnabledByDefault()).thenReturn(false); when(mockDataCollectorService.isEnabledByDefault()).thenReturn(false);
@@ -152,13 +150,13 @@ public class HeartBeatTest
heartbeat.onLicenseChange(mockLicenseDescriptor); heartbeat.onLicenseChange(mockLicenseDescriptor);
// Check heartbeat is disabled and job unscheduled // Check heartbeat is enabled and job unscheduled
assertTrue(heartbeat.isEnabled()); assertTrue(heartbeat.isEnabled());
assertTrue("Job should be scheduled.",isJobScheduled()); assertTrue("Job should be scheduled.",isJobScheduled());
} }
@Test @Test
public void testOnLicenceFailRevertsToEnabled() public void testOnLicenceFailRevertsToEnabled() throws Exception
{ {
// Enable heartbeat in data collector service ( as if set in prop file) // Enable heartbeat in data collector service ( as if set in prop file)
when(mockDataCollectorService.isEnabledByDefault()).thenReturn(true); when(mockDataCollectorService.isEnabledByDefault()).thenReturn(true);
@@ -176,13 +174,13 @@ public class HeartBeatTest
// Revert back to default state // Revert back to default state
heartbeat.onLicenseFail(); heartbeat.onLicenseFail();
// Check heartbeat is disabled and job unscheduled // Check heartbeat is enabled and job unscheduled
assertTrue(heartbeat.isEnabled()); assertTrue(heartbeat.isEnabled());
assertTrue("Job should be unscheduled.",isJobScheduled()); assertTrue("Job should be unscheduled.",isJobScheduled());
} }
@Test @Test
public void testOnLicenceFailRevertsToDisabled() public void testOnLicenceFailRevertsToDisabled() throws Exception
{ {
// Disable heartbeat in data collector service ( as if set in prop file) // Disable heartbeat in data collector service ( as if set in prop file)
when(mockDataCollectorService.isEnabledByDefault()).thenReturn(false); when(mockDataCollectorService.isEnabledByDefault()).thenReturn(false);
@@ -205,19 +203,10 @@ public class HeartBeatTest
assertFalse("Job should be unscheduled.",isJobScheduled()); assertFalse("Job should be unscheduled.",isJobScheduled());
} }
private boolean isJobScheduled() private boolean isJobScheduled() throws Exception
{ {
Scheduler scheduler = (Scheduler) context.getBean("schedulerFactory"); Scheduler scheduler = (Scheduler) context.getBean("schedulerFactory");
String[] jobs = {}; String[] jobs = scheduler.getJobNames( Scheduler.DEFAULT_GROUP);
try
{
jobs = scheduler.getJobNames( Scheduler.DEFAULT_GROUP);
} catch (SchedulerException e)
{
e.printStackTrace();
fail("Exception before assertion.");
}
return Arrays.asList(jobs).contains("heartbeat"); return Arrays.asList(jobs).contains("heartbeat");
} }
} }