@Test
public void testWorkerExecutionMonitorServiceCollectMonitor() throws InterruptedException {

    HashMap<WorkerMonitorInfoEnum, Serializable> monitorInfo = new HashMap<>();
    when(workerMonitors.getMonitorInfo()).thenReturn(monitorInfo);
    ScoreEvent scoreEvent = new ScoreEvent(EventConstants.WORKER_EXECUTION_MONITOR, monitorInfo);
    workerExecutionMonitorService.collectMonitorInformation();
    verify(eventBus, times(1)).dispatch(refEq(scoreEvent));
}