adds overload to make usage from Java more ergonomic

Author: ayedo

src/main/kotlin/PostgresFlowable.kt

@@ -100,4 +100,22 @@ object PostgresNotifyFlowable {
         return retryingObservable.share()
     }
 
+    /**
+     * A variant of [forChannels] with defaults set, to make usage from Java more ergonomic
+     */
+    fun forChannels(
+        jdbcUrl: String,
+        user: String,
+        password: String,
+        channels: List<String>
+        ): Flowable<PGNotification> = forChannels(
+        jdbcUrl = jdbcUrl,
+        user = user,
+        password = password,
+        pollingPeriodMs = 1000,
+        reconnectionTimeoutMs = 5000,
+        channels = channels,
+        backpressureStrategy = BUFFER
+    )
+
 }

src/test/kotlin/IntegrationTest.kt

@@ -1,4 +1,5 @@
 import ch.sponty.backend.common.database.postgres.PostgresNotifyFlowable
+import io.reactivex.BackpressureStrategy
 import io.reactivex.schedulers.Schedulers
 import org.junit.jupiter.api.Test
 import org.postgresql.jdbc.PgConnection
@@ -28,7 +29,7 @@ class PostgresFlowableTest {
             password = db.password,
             pollingPeriodMs = 1000,
             channels = listOf("test"),
-            backpressureStrategy = BUFFER
+            backpressureStrategy = BackpressureStrategy.BUFFER
         )
 
         val latch = CountDownLatch(4)