@Test public void testMissingAgendaProgress() { AgendaProgress agendaProgress = createAgendaProgress(ProcessingState.COMPLETE, CompleteStateMessage.FAILED.toString(), 0, 3); doReturn(new DefaultDataObjectResponse<>()).when(mockAgendaProgressClient).getObject(any()); processor.process(agendaProgress); verify(mockAgendaServiceClient, times(0)).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);  }