@Test public void testClearMisfire() { jobFacade.clearMisfire(Arrays.asList(0, 1)); verify(executionService).clearMisfire(Arrays.asList(0, 1)); }
public void clearMisfire(final List<Integer> shardingItems) { executionService.clearMisfire(shardingItems); }
JobFacade { public void clearMisfire(final List<Integer> shardingItems) { executionService.clearMisfire(shardingItems); } }
JobFacade { public void clearMisfire(final List<Integer> shardingItems) { executionService.clearMisfire(shardingItems); } JobFacade(final CoordinatorRegistryCenter coordinatorRegistryCenter, final JobConfiguration jobConfiguration, final List<ElasticJobListener> elasticJobListeners); }
JobFacade { public void clearMisfire(final List<Integer> shardingItems) { executionService.clearMisfire(shardingItems); } JobFacade(final CoordinatorRegistryCenter coordinatorRegistryCenter, final JobConfiguration jobConfiguration, final List<ElasticJobListener> elasticJobListeners); String getJobName(); int getConcurrentDataProcessThreadCount(); String getScriptCommandLine(); void checkMaxTimeDiffSecondsTolerable(); void failoverIfNecessary(); void registerJobBegin(final JobExecutionMultipleShardingContext shardingContext); void registerJobCompleted(final JobExecutionMultipleShardingContext shardingContext); JobExecutionMultipleShardingContext getShardingContext(); boolean misfireIfNecessary(final List<Integer> shardingItems); void clearMisfire(final List<Integer> shardingItems); boolean isExecuteMisfired(final List<Integer> shardingItems); boolean isEligibleForJobRunning(); boolean isNeedSharding(); void updateOffset(final int item, final String offset); void cleanPreviousExecutionInfo(); void beforeJobExecuted(final JobExecutionMultipleShardingContext shardingContext); void afterJobExecuted(final JobExecutionMultipleShardingContext shardingContext); }
JobFacade { public void clearMisfire(final List<Integer> shardingItems) { executionService.clearMisfire(shardingItems); } JobFacade(final CoordinatorRegistryCenter coordinatorRegistryCenter, final JobConfiguration jobConfiguration, final List<ElasticJobListener> elasticJobListeners); String getJobName(); int getConcurrentDataProcessThreadCount(); String getScriptCommandLine(); void checkMaxTimeDiffSecondsTolerable(); void failoverIfNecessary(); void registerJobBegin(final JobExecutionMultipleShardingContext shardingContext); void registerJobCompleted(final JobExecutionMultipleShardingContext shardingContext); JobExecutionMultipleShardingContext getShardingContext(); boolean misfireIfNecessary(final List<Integer> shardingItems); void clearMisfire(final List<Integer> shardingItems); boolean isExecuteMisfired(final List<Integer> shardingItems); boolean isEligibleForJobRunning(); boolean isNeedSharding(); void updateOffset(final int item, final String offset); void cleanPreviousExecutionInfo(); void beforeJobExecuted(final JobExecutionMultipleShardingContext shardingContext); void afterJobExecuted(final JobExecutionMultipleShardingContext shardingContext);  }