Funfix Database

Delayed Queue

A delayed, high-performance FIFO queue for the JVM, powered by your favorite RDBMS. 💨

• Schedule messages for future delivery
• Poll with an acknowledgement callback; unacked messages get redelivered after a timeout
• More reliable than many message queuing systems (MQ)
• Batch offers for bulk scheduling
• Cron-like scheduling for periodic tasks

Supported database systems:

• H2
• HSQLDB
• MariaDB
• Microsoft SQL Server
• MySQL
• Oracle
• PostgreSQL
• SQLite

Documentation

• Java Usage Guide
• Javadoc
• Internals

---

Maven:

<dependency>
  <groupId>org.funfix</groupId>
  <artifactId>delayedqueue-jvm</artifactId>
  <version>0.4.0</version>
</dependency>

Gradle:

dependencies {
    implementation("org.funfix:delayedqueue-jvm:0.4.0")
}

sbt:

libraryDependencies += "org.funfix" % "delayedqueue-jvm" % "0.4.0"

You will need to add a supported JDBC driver:

• H2: com.h2database:h2
• HSQLDB: org.hsqldb:hsqldb
• MariaDB: org.mariadb.jdbc:mariadb-java-client
• MS-SQL: com.microsoft.sqlserver:mssql-jdbc
• Oracle: com.oracle.database.jdbc:ojdbc11
• PostgreSQL: org.postgresql:postgresql
• SQLite: org.xerial:sqlite-jdbc