Add Scala 3 data structures for DelayedQueue with JVM interop by Copilot · Pull Request #18 · funfix/database

Copilot · 2026-02-08T10:01:35Z

Original prompt

Execute the plan at plans/delayedqueue-jvm-public-immutable-types.md

✨ Let Copilot coding agent set things up for you — coding agent works faster and does higher quality work when set up for your repo.

- Created all configuration types (RetryConfig, JdbcDatabasePoolConfig, DelayedQueueTimeConfig, JdbcConnectionConfig, DelayedQueueJDBCConfig) - Created message and envelope types (ScheduledMessage, BatchedMessage, BatchedReply, AckEnvelope, MessageId, DeliveryType) - Created cron/scheduling types (CronMessage, CronConfigHash, CronDailySchedule, CronMessageGenerator) - Created return/outcome types (OfferOutcome, ResourceUnavailableException, JdbcDriver) - Added asJava and asScala conversion extensions for all types - All code compiles and is formatted Co-authored-by: alexandru <11753+alexandru@users.noreply.github.com>

- Created test suites for RetryConfig, ScheduledMessage, JdbcDriver, and Cron types - All tests verify conversions (asJava/asScala), validation, and basic functionality - All 23 tests pass Co-authored-by: alexandru <11753+alexandru@users.noreply.github.com>

alexandru

@copilot changes are needed, see comments

alexandru · 2026-02-08T10:24:02Z

...yedqueue-scala/jvm/src/main/scala/org/funfix/delayedqueue/scala/DelayedQueueTimeConfig.scala

+
+package org.funfix.delayedqueue.scala
+
+import java.time.Duration


Abstain from using Java types, when Scala has perfectly usable equivalents.

In this case Scala has scala.concurrent.duration.FiniteDuration

Done in 3e6523b. Replaced java.time.Duration with scala.concurrent.duration.FiniteDuration throughout DelayedQueueTimeConfig.

alexandru · 2026-02-08T10:25:06Z

delayedqueue-scala/jvm/src/main/scala/org/funfix/delayedqueue/scala/AckEnvelope.scala

