spring/io.github.bluegroundltd.springoutbox/SpringTransactionalOutboxBuilder

SpringTransactionalOutboxBuilder

@Component
class SpringTransactionalOutboxBuilder(postgresLockDao: PostgresLockDao, outboxStore: OutboxStore, instantOutboxPublisher: InstantOutboxPublisher) : SpringOutboxClockStep, SpringOutboxHandlersStep, SpringMonitorLocksIdentifierStep, SpringCleanupLocksIdentifierStep

Builder for TransactionalOutbox.

Example on Spring Boot:

fun transactionalOutbox(
  private val springOutboxBuilder: SpringTransactionalOutboxBuilder,
): TransactionalOutbox {
  return springOutboxBuilder
    .withClock(clock)
    .withHandlers(outboxHandlers)
    .withMonitorLocksIdentifier(monitorLocksIdentifier)
    .withCleanupLocksIdentifier(cleanupLocksIdentifier)
    .withThreadPoolSize(threadPoolSize)
    .withThreadPriority(threadPriority)
    .withThreadPoolTimeOut(threadPoolTimeOut)
    .addProcessorDecorator(outboxItemProcessorDecorator)
    .withGroupIdProvider(outboxGroupIdProvider)
    .withGroupingConfiguration(outboxGroupingConfiguration)
    .build()
}
Content copied to clipboard

Constructors

Link copied to clipboard
constructor(postgresLockDao: PostgresLockDao, outboxStore: OutboxStore, instantOutboxPublisher: InstantOutboxPublisher)

Functions

Link copied to clipboard
open override fun withCleanupLocksIdentifier(locksIdentifier: Long): BuildStep

Sets the locks identifier for the outbox cleanup runs.

Link copied to clipboard
open override fun withClock(clock: Clock): SpringOutboxHandlersStep

Sets the clock for the outbox.

Link copied to clipboard
open override fun withHandlers(handlers: Set<OutboxHandler>): SpringMonitorLocksIdentifierStep

Sets the handlers for the outbox.

Link copied to clipboard
open override fun withMonitorLocksIdentifier(locksIdentifier: Long): SpringCleanupLocksIdentifierStep

Sets the locks identifier for the outbox monitor runs.