ryan_harg/testcontainers-infinispan
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Make the tests fail for connection errors

Browse source
This commit is contained in:
Reinhard Prechtl 2017-12-17 17:38:36 +01:00
parent 7382bbb377
commit 882ebaf6d8
1 changed files with 6 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/test/java/GenericInfinispanContainerIntegrationTest.java
View file

@ -10,10 +10,7 @@ import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.wait.LogMessageWaitStrategy; import org.testcontainers.containers.wait.LogMessageWaitStrategy;
import java.time.Duration; import java.time.Duration;
import java.util.concurrent.ExecutorService; import java.util.concurrent.*;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import static org.junit.Assert.assertNotNull; import static org.junit.Assert.assertNotNull;
@ -23,7 +20,7 @@ public class GenericInfinispanContainerIntegrationTest {
RemoteCacheManager cacheManager; RemoteCacheManager cacheManager;
@ClassRule @ClassRule
public static GenericContainer container = public static GenericContainer infinispan =
new GenericContainer("jboss/infinispan-server:9.1.3.Final") new GenericContainer("jboss/infinispan-server:9.1.3.Final")
.waitingFor(new LogMessageWaitStrategy().withRegEx(".*Infinispan Server.*started in.*\\s")) .waitingFor(new LogMessageWaitStrategy().withRegEx(".*Infinispan Server.*started in.*\\s"))
.withStartupTimeout(Duration.ofMillis(20000)) .withStartupTimeout(Duration.ofMillis(20000))
@ -48,11 +45,12 @@ public class GenericInfinispanContainerIntegrationTest {
} }
@Test @Test
public void should_be_able_to_retrieve_a_configured_cache() { public void should_be_able_to_retrieve_a_configured_cache() throws Exception {
assertNotNull(cacheManager.getCache("testCache")); Future<RemoteCache<Object, Object>> result = executorService.submit(() -> cacheManager.getCache("testCache"));
assertNotNull(result.get(1500, TimeUnit.MILLISECONDS));
} }
private String getServerAddress() { private String getServerAddress() {
return container.getContainerIpAddress() + ":" + container.getMappedPort(11222); return infinispan.getContainerIpAddress() + ":" + infinispan.getMappedPort(11222);
} }
} }