compilation fixed

redisson-spring-data/redisson-spring-data-32/src/test/java/org/redisson/spring/data/connection/RedissonSubscribeReactiveTest.java

@@ -1,7 +1,7 @@
 package org.redisson.spring.data.connection;
 
 import org.awaitility.Awaitility;
-import org.awaitility.Duration;
+import org.awaitility.Durations;
 import org.junit.Test;
 import org.springframework.data.redis.connection.BitFieldSubCommands;
 import org.springframework.data.redis.connection.ReactiveRedisConnection;
@@ -36,7 +36,7 @@ public class RedissonSubscribeReactiveTest extends BaseConnectionTest {
             connection.pubSubCommands().publish(ByteBuffer.wrap("test".getBytes()), ByteBuffer.wrap("msg".getBytes())).block();
         }
 
-        Awaitility.await().atMost(Duration.ONE_SECOND).untilAsserted(() -> {
+        Awaitility.await().atMost(Durations.ONE_SECOND).untilAsserted(() -> {
             assertThat(counter.get()).isEqualTo(40);
         });
     }
@@ -60,7 +60,7 @@ public class RedissonSubscribeReactiveTest extends BaseConnectionTest {
         ReactiveRedisConnection connection = factory.getReactiveConnection();
         connection.pubSubCommands().publish(ByteBuffer.wrap("test".getBytes()), ByteBuffer.wrap("msg".getBytes())).block();
 
-        Awaitility.await().atMost(Duration.ONE_SECOND)
+        Awaitility.await().atMost(Durations.ONE_SECOND)
                     .until(() -> counter.get() == 1);
 
         BitFieldSubCommands commands = BitFieldSubCommands.create()
@@ -76,7 +76,7 @@ public class RedissonSubscribeReactiveTest extends BaseConnectionTest {
             result.set(r);
         }).subscribe();
 
-        Awaitility.waitAtMost(Duration.FIVE_HUNDRED_MILLISECONDS).untilAsserted(() -> {
+        Awaitility.waitAtMost(Durations.FIVE_HUNDRED_MILLISECONDS).untilAsserted(() -> {
             assertThat(result.get()).isEqualTo(Arrays.asList(0L, 0L, 0L));
         });
     }
@@ -96,7 +96,7 @@ public class RedissonSubscribeReactiveTest extends BaseConnectionTest {
         
         connection.pubSubCommands().publish(ByteBuffer.wrap("test".getBytes()), ByteBuffer.wrap("msg".getBytes())).block();
 
-        Awaitility.await().atMost(Duration.ONE_SECOND)
+        Awaitility.await().atMost(Durations.ONE_SECOND)
                     .until(() -> Arrays.equals("msg".getBytes(), msg.get()));
         
         ss.unsubscribe();
@@ -118,7 +118,7 @@ public class RedissonSubscribeReactiveTest extends BaseConnectionTest {
         }).subscribe();
         
         connection.pubSubCommands().publish(ByteBuffer.wrap("test".getBytes()), ByteBuffer.wrap("msg".getBytes())).block();
-        Awaitility.await().atMost(Duration.ONE_SECOND)
+        Awaitility.await().atMost(Durations.ONE_SECOND)
                     .until(() -> Arrays.equals("msg".getBytes(), msg.get()));
         
         ss.unsubscribe();

redisson-spring-data/redisson-spring-data-32/src/test/java/org/redisson/spring/data/connection/RedissonSubscribeTest.java

@@ -1,7 +1,7 @@
 package org.redisson.spring.data.connection;
 
 import org.awaitility.Awaitility;
-import org.awaitility.Duration;
+import org.awaitility.Durations;
 import org.junit.Test;
 import org.redisson.ClusterRunner;
 import org.redisson.RedisRunner;
@@ -163,7 +163,7 @@ public class RedissonSubscribeTest extends BaseConnectionTest {
         factory.getConnection().setEx("test:key2".getBytes(), 3, "123".getBytes());
         factory.getConnection().setEx("test:key1".getBytes(), 3, "123".getBytes());
 
-        Awaitility.await().atMost(Duration.FIVE_SECONDS).untilAsserted(() -> {
+        Awaitility.await().atMost(Durations.FIVE_SECONDS).untilAsserted(() -> {
             assertThat(names).containsExactlyInAnyOrder("EG:test:key1", "test:key2", "test:key1");
         });
 
@@ -191,7 +191,7 @@ public class RedissonSubscribeTest extends BaseConnectionTest {
         RedisConnection c = factory.getConnection();
         c.publish("a".getBytes(), "msg".getBytes());
 
-        Awaitility.await().atMost(Duration.ONE_SECOND)
+        Awaitility.await().atMost(Durations.ONE_SECOND)
                 .untilAsserted(() -> {
                     assertThat(msg).containsExactly("msg".getBytes());
                 });
@@ -239,7 +239,7 @@ public class RedissonSubscribeTest extends BaseConnectionTest {
         c.set("mykey".getBytes(), "2".getBytes());
         c.del("mykey".getBytes());
 
-        Awaitility.await().atMost(Duration.FIVE_SECONDS).until(() -> {
+        Awaitility.await().atMost(Durations.FIVE_SECONDS).until(() -> {
             return counterTest.get() == 3;
         });
 
@@ -259,7 +259,7 @@ public class RedissonSubscribeTest extends BaseConnectionTest {
         }, "test".getBytes());
         
         connection.publish("test".getBytes(), "msg".getBytes());
-        Awaitility.await().atMost(Duration.ONE_SECOND)
+        Awaitility.await().atMost(Durations.ONE_SECOND)
                     .until(() -> Arrays.equals("msg".getBytes(), msg.get()));
         
         connection.getSubscription().unsubscribe();
@@ -279,7 +279,7 @@ public class RedissonSubscribeTest extends BaseConnectionTest {
         }, "test".getBytes());
         
         connection.publish("test".getBytes(), "msg".getBytes());
-        Awaitility.await().atMost(Duration.ONE_SECOND)
+        Awaitility.await().atMost(Durations.ONE_SECOND)
                     .until(() -> Arrays.equals("msg".getBytes(), msg.get()));
         
         connection.getSubscription().unsubscribe();