Implement DelayedQueueInMemory Scala wrapper

[Copilot]

Adds Scala wrapper for DelayedQueueInMemory from the JVM implementation, providing idiomatic Cats Effect API.

Implementation

• DelayedQueueInMemory: Factory object with create[A]() method returning DelayedQueue[A]
• Wrapper pattern: Private class delegates all operations to JVM instance with proper type conversions
• CronService: Wraps JVM cron functionality with Resource[IO, Unit] lifecycle management
• Type conversions: Uses existing asScala/asJava extension patterns for all data types

API

import org.funfix.delayedqueue.scala._
import cats.effect.IO
import java.time.Instant

val queue = DelayedQueueInMemory.create[String](
  timeConfig = DelayedQueueTimeConfig.DEFAULT_IN_MEMORY,
  ackEnvSource = "my-queue"
)

for {
  _ <- queue.offerOrUpdate("key1", "payload", Instant.now().plusSeconds(10))
  envelope <- queue.poll
  _ <- processMessage(envelope.payload)
  _ <- envelope.acknowledge
} yield ()

Key Details

• Kotlin fun interface operators map to override def invoke (not apply)
• IO.interruptible wraps blocking poll() to support cancellation
• Java collections converted via scala.jdk.CollectionConverters

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-classpath7332713649861568576txt -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-classpath7332713649861568576txt -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)

Original prompt

In delayedqueue-scala implement DelayedQueueInMemory by wrapping the JVM version. Ensure that the resulting API is idiomatic Scala and according to project guidelines.

---

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