@Test(dataProvider = "rerunProgressStateProvider") public void testRerunAgendaProgressState(AgendaProgress agendaProgress) { doReturn(createDataObjectResponse(agendaProgress)).when(mockAgendaProgressClient).getObject(any()); doReturn(new RerunAgendaResponse()).when(mockAgendaServiceClient).rerunAgenda(any()); processor.process(agendaProgress); verify(mockAgendaServiceClient, times(1)).rerunAgenda(any()); }
public void process(AgendaProgress eventAgendaProgress) { if(eventAgendaProgress == null) return; AgendaProgress agendaProgress = getAgendaProgress(eventAgendaProgress); if(agendaProgress != null && shouldRetry(agendaProgress)) { retryAgenda(agendaProgress); } }
AgendaProgressProcessor { public void process(AgendaProgress eventAgendaProgress) { if(eventAgendaProgress == null) return; AgendaProgress agendaProgress = getAgendaProgress(eventAgendaProgress); if(agendaProgress != null && shouldRetry(agendaProgress)) { retryAgenda(agendaProgress); } } }
AgendaProgressProcessor { public void process(AgendaProgress eventAgendaProgress) { if(eventAgendaProgress == null) return; AgendaProgress agendaProgress = getAgendaProgress(eventAgendaProgress); if(agendaProgress != null && shouldRetry(agendaProgress)) { retryAgenda(agendaProgress); } } AgendaProgressProcessor(AgendaServiceClient agendaServiceClient, ObjectClient<AgendaProgress> agendaProgressClient); }
AgendaProgressProcessor { public void process(AgendaProgress eventAgendaProgress) { if(eventAgendaProgress == null) return; AgendaProgress agendaProgress = getAgendaProgress(eventAgendaProgress); if(agendaProgress != null && shouldRetry(agendaProgress)) { retryAgenda(agendaProgress); } } AgendaProgressProcessor(AgendaServiceClient agendaServiceClient, ObjectClient<AgendaProgress> agendaProgressClient); void process(AgendaProgress eventAgendaProgress); }
AgendaProgressProcessor { public void process(AgendaProgress eventAgendaProgress) { if(eventAgendaProgress == null) return; AgendaProgress agendaProgress = getAgendaProgress(eventAgendaProgress); if(agendaProgress != null && shouldRetry(agendaProgress)) { retryAgenda(agendaProgress); } } AgendaProgressProcessor(AgendaServiceClient agendaServiceClient, ObjectClient<AgendaProgress> agendaProgressClient); void process(AgendaProgress eventAgendaProgress);  }