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