InventoryDataScalingTaskGroup extends AbstractShardingScalingExecutor<InventoryPosition> implements ScalingTask<InventoryPosition> { @Override public void stop() { for (ScalingTask<InventoryPosition> each : scalingTasks) { each.stop(); } } InventoryDataScalingTaskGroup(final Collection<ScalingTask<InventoryPosition>> inventoryDataScalingTasks); @Override void start(); @Override void stop(); @Override SyncProgress getProgress();  }
@Test public void assertStop() { ScalingTask scalingTask = mock(ScalingTask.class); InventoryDataScalingTaskGroup inventoryDataSyncTaskGroup = new InventoryDataScalingTaskGroup(Collections.singletonList(scalingTask)); inventoryDataSyncTaskGroup.stop(); verify(scalingTask).stop(); }