Use redis cluter

.github/workflows/integration-tests.yml

@@ -20,7 +20,7 @@ jobs:
         env:
           INITIAL_PORT: 7010
         options: >-
-          --health-cmd "/redis-build/bin/redis-cli -p 7010 ping"
+          --health-cmd "redis-cli -p 7010 ping"
           --health-interval 10s
           --health-timeout 5s
           --health-retries 5
@@ -31,7 +31,7 @@ jobs:
         env:
           INITIAL_PORT: 7020
         options: >-
-          --health-cmd "/redis-build/bin/redis-cli -p 7020 ping"
+          --health-cmd "redis-cli -p 7020 ping"
           --health-interval 10s
           --health-timeout 5s
           --health-retries 5
@@ -42,7 +42,7 @@ jobs:
         env:
           INITIAL_PORT: 7030
         options: >-
-          --health-cmd "/redis-build/bin/redis-cli -p 7030 ping"
+          --health-cmd "redis-cli -p 7030 ping"
           --health-interval 10s
           --health-timeout 5s
           --health-retries 5

build.gradle.kts

@@ -18,7 +18,7 @@ plugins {
 
 allprojects {
     group = "com.himadieiev"
-    version = "1.3.0"
+    version = "1.3.1"
 
     repositories {
         mavenCentral()

redpulsar-jedis/src/test/kotlin/com/himadieiev/redpulsar/jedis/integrationtests/SemaphoreIntegrationTest.kt

@@ -127,7 +127,7 @@ class SemaphoreIntegrationTest {
 
         (1..maxLeases)
             .forEach {
-                assertTrue(semaphores[it - 1].lock("test", Duration.ofSeconds(1)))
+                assertTrue(semaphores[it - 1].lock("test", Duration.ofSeconds(2)))
             }
         val semaphores2 = mutableListOf<Semaphore>()
         (1..maxLeases)
@@ -147,7 +147,7 @@ class SemaphoreIntegrationTest {
             }
 
         runBlocking {
-            delay(2000)
+            delay(3000)
         }
         (1..maxLeases)
             .forEach {