JedisClusterPrefixedKeysTest.java

package redis.clients.jedis.prefix;

import java.util.stream.Collectors;
import java.util.Set;
import org.junit.jupiter.api.Test;

import redis.clients.jedis.HostAndPorts;
import redis.clients.jedis.DefaultJedisClientConfig;
import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisClientConfig;
import redis.clients.jedis.JedisCluster;

import static org.junit.jupiter.api.Assertions.assertThrows;

public class JedisClusterPrefixedKeysTest extends PrefixedKeysTest<JedisCluster> {

  private static final JedisClientConfig CLIENT_CONFIG = DefaultJedisClientConfig.builder().password("cluster").build();
  private static final Set<HostAndPort> NODES = HostAndPorts.getStableClusterServers().stream().collect(Collectors.toSet());

  @Override
  JedisCluster nonPrefixingJedis() {
    return new JedisCluster(NODES, CLIENT_CONFIG);
  }

  @Override
  @Test
  public void prefixesKeysInTransaction() {
    assertThrows(UnsupportedOperationException.class, () -> super.prefixesKeysInTransaction());
  }
}