spring/io.github.bluegroundltd.springoutbox/TransactionalOutbox

TransactionalOutbox

@Component

class TransactionalOutbox(@Lazy transactionalOutboxInstanceHolder: TransactionalOutboxInstanceHolder)

This bean is just a kotlin wrapper for using transactional outbox. Lazily injects the transactional outbox to avoid circular dependencies. Should be used instead of TransactionalOutbox inside outbox handlers. (no harm if used in other places as well)

Constructors

TransactionalOutbox

constructor(@Lazy transactionalOutboxInstanceHolder: TransactionalOutboxInstanceHolder)

Functions

add

fun add(type: OutboxType, payload: OutboxPayload, shouldPublishAfterInsertion: Boolean = false)

cleanup

fun cleanup()

monitor

fun monitor(id: Long? = null)

shutdown

fun shutdown()