sqlx4k-postgres-pgmq/io.github.smyrgeorge.sqlx4k.postgres.pgmq.impl.extensions/send

send

context(db: QueryExecutor)
suspend fun send(queue: String, message: String, headers: Map<String, String> = emptyMap(), delay: Duration = 0.seconds): Result<Long>(source)

context(db: QueryExecutor)
suspend fun send(queue: String, messages: List<String>, headers: Map<String, String> = emptyMap(), delay: Duration = 0.seconds): Result<List<Long>>(source)