PgMqConsumer
constructor(pgmq: PgMqClient, options: PgMqConsumer.Options, onMessage: suspend (Message) -> Unit, onFaiToRead: suspend (Throwable) -> Unit = {}, onFailToProcess: suspend (Throwable) -> Unit = {}, onFaiToAck: suspend (Throwable) -> Unit = {}, onFaiToNack: suspend (Throwable) -> Unit = {})(source)
Creates an instance of PgMqConsumer with the provided PgMq client, configuration options, and callbacks for message processing and error handling.