160d609bd4
Previously, there was a timing window where the output file had been created but it was empty. This would cause the test to fail as the output was read from the empty file and didn’t match the expected “Hello World”. This commit updates the test to only process the resources in the output directory when all the resolved resources have a non-zero content length. An @Before method has also been added to delete the output produced by the test so that the outcome of the test isn’t affected by files generated by previous runs. Fixes gh-1735
109 lines
3.3 KiB
Java
109 lines
3.3 KiB
Java
/*
|
|
* Copyright 2012-2013 the original author or authors.
|
|
*
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
* you may not use this file except in compliance with the License.
|
|
* You may obtain a copy of the License at
|
|
*
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
|
*
|
|
* Unless required by applicable law or agreed to in writing, software
|
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
* See the License for the specific language governing permissions and
|
|
* limitations under the License.
|
|
*/
|
|
|
|
package sample.integration.consumer;
|
|
|
|
import java.io.File;
|
|
import java.io.IOException;
|
|
import java.util.concurrent.Callable;
|
|
import java.util.concurrent.Executors;
|
|
import java.util.concurrent.Future;
|
|
import java.util.concurrent.TimeUnit;
|
|
|
|
import org.junit.AfterClass;
|
|
import org.junit.Before;
|
|
import org.junit.BeforeClass;
|
|
import org.junit.Test;
|
|
import org.springframework.boot.SpringApplication;
|
|
import org.springframework.context.ConfigurableApplicationContext;
|
|
import org.springframework.core.io.DefaultResourceLoader;
|
|
import org.springframework.core.io.Resource;
|
|
import org.springframework.core.io.support.ResourcePatternUtils;
|
|
import org.springframework.util.FileSystemUtils;
|
|
import org.springframework.util.StreamUtils;
|
|
|
|
import sample.integration.SampleIntegrationApplication;
|
|
import sample.integration.producer.ProducerApplication;
|
|
|
|
import static org.junit.Assert.assertTrue;
|
|
|
|
/**
|
|
* Basic integration tests for service demo application.
|
|
*
|
|
* @author Dave Syer
|
|
* @author Andy Wilkinson
|
|
*/
|
|
public class SampleIntegrationApplicationTests {
|
|
|
|
private static ConfigurableApplicationContext context;
|
|
|
|
@BeforeClass
|
|
public static void start() throws Exception {
|
|
context = SpringApplication.run(SampleIntegrationApplication.class);
|
|
}
|
|
|
|
@AfterClass
|
|
public static void stop() {
|
|
if (context != null) {
|
|
context.close();
|
|
}
|
|
}
|
|
|
|
@Before
|
|
public void deleteOutput() {
|
|
FileSystemUtils.deleteRecursively(new File("target/output"));
|
|
}
|
|
|
|
@Test
|
|
public void testVanillaExchange() throws Exception {
|
|
SpringApplication.run(ProducerApplication.class, "World");
|
|
String output = getOutput();
|
|
assertTrue("Wrong output: " + output, output.contains("Hello World"));
|
|
}
|
|
|
|
private String getOutput() throws Exception {
|
|
Future<String> future = Executors.newSingleThreadExecutor().submit(
|
|
new Callable<String>() {
|
|
@Override
|
|
public String call() throws Exception {
|
|
Resource[] resources = getResourcesWithContent();
|
|
while (resources.length == 0) {
|
|
Thread.sleep(200);
|
|
resources = getResourcesWithContent();
|
|
}
|
|
StringBuilder builder = new StringBuilder();
|
|
for (Resource resource : resources) {
|
|
builder.append(new String(StreamUtils
|
|
.copyToByteArray(resource.getInputStream())));
|
|
}
|
|
return builder.toString();
|
|
}
|
|
});
|
|
return future.get(30, TimeUnit.SECONDS);
|
|
}
|
|
|
|
private Resource[] getResourcesWithContent() throws IOException {
|
|
Resource[] candidates = ResourcePatternUtils.getResourcePatternResolver(
|
|
new DefaultResourceLoader()).getResources("file:target/output/**");
|
|
for (Resource candidate : candidates) {
|
|
if (candidate.contentLength() == 0) {
|
|
return new Resource[0];
|
|
}
|
|
}
|
|
return candidates;
|
|
}
|
|
}
|