diff --git a/redisson/src/test/java/org/redisson/RedisClientTest.java b/redisson/src/test/java/org/redisson/RedisClientTest.java index 60036a808..c1e7b40e4 100644 --- a/redisson/src/test/java/org/redisson/RedisClientTest.java +++ b/redisson/src/test/java/org/redisson/RedisClientTest.java @@ -9,6 +9,7 @@ import org.redisson.client.codec.StringCodec; import org.redisson.client.protocol.CommandData; import org.redisson.client.protocol.CommandsData; import org.redisson.client.protocol.RedisCommands; +import org.redisson.client.protocol.RedisStrictCommand; import org.redisson.client.protocol.pubsub.PubSubType; import org.redisson.config.Protocol; import org.testcontainers.containers.GenericContainer; @@ -37,7 +38,7 @@ public class RedisClientTest { @BeforeAll public static void beforeAll() { RedisClientConfig config = new RedisClientConfig(); - config.setProtocol(Protocol.RESP3); + config.setProtocol(Protocol.RESP2); config.setAddress("redis://127.0.0.1:" + REDIS.getFirstMappedPort()); redisClient = RedisClient.create(config); } @@ -47,6 +48,22 @@ public class RedisClientTest { redisClient.shutdown(); } + @Test + public void testUsername() { + RedisClientConfig cc = redisClient.getConfig(); + + RedisConnection c = redisClient.connect(); + c.sync(new RedisStrictCommand("ACL"), "SETUSER", "testuser", "on", ">123456", "~*", "allcommands"); + c.close(); + + cc.setUsername("testuser"); + cc.setPassword("123456"); + RedisClient client = RedisClient.create(cc); + RedisConnection c2 = client.connect(); + assertThat(c2.sync(RedisCommands.PING)).isEqualTo("PONG"); + client.shutdown(); + } + @Test public void testClientTrackingBroadcast() throws InterruptedException, ExecutionException { RedisPubSubConnection c = redisClient.connectPubSub();