Yorgos S.
10/15/2025, 3:39 PM// Create a client
val client = PgMqClient(pool, "my_queue")
// Send messages
client.send(MyMessage(data = "hello"))
client.sendBatch(listOf(msg1, msg2, msg3))
// Consume messages
val consumer = PgMqConsumer(pool, "my_queue")
consumer.consume { message ->
// Process message
}
// Get queue metrics
val metrics = client.metrics()loke
10/19/2025, 10:32 AMYorgos S.
10/19/2025, 5:20 PMsqlx4k-jdbc