diff --git a/compute/src/test/java/org/jclouds/compute/internal/BaseComputeServiceLiveTest.java b/compute/src/test/java/org/jclouds/compute/internal/BaseComputeServiceLiveTest.java index e24ff2cf355..3fc40b22f8c 100644 --- a/compute/src/test/java/org/jclouds/compute/internal/BaseComputeServiceLiveTest.java +++ b/compute/src/test/java/org/jclouds/compute/internal/BaseComputeServiceLiveTest.java @@ -419,30 +419,31 @@ public void testCreateAnotherNodeWithANewContextToEnsureSharedMemIsntRequired() @Test(enabled = true, dependsOnMethods = "testCompareSizes") public void testConcurrentUseOfComputeServiceToCreateNodes() throws Exception { - final long timeoutMs = 20*60*1000; + final long timeoutMs = 20 * 60 * 1000; List groups = new ArrayList(); List> futures = new ArrayList>(); ListeningExecutorService executor = MoreExecutors.listeningDecorator(context.utils().userExecutor()); - + try { for (int i = 0; i < 2; i++) { final int groupNum = i; - final String group = "groupconcurrent"+groupNum; + final String group = "twin" + groupNum; groups.add(group); - + ListenableFuture future = executor.submit(new Callable() { public NodeMetadata call() throws Exception { - NodeMetadata node = getOnlyElement(client.createNodesInGroup(group, 1, - inboundPorts(22, 8080).blockOnPort(22, 300+groupNum))); - getAnonymousLogger().info("Started node "+node.getId()); + NodeMetadata node = getOnlyElement(client.createNodesInGroup(group, 1, inboundPorts(22, 8080) + .blockOnPort(22, 300 + groupNum))); + getAnonymousLogger().info("Started node " + node.getId()); return node; - }}); + } + }); futures.add(future); } - + ListenableFuture> compoundFuture = Futures.allAsList(futures); compoundFuture.get(timeoutMs, TimeUnit.MILLISECONDS); - + } finally { for (String group : groups) { client.destroyNodesMatching(inGroup(group));