Pgmq

class Pgmq(pg: IPostgresSQL, options: PgmqClient.Options = PgmqClient.Options())(source)

A wrapper class that provides access to PostgreSQL message queue (PGMQ) functionalities.

This class initializes the necessary parts to interact with a PostgreSQL-backed message queue system. It leverages a database adapter and a PGMQ client to enable message publishing and consumption.

Parameters

pg

An implementation of the IPostgresSQL interface used for database operations.

Properties:

  • client: The primary interface for interacting with the PostgreSQL message queue.

Constructors

Link copied to clipboard
constructor(pg: IPostgresSQL, options: PgmqClient.Options = PgmqClient.Options())

Creates a new instance of the Pgmq class.

Properties

Link copied to clipboard
val client: PgmqClient