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