@Test public void assertIsNotRegisterCompleteSuccess() { assertFalse(guaranteeService.isRegisterCompleteSuccess(Arrays.asList(0, 1))); }
public boolean isRegisterCompleteSuccess(final Collection<Integer> shardingItems) { for (int each : shardingItems) { if (!jobNodeStorage.isJobNodeExisted(GuaranteeNode.getCompletedNode(each))) { return false; } } return true; }
GuaranteeService { public boolean isRegisterCompleteSuccess(final Collection<Integer> shardingItems) { for (int each : shardingItems) { if (!jobNodeStorage.isJobNodeExisted(GuaranteeNode.getCompletedNode(each))) { return false; } } return true; } }
GuaranteeService { public boolean isRegisterCompleteSuccess(final Collection<Integer> shardingItems) { for (int each : shardingItems) { if (!jobNodeStorage.isJobNodeExisted(GuaranteeNode.getCompletedNode(each))) { return false; } } return true; } GuaranteeService(final CoordinatorRegistryCenter regCenter, final String jobName); }
GuaranteeService { public boolean isRegisterCompleteSuccess(final Collection<Integer> shardingItems) { for (int each : shardingItems) { if (!jobNodeStorage.isJobNodeExisted(GuaranteeNode.getCompletedNode(each))) { return false; } } return true; } GuaranteeService(final CoordinatorRegistryCenter regCenter, final String jobName); void registerStart(final Collection<Integer> shardingItems); boolean isRegisterStartSuccess(final Collection<Integer> shardingItems); boolean isAllStarted(); void clearAllStartedInfo(); void registerComplete(final Collection<Integer> shardingItems); boolean isRegisterCompleteSuccess(final Collection<Integer> shardingItems); boolean isAllCompleted(); void clearAllCompletedInfo(); }
GuaranteeService { public boolean isRegisterCompleteSuccess(final Collection<Integer> shardingItems) { for (int each : shardingItems) { if (!jobNodeStorage.isJobNodeExisted(GuaranteeNode.getCompletedNode(each))) { return false; } } return true; } GuaranteeService(final CoordinatorRegistryCenter regCenter, final String jobName); void registerStart(final Collection<Integer> shardingItems); boolean isRegisterStartSuccess(final Collection<Integer> shardingItems); boolean isAllStarted(); void clearAllStartedInfo(); void registerComplete(final Collection<Integer> shardingItems); boolean isRegisterCompleteSuccess(final Collection<Integer> shardingItems); boolean isAllCompleted(); void clearAllCompletedInfo();  }