Redis shutdown improvements

pull/1461/head
Nikita 7 years ago
parent f1b10deb5d
commit 28b0c49acb

@ -1,8 +1,8 @@
package org.redisson; package org.redisson;
import java.io.IOException; import java.io.IOException;
import org.junit.After; import org.junit.After;
import org.junit.AfterClass;
import org.junit.Before; import org.junit.Before;
import org.junit.BeforeClass; import org.junit.BeforeClass;
import org.redisson.api.RedissonClient; import org.redisson.api.RedissonClient;
@ -18,14 +18,18 @@ public abstract class BaseTest {
if (!RedissonRuntimeEnvironment.isTravis) { if (!RedissonRuntimeEnvironment.isTravis) {
RedisRunner.startDefaultRedisServerInstance(); RedisRunner.startDefaultRedisServerInstance();
defaultRedisson = createInstance(); defaultRedisson = createInstance();
} Runtime.getRuntime().addShutdownHook(new Thread() {
} @Override
public void run() {
@AfterClass defaultRedisson.shutdown();
public static void afterClass() throws IOException, InterruptedException { try {
if (!RedissonRuntimeEnvironment.isTravis) { RedisRunner.shutDownDefaultRedisServerInstance();
defaultRedisson.shutdown(); } catch (InterruptedException e) {
RedisRunner.shutDownDefaultRedisServerInstance(); // TODO Auto-generated catch block
e.printStackTrace();
}
}
});
} }
} }

Loading…
Cancel
Save