@Test public void assertClearPreviousServerStatus() { serverService.clearPreviousServerStatus(); verify(jobNodeStorage).removeJobNodeIfExisted(ServerNode.getStatusNode("mockedIP")); verify(jobNodeStorage).removeJobNodeIfExisted(ServerNode.getShutdownNode("mockedIP")); }
public void clearPreviousServerStatus() { jobNodeStorage.removeJobNodeIfExisted(ServerNode.getStatusNode(localHostService.getIp())); jobNodeStorage.removeJobNodeIfExisted(ServerNode.getShutdownNode(localHostService.getIp())); }
ServerService { public void clearPreviousServerStatus() { jobNodeStorage.removeJobNodeIfExisted(ServerNode.getStatusNode(localHostService.getIp())); jobNodeStorage.removeJobNodeIfExisted(ServerNode.getShutdownNode(localHostService.getIp())); } }
ServerService { public void clearPreviousServerStatus() { jobNodeStorage.removeJobNodeIfExisted(ServerNode.getStatusNode(localHostService.getIp())); jobNodeStorage.removeJobNodeIfExisted(ServerNode.getShutdownNode(localHostService.getIp())); } ServerService(final CoordinatorRegistryCenter coordinatorRegistryCenter, final JobConfiguration jobConfiguration); }
ServerService { public void clearPreviousServerStatus() { jobNodeStorage.removeJobNodeIfExisted(ServerNode.getStatusNode(localHostService.getIp())); jobNodeStorage.removeJobNodeIfExisted(ServerNode.getShutdownNode(localHostService.getIp())); } ServerService(final CoordinatorRegistryCenter coordinatorRegistryCenter, final JobConfiguration jobConfiguration); void clearPreviousServerStatus(); void persistServerOnline(); void clearJobTriggerStatus(); void clearJobPausedStatus(); boolean isJobPausedManually(); void processServerShutdown(); void updateServerStatus(final ServerStatus status); void removeServerStatus(); List<String> getAllServers(); List<String> getAvailableServers(); boolean isAvailableServer(final String ip); boolean isLocalServerDisabled(); boolean isLocalhostServerReady(); void persistProcessSuccessCount(final int processSuccessCount); void persistProcessFailureCount(final int processFailureCount); }
ServerService { public void clearPreviousServerStatus() { jobNodeStorage.removeJobNodeIfExisted(ServerNode.getStatusNode(localHostService.getIp())); jobNodeStorage.removeJobNodeIfExisted(ServerNode.getShutdownNode(localHostService.getIp())); } ServerService(final CoordinatorRegistryCenter coordinatorRegistryCenter, final JobConfiguration jobConfiguration); void clearPreviousServerStatus(); void persistServerOnline(); void clearJobTriggerStatus(); void clearJobPausedStatus(); boolean isJobPausedManually(); void processServerShutdown(); void updateServerStatus(final ServerStatus status); void removeServerStatus(); List<String> getAllServers(); List<String> getAvailableServers(); boolean isAvailableServer(final String ip); boolean isLocalServerDisabled(); boolean isLocalhostServerReady(); void persistProcessSuccessCount(final int processSuccessCount); void persistProcessFailureCount(final int processFailureCount);  }