AbstractPgmqEventHandler

abstract class AbstractPgmqEventHandler(pgmq: Pgmq, queue: PgmqClient.Queue, options: PgmqConsumer.Options = DEFAULT_OPTIONS, defaultUser: Principal? = null) : Component(source)

Constructors

constructor(pgmq: Pgmq, queue: PgmqClient.Queue, options: PgmqConsumer.Options = DEFAULT_OPTIONS, defaultUser: Principal? = null)

val log: Logger

val trace: Tracer

context(_: ExecContext, _: QueryExecutor)
suspend fun archive(message: Message): EitherThrowable<Boolean>

context(ec: ExecContext, _: QueryExecutor)
suspend fun archive(msgId: Long): EitherThrowable<Boolean>

open suspend fun ctx(): ExecContext

context(_: ExecContext)
abstract suspend fun EventContext.handler(message: Message)

open suspend fun onFailToAck(e: Throwable)

open suspend fun onFailToNack(e: Throwable)

open suspend fun onFailToRead(e: Throwable)

context(ec: ExecContext, _: QueryExecutor)
suspend fun send(message: String, headers: Map<String, String> = emptyMap(), delay: Duration = 0.seconds): EitherThrowable<Long>

context(ec: ExecContext, _: QueryExecutor)
suspend fun send(headers: Map<String, String> = emptyMap(), delay: Duration = 0.seconds, supplier: () -> String): EitherThrowable<Long>

fun start()

suspend fun stop()