|
|
|
@ -11,6 +11,7 @@ import org.junit.jupiter.api.AfterAll;
|
|
|
|
|
import org.junit.jupiter.api.BeforeAll;
|
|
|
|
|
import org.junit.jupiter.api.Test;
|
|
|
|
|
import org.redisson.BaseTest;
|
|
|
|
|
import org.redisson.RedisDockerTest;
|
|
|
|
|
import org.redisson.RedisRunner.FailedToStartRedisException;
|
|
|
|
|
import org.redisson.RedissonNode;
|
|
|
|
|
import org.redisson.api.RExecutorFuture;
|
|
|
|
@ -26,7 +27,7 @@ import org.springframework.context.annotation.ComponentScan;
|
|
|
|
|
import org.springframework.context.annotation.Configuration;
|
|
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
|
|
|
|
public class RedissonExecutorServiceSpringTest extends BaseTest {
|
|
|
|
|
public class RedissonExecutorServiceSpringTest extends RedisDockerTest {
|
|
|
|
|
|
|
|
|
|
public static class SampleRunnable implements Runnable, Serializable {
|
|
|
|
|
|
|
|
|
@ -79,7 +80,7 @@ public class RedissonExecutorServiceSpringTest extends BaseTest {
|
|
|
|
|
|
|
|
|
|
@Bean(destroyMethod = "shutdown")
|
|
|
|
|
RedissonNode redissonNode(BeanFactory beanFactory) {
|
|
|
|
|
Config config = BaseTest.createConfig();
|
|
|
|
|
Config config = createConfig();
|
|
|
|
|
RedissonNodeConfig nodeConfig = new RedissonNodeConfig(config);
|
|
|
|
|
nodeConfig.setExecutorServiceWorkers(Collections.singletonMap(EXECUTOR_NAME, 1));
|
|
|
|
|
nodeConfig.setBeanFactory(beanFactory);
|
|
|
|
|