@Test public void shouldUpdateAllNodes() throws Exception { NodePoolManager npmMock = mock(NodePoolManager.class); RESTClientsRetriever.npmForTest = npmMock; RESTClientsRetriever.testing = true; List<DeployableService> services = chor.getDeployableServices(); NodesUpdater updater = new NodesUpdater(services, chor.getId()); updater.updateNodes(); for (DeployableService svc: services) { String nodeId = svc.getSelectedNodes().iterator().next().getId(); verify(npmMock).updateNode(nodeId); } RESTClientsRetriever.testing = false; }
public void updateNodes() throws EnactmentException { logger.info("Going to update nodes of choreography " + chorId); setNodesToUpdate(); submitUpdates(); waitUpdates(); }
NodesUpdater { public void updateNodes() throws EnactmentException { logger.info("Going to update nodes of choreography " + chorId); setNodesToUpdate(); submitUpdates(); waitUpdates(); } }
NodesUpdater { public void updateNodes() throws EnactmentException { logger.info("Going to update nodes of choreography " + chorId); setNodesToUpdate(); submitUpdates(); waitUpdates(); } NodesUpdater(List<DeployableService> services, String chorId); }
NodesUpdater { public void updateNodes() throws EnactmentException { logger.info("Going to update nodes of choreography " + chorId); setNodesToUpdate(); submitUpdates(); waitUpdates(); } NodesUpdater(List<DeployableService> services, String chorId); void updateNodes(); }
NodesUpdater { public void updateNodes() throws EnactmentException { logger.info("Going to update nodes of choreography " + chorId); setNodesToUpdate(); submitUpdates(); waitUpdates(); } NodesUpdater(List<DeployableService> services, String chorId); void updateNodes();  }