added local test timeout

pull/616/head
jackygurui 9 years ago
parent 5b72ef24a8
commit 8f32bd6d7d

@ -9,6 +9,7 @@ import org.junit.AfterClass;
import org.junit.Before; import org.junit.Before;
import org.junit.BeforeClass; import org.junit.BeforeClass;
import org.junit.ClassRule; import org.junit.ClassRule;
import org.junit.Rule;
import org.junit.rules.Timeout; import org.junit.rules.Timeout;
import org.reactivestreams.Publisher; import org.reactivestreams.Publisher;
import org.redisson.api.RCollectionReactive; import org.redisson.api.RCollectionReactive;
@ -22,7 +23,9 @@ import reactor.rx.Streams;
public abstract class BaseReactiveTest { public abstract class BaseReactiveTest {
@ClassRule @ClassRule
public static Timeout classTimeout = new Timeout(15, TimeUnit.MINUTES); public static Timeout classTimeout = new Timeout(1, TimeUnit.HOURS);
@Rule
public static Timeout testTimeout = new Timeout(15, TimeUnit.MINUTES);
protected RedissonReactiveClient redisson; protected RedissonReactiveClient redisson;
protected static RedissonReactiveClient defaultRedisson; protected static RedissonReactiveClient defaultRedisson;

@ -7,6 +7,7 @@ import org.junit.AfterClass;
import org.junit.Before; import org.junit.Before;
import org.junit.BeforeClass; import org.junit.BeforeClass;
import org.junit.ClassRule; import org.junit.ClassRule;
import org.junit.Rule;
import org.junit.rules.Timeout; import org.junit.rules.Timeout;
import org.redisson.api.RedissonClient; import org.redisson.api.RedissonClient;
import org.redisson.codec.MsgPackJacksonCodec; import org.redisson.codec.MsgPackJacksonCodec;
@ -15,7 +16,9 @@ import org.redisson.config.Config;
public abstract class BaseTest { public abstract class BaseTest {
@ClassRule @ClassRule
public static Timeout classTimeout = new Timeout(15, TimeUnit.MINUTES); public static Timeout classTimeout = new Timeout(1, TimeUnit.HOURS);
@Rule
public static Timeout testTimeout = new Timeout(15, TimeUnit.MINUTES);
protected RedissonClient redisson; protected RedissonClient redisson;
protected static RedissonClient defaultRedisson; protected static RedissonClient defaultRedisson;

@ -35,12 +35,15 @@ import org.redisson.misc.RedissonPromise;
import io.netty.util.concurrent.FutureListener; import io.netty.util.concurrent.FutureListener;
import io.netty.util.concurrent.ImmediateEventExecutor; import io.netty.util.concurrent.ImmediateEventExecutor;
import org.junit.ClassRule; import org.junit.ClassRule;
import org.junit.Rule;
import org.junit.rules.Timeout; import org.junit.rules.Timeout;
public class RedisClientTest { public class RedisClientTest {
@ClassRule @ClassRule
public static Timeout classTimeout = new Timeout(15, TimeUnit.MINUTES); public static Timeout classTimeout = new Timeout(1, TimeUnit.HOURS);
@Rule
public static Timeout testTimeout = new Timeout(15, TimeUnit.MINUTES);
@BeforeClass @BeforeClass
public static void beforeClass() throws IOException, InterruptedException { public static void beforeClass() throws IOException, InterruptedException {

@ -12,6 +12,7 @@ import org.junit.Assert;
import org.junit.Before; import org.junit.Before;
import org.junit.BeforeClass; import org.junit.BeforeClass;
import org.junit.ClassRule; import org.junit.ClassRule;
import org.junit.Rule;
import org.junit.Test; import org.junit.Test;
import org.junit.rules.Timeout; import org.junit.rules.Timeout;
import org.redisson.api.RCountDownLatch; import org.redisson.api.RCountDownLatch;
@ -20,7 +21,9 @@ import org.redisson.api.RedissonClient;
public class RedissonCountDownLatchConcurrentTest { public class RedissonCountDownLatchConcurrentTest {
@ClassRule @ClassRule
public static Timeout classTimeout = new Timeout(15, TimeUnit.MINUTES); public static Timeout classTimeout = new Timeout(1, TimeUnit.HOURS);
@Rule
public static Timeout testTimeout = new Timeout(15, TimeUnit.MINUTES);
@BeforeClass @BeforeClass
public static void beforeClass() throws IOException, InterruptedException { public static void beforeClass() throws IOException, InterruptedException {

@ -15,12 +15,15 @@ import org.redisson.config.Config;
import static com.jayway.awaitility.Awaitility.await; import static com.jayway.awaitility.Awaitility.await;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;
import org.junit.ClassRule; import org.junit.ClassRule;
import org.junit.Rule;
import org.junit.rules.Timeout; import org.junit.rules.Timeout;
public class RedissonMultiLockTest { public class RedissonMultiLockTest {
@ClassRule @ClassRule
public static Timeout classTimeout = new Timeout(15, TimeUnit.MINUTES); public static Timeout classTimeout = new Timeout(1, TimeUnit.HOURS);
@Rule
public static Timeout testTimeout = new Timeout(15, TimeUnit.MINUTES);
@Test @Test
public void testMultiThreads() throws IOException, InterruptedException { public void testMultiThreads() throws IOException, InterruptedException {

@ -17,12 +17,15 @@ import org.redisson.config.Config;
import static com.jayway.awaitility.Awaitility.await; import static com.jayway.awaitility.Awaitility.await;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;
import org.junit.ClassRule; import org.junit.ClassRule;
import org.junit.Rule;
import org.junit.rules.Timeout; import org.junit.rules.Timeout;
public class RedissonRedLockTest { public class RedissonRedLockTest {
@ClassRule @ClassRule
public static Timeout classTimeout = new Timeout(15, TimeUnit.MINUTES); public static Timeout classTimeout = new Timeout(1, TimeUnit.HOURS);
@Rule
public static Timeout testTimeout = new Timeout(15, TimeUnit.MINUTES);
@Test @Test
public void testLockFailed() throws IOException, InterruptedException { public void testLockFailed() throws IOException, InterruptedException {

@ -33,13 +33,16 @@ import org.redisson.connection.ConnectionListener;
import static com.jayway.awaitility.Awaitility.await; import static com.jayway.awaitility.Awaitility.await;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;
import org.junit.ClassRule; import org.junit.ClassRule;
import org.junit.Rule;
import org.junit.rules.Timeout; import org.junit.rules.Timeout;
import static org.redisson.BaseTest.createInstance; import static org.redisson.BaseTest.createInstance;
public class RedissonTest { public class RedissonTest {
@ClassRule @ClassRule
public static Timeout classTimeout = new Timeout(15, TimeUnit.MINUTES); public static Timeout classTimeout = new Timeout(1, TimeUnit.HOURS);
@Rule
public static Timeout testTimeout = new Timeout(15, TimeUnit.MINUTES);
protected RedissonClient redisson; protected RedissonClient redisson;
protected static RedissonClient defaultRedisson; protected static RedissonClient defaultRedisson;

@ -20,6 +20,7 @@ import org.junit.Assert;
import org.junit.Before; import org.junit.Before;
import org.junit.BeforeClass; import org.junit.BeforeClass;
import org.junit.ClassRule; import org.junit.ClassRule;
import org.junit.Rule;
import org.junit.Test; import org.junit.Test;
import org.junit.rules.Timeout; import org.junit.rules.Timeout;
import org.redisson.RedisRunner.RedisProcess; import org.redisson.RedisRunner.RedisProcess;
@ -36,7 +37,9 @@ import org.redisson.config.Config;
public class RedissonTopicPatternTest { public class RedissonTopicPatternTest {
@ClassRule @ClassRule
public static Timeout classTimeout = new Timeout(15, TimeUnit.MINUTES); public static Timeout classTimeout = new Timeout(1, TimeUnit.HOURS);
@Rule
public static Timeout testTimeout = new Timeout(15, TimeUnit.MINUTES);
@BeforeClass @BeforeClass
public static void beforeClass() throws IOException, InterruptedException { public static void beforeClass() throws IOException, InterruptedException {

@ -37,12 +37,15 @@ import org.redisson.config.Config;
import com.jayway.awaitility.Awaitility; import com.jayway.awaitility.Awaitility;
import com.jayway.awaitility.Duration; import com.jayway.awaitility.Duration;
import org.junit.ClassRule; import org.junit.ClassRule;
import org.junit.Rule;
import org.junit.rules.Timeout; import org.junit.rules.Timeout;
public class RedissonTopicTest { public class RedissonTopicTest {
@ClassRule @ClassRule
public static Timeout classTimeout = new Timeout(15, TimeUnit.MINUTES); public static Timeout classTimeout = new Timeout(1, TimeUnit.HOURS);
@Rule
public static Timeout testTimeout = new Timeout(15, TimeUnit.MINUTES);
@BeforeClass @BeforeClass
public static void beforeClass() throws IOException, InterruptedException { public static void beforeClass() throws IOException, InterruptedException {

@ -21,6 +21,7 @@ import java.util.concurrent.TimeUnit;
import org.junit.AfterClass; import org.junit.AfterClass;
import org.junit.BeforeClass; import org.junit.BeforeClass;
import org.junit.ClassRule; import org.junit.ClassRule;
import org.junit.Rule;
import org.junit.rules.Timeout; import org.junit.rules.Timeout;
import static org.redisson.BaseTest.createInstance; import static org.redisson.BaseTest.createInstance;
@ -28,7 +29,9 @@ import static org.redisson.BaseTest.createInstance;
public class RedissonTwoLockedThread { public class RedissonTwoLockedThread {
@ClassRule @ClassRule
public static Timeout classTimeout = new Timeout(15, TimeUnit.MINUTES); public static Timeout classTimeout = new Timeout(1, TimeUnit.HOURS);
@Rule
public static Timeout testTimeout = new Timeout(15, TimeUnit.MINUTES);
@Parameterized.Parameters(name= "{index} - {0}") @Parameterized.Parameters(name= "{index} - {0}")
public static Iterable<Object[]> data() { public static Iterable<Object[]> data() {

Loading…
Cancel
Save