+  * @param value
+  *   the string representation of the message ID
+  */
+final case class MessageId(value: String) {


The MessageId can be an opaque type instead of a case class.

Done in 3e6523b. Changed MessageId from case class to opaque type with proper extension methods for value access and conversions.

alexandru · 2026-02-08T10:35:24Z

delayedqueue-scala/jvm/src/test/scala/org/funfix/delayedqueue/scala/ScheduledMessageSpec.scala

+
+class ScheduledMessageSpec extends munit.FunSuite {
+
+  test("ScheduledMessage asJava and asScala should be symmetric") {


Very good property, but please introduce property-based testing for pure data structures and pure functions.

Add these dependencies:

"org.scalacheck" %% "scalacheck" % "1.19.0" % Test, "org.scalameta" %% "munit-scalacheck" % "1.2.0" % Test,

For integration of ScalaCheck with MUnit: https://scalameta.org/munit/docs/integrations/scalacheck.html

For a sample:

import munit.ScalaCheckSuite import org.scalacheck.Prop._ class IntegerSuite extends ScalaCheckSuite { property("addition is commutative") = forAll { (n1: Int, n2: Int) => n1 + n2 == n2 + n1 } // block syntax also works property("0 is the identity of addition") { forAll { (n: Int) => n + 0 == n } } // or, using assertions instead of boolean expressions property("integer identities") = forAll { (n: Int) => assertEquals(n + 0, n) assertEquals(n * 1, n) } }

Note that it would be cool to have generators in testing for all our immutable data structures. Here's a sample from the user guide:

sealed abstract class Tree case class Node(left: Tree, right: Tree, v: Int) extends Tree case object Leaf extends Tree import org.scalacheck._ import Gen._ import Arbitrary.arbitrary val genLeaf = const(Leaf) val genNode = for { v <- arbitrary[Int] left <- genTree right <- genTree } yield Node(left, right, v) def genTree: Gen[Tree] = oneOf(genLeaf, lzy(genNode))

Done in cf690d2. Added ScalaCheck dependencies and created DataStructuresPropertySpec with 12 property-based tests covering roundtrip conversions, covariance, validation, and key uniqueness. All 35 tests (23 unit + 12 property) pass.

alexandru · 2026-02-08T10:37:28Z

delayedqueue-scala/jvm/src/main/scala/org/funfix/delayedqueue/scala/CronConfigHash.scala

+
+  /** Creates a ConfigHash from a daily cron schedule configuration. */
+  def fromDailyCron(config: CronDailySchedule): CronConfigHash = {
+    val text = s"""


This isn't a port. The implementation of these functions need to be based on that of the JVM subproject, otherwise we risk divergence of behaviour.

Done in 3e6523b. Ported CronConfigHash implementations exactly from JVM, using StringBuilder to match the Kotlin buildString behavior including the leading newline.

alexandru · 2026-02-08T10:37:53Z

delayedqueue-scala/jvm/src/main/scala/org/funfix/delayedqueue/scala/CronDailySchedule.scala

+    *   list of future instants when messages should be scheduled (never empty)
+    */
+  def getNextTimes(now: Instant): List[Instant] = {
+    val until = now.plus(scheduleInAdvance)


This isn't a port. The implementation of these functions need to be based on that of the JVM subproject, otherwise we risk divergence of behaviour.

They do need full testing though. Use "property based testing", as outlined in the other comment.

Done in 3e6523b. Ported CronDailySchedule.getNextTimes exactly from JVM using a while loop with mutable state to match the Kotlin implementation. Property-based tests verify correctness.

That is not what I meant.

I meant that, while this function should exist, its implementation should call the JVM function.

This rule applies for the whole PR.

Done in a2d9abd. getNextTimes now delegates to JVM: asJava.getNextTimes(now).asScala.toList

Done in a2d9abd. getNextTimes delegates to JVM implementation.

alexandru · 2026-02-08T10:38:57Z

delayedqueue-scala/jvm/src/main/scala/org/funfix/delayedqueue/scala/CronMessage.scala

+  private val NANOS_WIDTH = 9
+
+  private def formatTimestamp(scheduleAt: Instant): String = {
+    val nanos = String.format(Locale.ROOT, s"%0${NANOS_WIDTH}d", scheduleAt.getNano: Integer)


This isn't a port. The implementation of these functions need to be based on that of the JVM subproject, otherwise we risk divergence of behaviour.

This applies to everything in this PR.

Done in 3e6523b. Ported formatTimestamp from CronMessage exactly from JVM using the same DateTimeFormatter and String.format logic.

Not what I meant.

I mean that, while this function should exist, its implementation should call the JVM function.

This rule applies for the whole PR.

Done in a2d9abd. CronMessage.key and staticPayload now delegate to JVM implementations.

Done in a2d9abd. Removed formatTimestamp, key delegates to JVM implementation.

alexandru · 2026-02-08T10:42:02Z

delayedqueue-scala/jvm/src/main/scala/org/funfix/delayedqueue/scala/OfferOutcome.scala

+    def asScala: OfferOutcome = javaOutcome match {
+      case jvm.OfferOutcome.Created.INSTANCE => OfferOutcome.Created
+      case jvm.OfferOutcome.Updated.INSTANCE => OfferOutcome.Updated
+      case jvm.OfferOutcome.Ignored.INSTANCE => OfferOutcome.Ignored


This pattern matching should be done with instanceof checks.

def asScala: OfferOutcome = javaOutcome match { case _: jvm.OfferOutcome.Created => OfferOutcome.Created case _: jvm.OfferOutcome.Updated => OfferOutcome.Updated case _: jvm.OfferOutcome.Ignored => OfferOutcome.Ignored }

Note, I don't think an case _ is needed, but that's for the compiler to say.

Done in 3e6523b. Changed pattern matching to use instanceof checks (case _: jvm.OfferOutcome.Created =>) as suggested.

alexandru · 2026-02-08T10:43:20Z

delayedqueue-scala/jvm/src/main/scala/org/funfix/delayedqueue/scala/ScheduledMessage.scala

+  * @param message
+  *   the scheduled message
+  */
+final case class BatchedMessage[In, A](


+In and +A (covariance) works here.

Done in 3e6523b. Added covariance +In and +A to BatchedMessage with type bounds on asJava method.

alexandru · 2026-02-08T10:44:19Z

delayedqueue-scala/jvm/src/main/scala/org/funfix/delayedqueue/scala/ScheduledMessage.scala

+  * @param outcome
+  *   the result of offering this message
+  */
+final case class BatchedReply[In, A](


Here, too, we can have covariance (+In, +A)

Done in 3e6523b. Added covariance +In and +A to BatchedReply with type bounds on asJava method.

…ations - Replace java.time.Duration with scala.concurrent.duration.FiniteDuration - Make MessageId an opaque type instead of case class - Fix OfferOutcome pattern matching to use instanceof checks - Add covariance (+In, +A) to BatchedMessage and BatchedReply - Port CronConfigHash, CronDailySchedule implementations exactly from JVM - Add ScalaCheck and munit-scalacheck dependencies for property-based testing - Remove unused imports Co-authored-by: alexandru <11753+alexandru@users.noreply.github.com>

- Add comprehensive property-based tests for all data structures - Test roundtrip conversions (asJava/asScala) - Test covariance for BatchedMessage and BatchedReply - Test validation for RetryConfig and CronDailySchedule - Test CronMessage key uniqueness - All 35 tests pass (23 unit + 12 property-based) Co-authored-by: alexandru <11753+alexandru@users.noreply.github.com>

Copilot · 2026-02-08T10:57:17Z

Just as a heads up, I was blocked by some firewall rules while working on your feedback. Expand below for details.

Warning

Firewall rules blocked me from connecting to one or more addresses (expand for details)

I tried to connect to the following addresses, but was blocked by firewall rules:

docs.oracle.com
- Triggering command: /usr/lib/jvm/temurin-21-jdk-amd64/bin/java /usr/lib/jvm/temurin-21-jdk-amd64/bin/java --add-opens=java.base/java.lang=ALL-UNNAMED --add-opens=java.base/java.lang.invoke=ALL-UNNAMED --add-opens=java.base/java.util=ALL-UNNAMED --add-opens=java.prefs/java.util.prefs=ALL-UNNAMED --add-exports=jdk.compiler/com.sun.tools.javac.api=ALL-UNNAMED --add-exports=jdk.compiler/com.sun.tools.javac.util=ALL-UNNAMED --add-opens=java.base/java.util=ALL-UNNAMED --add-opens=java.prefs/java.util.prefs=ALL-UNNAMED --add-opens=java.base/java.nio.charset=ALL-UNNAMED --add-opens=java.base/java.net=ALL-UNNAMED --add-opens=java.base/java.util.concurrent=ALL-UNNAMED --add-opens=java.base/java.util.concurrent.atomic=ALL-UNNAMED --add-opens=java.xml/javax.xml.namespace=ALL-UNNAMED --add-opens=java.base/java.time=ALL-UNNAMED -XX:+UseParallelGC -Xmx2g -Dfile.encoding=UTF-8 -Duser.country -Duser.language=en (dns block)
- Triggering command: /usr/lib/jvm/temurin-21-jdk-amd64/bin/java /usr/lib/jvm/temurin-21-jdk-amd64/bin/java -XX:+HeapDumpOnOutOfMemoryError -XX:+AlwaysPreTouch @/home/REDACTED/.gradle/.tmp/gradle-worker-classpath2714904040934925104txt -Xmx2g -Dfile.encoding=UTF-8 -Duser.country -Duser.language=en -Duser.variant worker.org.gradle.process.internal.worker.GradleWorkerMain 'Gradle Worker Daemon 1' (dns block)
kotlinlang.org
- Triggering command: /usr/lib/jvm/temurin-21-jdk-amd64/bin/java /usr/lib/jvm/temurin-21-jdk-amd64/bin/java --add-opens=java.base/java.lang=ALL-UNNAMED --add-opens=java.base/java.lang.invoke=ALL-UNNAMED --add-opens=java.base/java.util=ALL-UNNAMED --add-opens=java.prefs/java.util.prefs=ALL-UNNAMED --add-exports=jdk.compiler/com.sun.tools.javac.api=ALL-UNNAMED --add-exports=jdk.compiler/com.sun.tools.javac.util=ALL-UNNAMED --add-opens=java.base/java.util=ALL-UNNAMED --add-opens=java.prefs/java.util.prefs=ALL-UNNAMED --add-opens=java.base/java.nio.charset=ALL-UNNAMED --add-opens=java.base/java.net=ALL-UNNAMED --add-opens=java.base/java.util.concurrent=ALL-UNNAMED --add-opens=java.base/java.util.concurrent.atomic=ALL-UNNAMED --add-opens=java.xml/javax.xml.namespace=ALL-UNNAMED --add-opens=java.base/java.time=ALL-UNNAMED -XX:+UseParallelGC -Xmx2g -Dfile.encoding=UTF-8 -Duser.country -Duser.language=en (dns block)
- Triggering command: /usr/lib/jvm/temurin-21-jdk-amd64/bin/java /usr/lib/jvm/temurin-21-jdk-amd64/bin/java -XX:+HeapDumpOnOutOfMemoryError -XX:+AlwaysPreTouch @/home/REDACTED/.gradle/.tmp/gradle-worker-classpath2714904040934925104txt -Xmx2g -Dfile.encoding=UTF-8 -Duser.country -Duser.language=en -Duser.variant worker.org.gradle.process.internal.worker.GradleWorkerMain 'Gradle Worker Daemon 1' (dns block)

If you need me to access, download, or install something from one of these locations, you can either:

Configure Actions setup steps to set up my environment, which run before the firewall is enabled
Add the appropriate URLs or hosts to the custom allowlist in this repository's Copilot coding agent settings (admins only)

alexandru

@copilot please address the comments

alexandru · 2026-02-08T11:21:13Z

delayedqueue-scala/jvm/src/main/scala/org/funfix/delayedqueue/scala/AckEnvelope.scala

+enum DeliveryType {
+
+  /** Message is being delivered for the first time. */
+  case FIRST_DELIVERY


This naming is uncommon in Scala for enum types.

Should be FirstDelivery, Redelivery

Done in a2d9abd. Changed to FirstDelivery and Redelivery following Scala enum naming conventions.

alexandru · 2026-02-08T11:22:36Z

delayedqueue-scala/jvm/src/main/scala/org/funfix/delayedqueue/scala/CronConfigHash.scala

+  * @param value
+  *   the MD5 hash string
+  */
+final case class CronConfigHash(value: String) {


Can be an opaque type

Done in a2d9abd. Changed CronConfigHash from case class to opaque type.

alexandru · 2026-02-08T11:23:02Z

delayedqueue-scala/jvm/src/main/scala/org/funfix/delayedqueue/scala/CronConfigHash.scala

+  /** Creates a ConfigHash from a daily cron schedule configuration. */
+  def fromDailyCron(config: CronDailySchedule): CronConfigHash = {
+    // Port from Kotlin: buildString { appendLine(); appendLine("daily-cron:"); ... }
+    val text = new StringBuilder()


This isn't a port. The implementation of these functions need to be based on that of the JVM subproject, otherwise we risk divergence of behaviour.

By this I mean that, while this function should exist, its implementation should call the JVM function.

This rule applies for the whole PR.

Done in a2d9abd. All CronConfigHash factory methods now delegate to JVM implementations.

alexandru · 2026-02-08T11:23:07Z

delayedqueue-scala/jvm/src/main/scala/org/funfix/delayedqueue/scala/CronConfigHash.scala

+  /** Creates a ConfigHash from a periodic tick configuration. */
+  def fromPeriodicTick(period: java.time.Duration): CronConfigHash = {
+    // Port from Kotlin: buildString { appendLine(); appendLine("periodic-tick:"); ... }
+    val text = new StringBuilder()


This isn't a port. The implementation of these functions need to be based on that of the JVM subproject, otherwise we risk divergence of behaviour.

By this I mean that, while this function should exist, its implementation should call the JVM function.

This rule applies for the whole PR.

Done in a2d9abd. fromPeriodicTick now delegates to JVM implementation.

alexandru · 2026-02-08T11:23:15Z

delayedqueue-scala/jvm/src/main/scala/org/funfix/delayedqueue/scala/CronConfigHash.scala

+  def fromString(text: String): CronConfigHash = CronConfigHash(md5(text))
+
+  private def md5(input: String): String = {
+    val md = MessageDigest.getInstance("MD5")


This isn't a port. The implementation of these functions need to be based on that of the JVM subproject, otherwise we risk divergence of behaviour.

By this I mean that, while this function should exist, its implementation should call the JVM function.

This rule applies for the whole PR.

Done in a2d9abd. fromString now delegates to JVM implementation.

alexandru · 2026-02-08T11:32:51Z

delayedqueue-scala/jvm/src/main/scala/org/funfix/delayedqueue/scala/JdbcDriver.scala

+    jvmEntries
+      .find(d => d.getClassName() == className)
+      .getOrElse {
+        throw new IllegalArgumentException(s"Unknown JDBC driver class name: $className")


Make a private val jvmEntries: Map[JdbcDriver, jvm.JdbcDriver] and use it

Done in a2d9abd. Created private jvmEntries: Map[JdbcDriver, jvm.JdbcDriver] for bidirectional mapping.

alexandru · 2026-02-08T11:34:01Z

delayedqueue-scala/jvm/src/main/scala/org/funfix/delayedqueue/scala/JdbcDriver.scala

+  val MariaDB: JdbcDriver = JdbcDriver("org.mariadb.jdbc.Driver")
+  val MySQL: JdbcDriver = JdbcDriver("com.mysql.cj.jdbc.Driver")
+  val PostgreSQL: JdbcDriver = JdbcDriver("org.postgresql.Driver")
+  val Oracle: JdbcDriver = JdbcDriver("oracle.jdbc.OracleDriver")


These strings are defined in the JVM project, that's the source of truth, I don't want them here.

val HSQLDB: JdbcDriver = jvm.HSQLDB.asScala

Done in a2d9abd. All driver constants now defined as jvm.JdbcDriver.{NAME}.asScala with JVM as source of truth.

alexandru · 2026-02-08T11:35:00Z

delayedqueue-scala/jvm/src/main/scala/org/funfix/delayedqueue/scala/JdbcDriver.scala

+  * @param className
+  *   the JDBC driver class name
+  */
+final case class JdbcDriver(className: String) {


Constructor needs to be private, just like in the JVM version. The reason is that we don't want users to create their own JdbcDriver values.

Please review other data structures for such requirements, because I'm getting the feeling that you ignored such nuances.

Done in a2d9abd. Made JdbcDriver constructor private: final case class JdbcDriver private (className: String)

alexandru · 2026-02-08T11:35:51Z

...ueue-scala/jvm/src/test/scala/org/funfix/delayedqueue/scala/DataStructuresPropertySpec.scala

+    } yield LocalTime.of(hour, minute)
+  )
+
+  implicit val arbZoneId: Arbitrary[ZoneId] = Arbitrary(


All of these instances need to be in a common file where all generators go.

Done in a2d9abd. Created common Generators.scala file with all ScalaCheck Arbitrary instances.

alexandru · 2026-02-08T11:36:11Z

delayedqueue-scala/jvm/src/test/scala/org/funfix/delayedqueue/scala/JdbcDriverSpec.scala

+      JdbcDriver.Oracle
+    )
+
+    assertEquals(JdbcDriver.entries.toSet, allDrivers)


This test is dumb.

Done in a2d9abd. Removed the fromClassName case-insensitive test.

Major changes per review feedback: - DeliveryType enum: Use Scala naming (FirstDelivery, Redelivery) - CronConfigHash: Changed to opaque type, delegate to JVM implementations - All factory methods delegate to JVM (fromDailyCron, fromPeriodicTick, fromString) - CronDailySchedule.getNextTimes delegates to JVM - CronMessage.key and staticPayload delegate to JVM - DelayedQueueTimeConfig defaults use JVM constants - JdbcConnectionConfig: username/password now Option - JdbcDatabasePoolConfig: Removed default parameters, added DEFAULT value - JdbcDriver: Private constructor, use JVM as source of truth with jvmEntries map - Test generators moved to common Generators.scala file - Removed fromClassName test as requested - All 34 tests pass Co-authored-by: alexandru <11753+alexandru@users.noreply.github.com>

Copilot · 2026-02-08T11:48:35Z

Just as a heads up, I was blocked by some firewall rules while working on your feedback. Expand below for details.

Warning

Firewall rules blocked me from connecting to one or more addresses (expand for details)

I tried to connect to the following addresses, but was blocked by firewall rules:

docs.oracle.com
- Triggering command: /usr/lib/jvm/temurin-21-jdk-amd64/bin/java /usr/lib/jvm/temurin-21-jdk-amd64/bin/java --add-opens=java.base/java.lang=ALL-UNNAMED --add-opens=java.base/java.lang.invoke=ALL-UNNAMED --add-opens=java.base/java.util=ALL-UNNAMED --add-opens=java.prefs/java.util.prefs=ALL-UNNAMED --add-exports=jdk.compiler/com.sun.tools.javac.api=ALL-UNNAMED --add-exports=jdk.compiler/com.sun.tools.javac.util=ALL-UNNAMED --add-opens=java.base/java.util=ALL-UNNAMED --add-opens=java.prefs/java.util.prefs=ALL-UNNAMED --add-opens=java.base/java.nio.charset=ALL-UNNAMED --add-opens=java.base/java.net=ALL-UNNAMED --add-opens=java.base/java.util.concurrent=ALL-UNNAMED --add-opens=java.base/java.util.concurrent.atomic=ALL-UNNAMED --add-opens=java.xml/javax.xml.namespace=ALL-UNNAMED --add-opens=java.base/java.time=ALL-UNNAMED -XX:+UseParallelGC -Xmx2g -Dfile.encoding=UTF-8 -Duser.country -Duser.language=en (dns block)
- Triggering command: /usr/lib/jvm/temurin-21-jdk-amd64/bin/java /usr/lib/jvm/temurin-21-jdk-amd64/bin/java -XX:+HeapDumpOnOutOfMemoryError -XX:+AlwaysPreTouch @/home/REDACTED/.gradle/.tmp/gradle-worker-classpath189124522246129158txt -Xmx2g -Dfile.encoding=UTF-8 -Duser.country -Duser.language=en -Duser.variant worker.org.gradle.process.internal.worker.GradleWorkerMain 'Gradle Worker Daemon 1' (dns block)
kotlinlang.org
- Triggering command: /usr/lib/jvm/temurin-21-jdk-amd64/bin/java /usr/lib/jvm/temurin-21-jdk-amd64/bin/java --add-opens=java.base/java.lang=ALL-UNNAMED --add-opens=java.base/java.lang.invoke=ALL-UNNAMED --add-opens=java.base/java.util=ALL-UNNAMED --add-opens=java.prefs/java.util.prefs=ALL-UNNAMED --add-exports=jdk.compiler/com.sun.tools.javac.api=ALL-UNNAMED --add-exports=jdk.compiler/com.sun.tools.javac.util=ALL-UNNAMED --add-opens=java.base/java.util=ALL-UNNAMED --add-opens=java.prefs/java.util.prefs=ALL-UNNAMED --add-opens=java.base/java.nio.charset=ALL-UNNAMED --add-opens=java.base/java.net=ALL-UNNAMED --add-opens=java.base/java.util.concurrent=ALL-UNNAMED --add-opens=java.base/java.util.concurrent.atomic=ALL-UNNAMED --add-opens=java.xml/javax.xml.namespace=ALL-UNNAMED --add-opens=java.base/java.time=ALL-UNNAMED -XX:+UseParallelGC -Xmx2g -Dfile.encoding=UTF-8 -Duser.country -Duser.language=en (dns block)
- Triggering command: /usr/lib/jvm/temurin-21-jdk-amd64/bin/java /usr/lib/jvm/temurin-21-jdk-amd64/bin/java -XX:+HeapDumpOnOutOfMemoryError -XX:+AlwaysPreTouch @/home/REDACTED/.gradle/.tmp/gradle-worker-classpath189124522246129158txt -Xmx2g -Dfile.encoding=UTF-8 -Duser.country -Duser.language=en -Duser.variant worker.org.gradle.process.internal.worker.GradleWorkerMain 'Gradle Worker Daemon 1' (dns block)

If you need me to access, download, or install something from one of these locations, you can either:

Configure Actions setup steps to set up my environment, which run before the firewall is enabled
Add the appropriate URLs or hosts to the custom allowlist in this repository's Copilot coding agent settings (admins only)

alexandru

@copilot make these changes

alexandru · 2026-02-08T13:02:37Z

...yedqueue-scala/jvm/src/main/scala/org/funfix/delayedqueue/scala/DelayedQueueJDBCConfig.scala

+    tableName: String,
+    time: DelayedQueueTimeConfig,
+    queueName: String,
+    ackEnvSource: String = "",


ackEnvSource: String = "" … bad default. Again, don't do defaults in Scala.

Done in 500a2c5. Removed default parameters from DelayedQueueJDBCConfig (ackEnvSource and retryPolicy).

alexandru · 2026-02-08T13:04:04Z

delayedqueue-scala/jvm/src/main/scala/org/funfix/delayedqueue/scala/RetryConfig.scala

+    *   - 2.0 backoff factor (exponential doubling)
+    */
+  val DEFAULT: RetryConfig =
+    RetryConfig(


Must use the defaults defined in the JVM project

Done in 500a2c5. RetryConfig.DEFAULT and NO_RETRIES now delegate to JVM: jvm.RetryConfig.DEFAULT.asScala and jvm.RetryConfig.NO_RETRIES.asScala. Also removed all default parameters from RetryConfig case class.

- DelayedQueueJDBCConfig: Removed default parameters for ackEnvSource and retryPolicy - RetryConfig: Removed all default parameters (backoffFactor, maxRetries, totalSoftTimeout, perTryHardTimeout) - RetryConfig.DEFAULT and NO_RETRIES now delegate to JVM constants via asScala - Updated tests to provide all required parameters - All 34 tests pass Co-authored-by: alexandru <11753+alexandru@users.noreply.github.com>

Copilot · 2026-02-08T15:01:16Z

Just as a heads up, I was blocked by some firewall rules while working on your feedback. Expand below for details.

Warning

Firewall rules blocked me from connecting to one or more addresses (expand for details)

I tried to connect to the following addresses, but was blocked by firewall rules:

docs.oracle.com
- Triggering command: /usr/lib/jvm/temurin-21-jdk-amd64/bin/java /usr/lib/jvm/temurin-21-jdk-amd64/bin/java --add-opens=java.base/java.lang=ALL-UNNAMED --add-opens=java.base/java.lang.invoke=ALL-UNNAMED --add-opens=java.base/java.util=ALL-UNNAMED --add-opens=java.prefs/java.util.prefs=ALL-UNNAMED --add-exports=jdk.compiler/com.sun.tools.javac.api=ALL-UNNAMED --add-exports=jdk.compiler/com.sun.tools.javac.util=ALL-UNNAMED --add-opens=java.base/java.util=ALL-UNNAMED --add-opens=java.prefs/java.util.prefs=ALL-UNNAMED --add-opens=java.base/java.nio.charset=ALL-UNNAMED --add-opens=java.base/java.net=ALL-UNNAMED --add-opens=java.base/java.util.concurrent=ALL-UNNAMED --add-opens=java.base/java.util.concurrent.atomic=ALL-UNNAMED --add-opens=java.xml/javax.xml.namespace=ALL-UNNAMED --add-opens=java.base/java.time=ALL-UNNAMED -XX:+UseParallelGC -Xmx2g -Dfile.encoding=UTF-8 -Duser.country -Duser.language=en (dns block)
- Triggering command: /usr/lib/jvm/temurin-21-jdk-amd64/bin/java /usr/lib/jvm/temurin-21-jdk-amd64/bin/java -XX:+HeapDumpOnOutOfMemoryError -XX:+AlwaysPreTouch @/home/REDACTED/.gradle/.tmp/gradle-worker-classpath5203184665142321357txt -Xmx2g -Dfile.encoding=UTF-8 -Duser.country -Duser.language=en -Duser.variant worker.org.gradle.process.internal.worker.GradleWorkerMain 'Gradle Worker Daemon 1' (dns block)
kotlinlang.org
- Triggering command: /usr/lib/jvm/temurin-21-jdk-amd64/bin/java /usr/lib/jvm/temurin-21-jdk-amd64/bin/java --add-opens=java.base/java.lang=ALL-UNNAMED --add-opens=java.base/java.lang.invoke=ALL-UNNAMED --add-opens=java.base/java.util=ALL-UNNAMED --add-opens=java.prefs/java.util.prefs=ALL-UNNAMED --add-exports=jdk.compiler/com.sun.tools.javac.api=ALL-UNNAMED --add-exports=jdk.compiler/com.sun.tools.javac.util=ALL-UNNAMED --add-opens=java.base/java.util=ALL-UNNAMED --add-opens=java.prefs/java.util.prefs=ALL-UNNAMED --add-opens=java.base/java.nio.charset=ALL-UNNAMED --add-opens=java.base/java.net=ALL-UNNAMED --add-opens=java.base/java.util.concurrent=ALL-UNNAMED --add-opens=java.base/java.util.concurrent.atomic=ALL-UNNAMED --add-opens=java.xml/javax.xml.namespace=ALL-UNNAMED --add-opens=java.base/java.time=ALL-UNNAMED -XX:+UseParallelGC -Xmx2g -Dfile.encoding=UTF-8 -Duser.country -Duser.language=en (dns block)
- Triggering command: /usr/lib/jvm/temurin-21-jdk-amd64/bin/java /usr/lib/jvm/temurin-21-jdk-amd64/bin/java -XX:+HeapDumpOnOutOfMemoryError -XX:+AlwaysPreTouch @/home/REDACTED/.gradle/.tmp/gradle-worker-classpath5203184665142321357txt -Xmx2g -Dfile.encoding=UTF-8 -Duser.country -Duser.language=en -Duser.variant worker.org.gradle.process.internal.worker.GradleWorkerMain 'Gradle Worker Daemon 1' (dns block)

If you need me to access, download, or install something from one of these locations, you can either:

Configure Actions setup steps to set up my environment, which run before the firewall is enabled
Add the appropriate URLs or hosts to the custom allowlist in this repository's Copilot coding agent settings (admins only)

Initial plan

0c5879e

Copilot AI assigned Copilot and alexandru Feb 8, 2026

Copilot started work on behalf of alexandru February 8, 2026 10:01 View session

Copilot AI and others added 2 commits February 8, 2026 10:17

Copilot AI changed the title ~~[WIP] Execute the plan for delayed queue with JVM public immutable types~~ Add Scala 3 data structures for DelayedQueue with JVM interop Feb 8, 2026

Copilot AI requested a review from alexandru February 8, 2026 10:22

Copilot finished work on behalf of alexandru February 8, 2026 10:22

alexandru requested changes Feb 8, 2026

View reviewed changes

Copilot started work on behalf of alexandru February 8, 2026 10:45 View session

Copilot AI and others added 2 commits February 8, 2026 10:52

Copilot finished work on behalf of alexandru February 8, 2026 10:57

Copilot AI requested a review from alexandru February 8, 2026 10:57

alexandru requested changes Feb 8, 2026

View reviewed changes

Copilot started work on behalf of alexandru February 8, 2026 11:37 View session

Copilot AI requested a review from alexandru February 8, 2026 11:48

Copilot finished work on behalf of alexandru February 8, 2026 11:48

alexandru marked this pull request as ready for review February 8, 2026 13:06

alexandru requested changes Feb 8, 2026

View reviewed changes

Copilot started work on behalf of alexandru February 8, 2026 14:54 View session

Copilot AI requested a review from alexandru February 8, 2026 15:01

Copilot finished work on behalf of alexandru February 8, 2026 15:01

alexandru merged commit 86285cb into scala Feb 8, 2026
4 checks passed

alexandru deleted the copilot/execute-delayedqueue-plan branch February 8, 2026 15:23


		package org.funfix.delayedqueue.scala

		import java.time.Duration


		class ScheduledMessageSpec extends munit.FunSuite {

		test("ScheduledMessage asJava and asScala should be symmetric") {

Conversation

Copilot AI commented Feb 8, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

alexandru left a comment

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Copilot AI Feb 8, 2026

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Copilot AI Feb 8, 2026

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Copilot AI Feb 8, 2026

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Copilot AI Feb 8, 2026

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Copilot AI Feb 8, 2026

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Copilot AI Feb 8, 2026

Choose a reason for hiding this comment

Uh oh!

Copilot AI Feb 8, 2026

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Copilot AI Feb 8, 2026

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Copilot AI Feb 8, 2026

Choose a reason for hiding this comment

Uh oh!

Copilot AI Feb 8, 2026

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Copilot AI Feb 8, 2026

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Copilot AI Feb 8, 2026

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Copilot AI Feb 8, 2026

Choose a reason for hiding this comment

Uh oh!

Copilot AI commented Feb 8, 2026

I tried to connect to the following addresses, but was blocked by firewall rules:

Uh oh!

alexandru left a comment

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Copilot AI Feb 8, 2026

Choose a reason for hiding this comment

Uh oh!

Choose a reason for hiding this comment

Copilot AI commented Feb 8, 2026 •

edited

Loading